Dealer/pkg/proto/stream.proto

49 lines
1017 B
Protocol Buffer
Raw Normal View History

2024-07-14 15:45:18 +00:00
syntax = "proto3";
option go_package = ".;proto";
package proto;
service StreamController {
rpc CountStreamConnection(CountConnectionRequest) returns (CountConnectionResponse) {}
2024-07-14 15:45:18 +00:00
rpc PushStream(PushStreamRequest) returns (PushStreamResponse) {}
rpc PushStreamBatch(PushStreamBatchRequest) returns (PushStreamResponse) {}
rpc EmitStreamEvent(StreamEventRequest) returns (StreamEventResponse) {}
2024-07-14 15:45:18 +00:00
}
message CountConnectionRequest {
uint64 user_id = 1;
}
message CountConnectionResponse {
int64 count = 1;
}
2024-07-14 15:45:18 +00:00
message PushStreamRequest {
optional uint64 user_id = 1;
optional uint64 client_id = 2;
bytes body = 3;
2024-07-14 15:45:18 +00:00
}
message PushStreamBatchRequest {
repeated uint64 user_id = 1;
repeated uint64 client_id = 2;
bytes body = 3;
}
2024-07-14 15:45:18 +00:00
message PushStreamResponse {
bool is_all_success = 1;
int64 affected_count = 2;
int64 failed_count = 3;
}
message StreamEventRequest {
string event = 1;
uint64 user_id = 2;
uint64 client_id = 3;
bytes payload = 4;
}
message StreamEventResponse {
}