messageBusService.proto

syntax = "proto3";
package msgbus;

// =====================================================================================================================
//  Shared
// =====================================================================================================================

message SubscriberInfo {
    repeated string topics = 2;
    string addr = 3;
}

message Error {
    string message = 1;
}

service messageBusService {
    rpc Subscribe (SubscriberInfo) returns (Error);
    rpc Unsubscribe (SubscriberInfo) returns (Error);
}