pkg/proto/websockets/v1beta/websockets.proto


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

syntax = "proto3";

package websockets.v1beta;
option go_package = "./;websocketsv1beta";

message Message {
    string command = 1;
    string broker = 2;
    repeated string topics = 3;
    bytes payload = 4;
}

// RPC request with messages
message Request {
    repeated Message messages = 1;
}

// RPC response (false in case of error)
message Response {
    bool ok = 1;
}