From 4a16c941b74d60d67a1ef3bef61b0d575c3d1c54 Mon Sep 17 00:00:00 2001 From: Casey Brooks Date: Thu, 23 Apr 2026 18:01:12 +0000 Subject: [PATCH 1/2] feat(runners): add log stream rpc --- proto/agynio/api/runners/v1/runners.proto | 5 +++++ proto/agynio/api/ziti_management/v1/ziti_management.proto | 1 + 2 files changed, 6 insertions(+) diff --git a/proto/agynio/api/runners/v1/runners.proto b/proto/agynio/api/runners/v1/runners.proto index 055b1c0..a7c10d8 100644 --- a/proto/agynio/api/runners/v1/runners.proto +++ b/proto/agynio/api/runners/v1/runners.proto @@ -2,6 +2,7 @@ syntax = "proto3"; package agynio.api.runners.v1; +import "agynio/api/runner/v1/runner.proto"; import "google/protobuf/timestamp.proto"; option go_package = "github.com/agynio/api/gen/agynio/api/runners/v1;runnersv1"; @@ -28,6 +29,10 @@ service RunnersService { rpc ListWorkloads(ListWorkloadsRequest) returns (ListWorkloadsResponse); rpc BatchUpdateWorkloadSampledAt(BatchUpdateWorkloadSampledAtRequest) returns (BatchUpdateWorkloadSampledAtResponse); + // --- Workload logs --- + rpc StreamWorkloadLogs(agynio.api.runner.v1.StreamWorkloadLogsRequest) + returns (stream agynio.api.runner.v1.StreamWorkloadLogsResponse); + // --- Volume state --- rpc CreateVolume(CreateVolumeRequest) returns (CreateVolumeResponse); rpc UpdateVolume(UpdateVolumeRequest) returns (UpdateVolumeResponse); diff --git a/proto/agynio/api/ziti_management/v1/ziti_management.proto b/proto/agynio/api/ziti_management/v1/ziti_management.proto index 6eb7261..3d968e2 100644 --- a/proto/agynio/api/ziti_management/v1/ziti_management.proto +++ b/proto/agynio/api/ziti_management/v1/ziti_management.proto @@ -74,6 +74,7 @@ enum ServiceType { SERVICE_TYPE_ORCHESTRATOR = 2; SERVICE_TYPE_LLM_PROXY = 4; SERVICE_TYPE_TRACING = 5; + SERVICE_TYPE_RUNNERS = 6; reserved 3; reserved "SERVICE_TYPE_RUNNER"; } From 63b7446cb87c9a1a607a272094187c063307e02b Mon Sep 17 00:00:00 2001 From: Casey Brooks Date: Thu, 23 Apr 2026 18:21:53 +0000 Subject: [PATCH 2/2] style(api): format runners proto --- proto/agynio/api/runners/v1/runners.proto | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/proto/agynio/api/runners/v1/runners.proto b/proto/agynio/api/runners/v1/runners.proto index a7c10d8..9f1c8ea 100644 --- a/proto/agynio/api/runners/v1/runners.proto +++ b/proto/agynio/api/runners/v1/runners.proto @@ -30,8 +30,7 @@ service RunnersService { rpc BatchUpdateWorkloadSampledAt(BatchUpdateWorkloadSampledAtRequest) returns (BatchUpdateWorkloadSampledAtResponse); // --- Workload logs --- - rpc StreamWorkloadLogs(agynio.api.runner.v1.StreamWorkloadLogsRequest) - returns (stream agynio.api.runner.v1.StreamWorkloadLogsResponse); + rpc StreamWorkloadLogs(agynio.api.runner.v1.StreamWorkloadLogsRequest) returns (stream agynio.api.runner.v1.StreamWorkloadLogsResponse); // --- Volume state --- rpc CreateVolume(CreateVolumeRequest) returns (CreateVolumeResponse);