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;
}