Skip to content

Commit

Permalink
fix
Browse files Browse the repository at this point in the history
  • Loading branch information
Rustin170506 committed Jul 5, 2024
1 parent 8de06a3 commit 6b1effa
Showing 1 changed file with 29 additions and 29 deletions.
58 changes: 29 additions & 29 deletions console-api/proto/instrument.proto
Original file line number Diff line number Diff line change
Expand Up @@ -10,14 +10,14 @@ import "async_ops.proto";

// `InstrumentServer<T>` implements `Instrument` as a service.
service Instrument {
// Produces a stream of updates representing the behavior of the instrumented async runtime.
rpc WatchUpdates(InstrumentRequest) returns (stream Update) {}
// Produces a stream of updates describing the activity of a specific task.
rpc WatchTaskDetails(TaskDetailsRequest) returns (stream tasks.TaskDetails) {}
// Registers that the console observer wants to pause the stream.
rpc Pause(PauseRequest) returns (PauseResponse) {}
// Registers that the console observer wants to resume the stream.
rpc Resume(ResumeRequest) returns (ResumeResponse) {}
// Produces a stream of updates representing the behavior of the instrumented async runtime.
rpc WatchUpdates(InstrumentRequest) returns (stream Update) {}
// Produces a stream of updates describing the activity of a specific task.
rpc WatchTaskDetails(TaskDetailsRequest) returns (stream tasks.TaskDetails) {}
// Registers that the console observer wants to pause the stream.
rpc Pause(PauseRequest) returns (PauseResponse) {}
// Registers that the console observer wants to resume the stream.
rpc Resume(ResumeRequest) returns (ResumeResponse) {}
}

// InstrumentRequest requests the stream of updates
Expand All @@ -32,8 +32,8 @@ message InstrumentRequest {
// TaskDetailsRequest requests the stream of updates about
// the specific task identified in the request.
message TaskDetailsRequest {
// Identifies the task for which details were requested.
common.Id id = 1;
// Identifies the task for which details were requested.
common.Id id = 1;
}

// PauseRequest requests the stream of updates to pause.
Expand All @@ -53,34 +53,34 @@ message ResumeRequest {
// - things such as async ops and resource ops do not make sense
// on their own as they have relations to tasks and resources
message Update {
// The system time when this update was recorded.
//
// This is the timestamp any durations in the included `Stats` were
// calculated relative to.
google.protobuf.Timestamp now = 1;
// The system time when this update was recorded.
//
// This is the timestamp any durations in the included `Stats` were
// calculated relative to.
google.protobuf.Timestamp now = 1;

// Task state update.
tasks.TaskUpdate task_update = 2;
// Task state update.
tasks.TaskUpdate task_update = 2;

// Resource state update.
resources.ResourceUpdate resource_update = 3;
// Resource state update.
resources.ResourceUpdate resource_update = 3;

// Async operations state update
async_ops.AsyncOpUpdate async_op_update = 4;
// Async operations state update
async_ops.AsyncOpUpdate async_op_update = 4;

// Any new span metadata that was registered since the last update.
common.RegisterMetadata new_metadata = 5;
// Any new span metadata that was registered since the last update.
common.RegisterMetadata new_metadata = 5;

// The time "state" of the aggregator, such as paused or live.
Temporality temporality = 6;
// The time "state" of the aggregator, such as paused or live.
Temporality temporality = 6;
}

// The time "state" of the aggregator.
enum Temporality {
// The aggregator is currently live.
LIVE = 0;
// The aggregator is currently paused.
PAUSED = 1;
// The aggregator is currently live.
LIVE = 0;
// The aggregator is currently paused.
PAUSED = 1;
}

// `PauseResponse` is the value returned after a pause request.
Expand Down

0 comments on commit 6b1effa

Please sign in to comment.