47 lines
963 B
Protocol Buffer
47 lines
963 B
Protocol Buffer
syntax = "proto3";
|
|
|
|
import "google/protobuf/timestamp.proto";
|
|
|
|
package nodata.v1;
|
|
|
|
service NoDataService {
|
|
rpc PublishEvent(PublishEventRequest) returns (PublishEventResponse) {}
|
|
rpc GetTopics(GetTopicsRequest) returns (GetTopicsResponse) {}
|
|
rpc GetKeys(GetKeysRequest) returns (GetKeysResponse) {}
|
|
rpc Subscribe(SubscribeRequest) returns (stream SubscribeResponse){}
|
|
}
|
|
|
|
message PublishEventRequest {
|
|
string topic = 1;
|
|
google.protobuf.Timestamp published = 2;
|
|
string key = 3;
|
|
bytes value = 4;
|
|
optional string id = 5;
|
|
}
|
|
|
|
message PublishEventResponse {
|
|
|
|
}
|
|
|
|
message GetTopicsRequest {}
|
|
message GetTopicsResponse {
|
|
repeated string topics = 1;
|
|
}
|
|
message GetKeysRequest {
|
|
string topic = 1;
|
|
}
|
|
message GetKeysResponse {
|
|
repeated string keys = 1;
|
|
}
|
|
|
|
message SubscribeRequest {
|
|
string topic = 1;
|
|
string key = 2;
|
|
}
|
|
message SubscribeResponse{
|
|
string id = 1;
|
|
google.protobuf.Timestamp published = 2;
|
|
uint64 offset = 3;
|
|
bytes value = 4;
|
|
}
|