<?php

require_once __DIR__ . '/vendor/autoload.php';

use Google\Async\AsyncBatchRunner;
use Google\Cloud\Logging\LoggingClient;

$c = function($items = []) {
    $c = new LoggingClient();
    $logger = $c->logger('my-log', [
        'resource' => [
            'type' => 'gcs_bucket',
            'labels' => [
                'bucket_name' => 'my_bucket'
            ]
        ]
    ]);
    $logger->writeBatch($items);
};

if (count($argv) === 2) {
    $num = intval($argv[1]);
} else {
    $num = 1;
}

$r = new AsyncBatchRunner();
$r->registerjob(
    'logging',
    $c,
    array(
        'workerNum' => $num,
        'batchSize' => 1000
    )
);