@@ -179,15 +179,15 @@ use Arcp\Envelope\Envelope;
179179use Arcp\Messages\Execution\JobProgress;
180180use Arcp\Messages\Execution\ResultChunk;
181181use Arcp\Messages\Telemetry\EventEmit;
182- use Arcp\Messages\Telemetry\LogRecord ;
183- use Arcp\Messages\Telemetry\Metric ;
182+ use Arcp\Messages\Telemetry\LogEvent ;
183+ use Arcp\Messages\Telemetry\MetricEvent ;
184184
185185$client->subscribe(
186186 ['session_id' => [(string) $client->session->sessionId]],
187187 static function (Envelope $env) use ($client): void {
188188 match (true) {
189- $env->payload instanceof LogRecord => printf("[log] %s\n", $env->payload->message),
190- $env->payload instanceof Metric => printf("[metric] %s=%s %s\n", $env->payload->name, $env->payload->value, $env->payload->unit ?? '' ),
189+ $env->payload instanceof LogEvent => printf("[log] %s\n", $env->payload->message),
190+ $env->payload instanceof MetricEvent => printf("[metric] %s=%s %s\n", $env->payload->name, $env->payload->value, $env->payload->unit),
191191 $env->payload instanceof JobProgress => printf("[progress %d%%] %s\n", $env->payload->percent, $env->payload->message ?? ''),
192192 $env->payload instanceof ResultChunk => $client->resultChunks->push($env->payload),
193193 $env->payload instanceof EventEmit => printf("[event] %s\n", $env->payload->eventType),
@@ -204,13 +204,13 @@ Request capabilities, a budget, and an expiry; read budget-remaining metrics as
204204``` php
205205use Arcp\Envelope\Envelope;
206206use Arcp\Errors\BudgetExhaustedException;
207- use Arcp\Messages\Telemetry\Metric ;
207+ use Arcp\Messages\Telemetry\MetricEvent ;
208208
209209$client->subscribe(
210210 ['types' => ['metric']],
211211 static function (Envelope $env): void {
212- if ($env->payload instanceof Metric && $env->payload->name === 'cost.budget.remaining') {
213- printf("budget remaining: %.2f %s\n", $env->payload->value, $env->payload->unit ?? '' );
212+ if ($env->payload instanceof MetricEvent && $env->payload->name === 'cost.budget.remaining') {
213+ printf("budget remaining: %.2f %s\n", $env->payload->value, $env->payload->unit);
214214 }
215215 },
216216);
0 commit comments