pb_broker

type MessageClient interface {
	Publish(ctx context.Context, in *PubReq, opts ...grpc.CallOption) (*PubResp, error)
	Subscribe(ctx context.Context, in *SubReq, opts ...grpc.CallOption) (Message_SubscribeClient, error)
	Ping(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*empty.Empty, error)
}

type MessageServer interface {
	Publish(context.Context, *PubReq) (*PubResp, error)
	Subscribe(*SubReq, Message_SubscribeServer) error
	Ping(context.Context, *empty.Empty) (*empty.Empty, error)
}

type Message_SubscribeClient interface {
	Recv() (*PubReq, error)
	grpc.ClientStream
}

type Message_SubscribeServer interface {
	Send(*PubReq) error
	grpc.ServerStream
}

type PubReq struct {
	Topic string   `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	Req   *any.Any `protobuf:"bytes,2,opt,name=req,proto3" json:"req,omitempty"`
	Resp  *any.Any `protobuf:"bytes,3,opt,name=resp,proto3" json:"resp,omitempty"`
	// contains filtered or unexported fields
}

type PubResp struct {
	Status int32 `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

type SubReq struct {

	// Types that are assignable to Oneof:
	//	*SubReq_Topic
	//	*SubReq_Topics
	Oneof isSubReq_Oneof `protobuf_oneof:"Oneof"`
	// contains filtered or unexported fields
}

type SubReq_Topic struct {
	Topic string `protobuf:"bytes,1,opt,name=topic,proto3,oneof"`
}

type SubReq_Topics struct {
	Topics *Topics `protobuf:"bytes,2,opt,name=topics,proto3,oneof"`
}

type Topics struct {
	Topics []string `protobuf:"bytes,1,rep,name=topics,proto3" json:"topics,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedMessageServer struct {
}