Changeset View
Changeset View
Standalone View
Standalone View
python_modules/dagster/dagster/grpc/protos/api.proto
| // If you make changes to this file, run "python -m dagster.grpc.compile" after. | // If you make changes to this file, run "python -m dagster.grpc.compile" after. | ||||
| syntax = "proto3"; | syntax = "proto3"; | ||||
| package api; | package api; | ||||
| service DagsterApi { | service DagsterApi { | ||||
| rpc Ping (PingRequest) returns (PingReply) {} | rpc Ping (PingRequest) returns (PingReply) {} | ||||
| rpc Heartbeat (PingRequest) returns (PingReply) {} | rpc Heartbeat (PingRequest) returns (PingReply) {} | ||||
| rpc StreamingPing (StreamingPingRequest) returns (stream StreamingPingEvent) {} | rpc StreamingPing (StreamingPingRequest) returns (stream StreamingPingEvent) {} | ||||
| rpc GetServerId (Empty) returns (GetServerIdReply) {} | |||||
| rpc ExecutionPlanSnapshot (ExecutionPlanSnapshotRequest) returns (ExecutionPlanSnapshotReply) {} | rpc ExecutionPlanSnapshot (ExecutionPlanSnapshotRequest) returns (ExecutionPlanSnapshotReply) {} | ||||
| rpc ListRepositories (ListRepositoriesRequest) returns (ListRepositoriesReply) {} | rpc ListRepositories (ListRepositoriesRequest) returns (ListRepositoriesReply) {} | ||||
| rpc ExternalPartitionNames (ExternalPartitionNamesRequest) returns (ExternalPartitionNamesReply) {} | rpc ExternalPartitionNames (ExternalPartitionNamesRequest) returns (ExternalPartitionNamesReply) {} | ||||
| rpc ExternalPartitionConfig (ExternalPartitionConfigRequest) returns (ExternalPartitionConfigReply) {} | rpc ExternalPartitionConfig (ExternalPartitionConfigRequest) returns (ExternalPartitionConfigReply) {} | ||||
| rpc ExternalPartitionTags (ExternalPartitionTagsRequest) returns (ExternalPartitionTagsReply) {} | rpc ExternalPartitionTags (ExternalPartitionTagsRequest) returns (ExternalPartitionTagsReply) {} | ||||
| rpc ExternalPartitionSetExecutionParams (ExternalPartitionSetExecutionParamsRequest) returns (ExternalPartitionSetExecutionParamsReply) {} | rpc ExternalPartitionSetExecutionParams (ExternalPartitionSetExecutionParamsRequest) returns (ExternalPartitionSetExecutionParamsReply) {} | ||||
| rpc ExternalPipelineSubsetSnapshot (ExternalPipelineSubsetSnapshotRequest) returns (ExternalPipelineSubsetSnapshotReply) {} | rpc ExternalPipelineSubsetSnapshot (ExternalPipelineSubsetSnapshotRequest) returns (ExternalPipelineSubsetSnapshotReply) {} | ||||
| rpc ExternalRepository (ExternalRepositoryRequest) returns (ExternalRepositoryReply) {} | rpc ExternalRepository (ExternalRepositoryRequest) returns (ExternalRepositoryReply) {} | ||||
| Show All 22 Lines | message StreamingPingRequest { | ||||
| string echo = 2; | string echo = 2; | ||||
| } | } | ||||
| message StreamingPingEvent { | message StreamingPingEvent { | ||||
| int32 sequence_number = 1; | int32 sequence_number = 1; | ||||
| string echo = 2; | string echo = 2; | ||||
| } | } | ||||
| message GetServerIdReply { | |||||
| string server_id = 1; | |||||
| } | |||||
| message ExecutionPlanSnapshotRequest { | message ExecutionPlanSnapshotRequest { | ||||
| string serialized_execution_plan_snapshot_args = 1; | string serialized_execution_plan_snapshot_args = 1; | ||||
| } | } | ||||
| message ExecutionPlanSnapshotReply { | message ExecutionPlanSnapshotReply { | ||||
| string serialized_execution_plan_snapshot = 1; | string serialized_execution_plan_snapshot = 1; | ||||
| } | } | ||||
| ▲ Show 20 Lines • Show All 107 Lines • Show Last 20 Lines | |||||