Versions in this module Expand all Collapse all v0 v0.2.0 Oct 18, 2021 v0.1.0 Nov 17, 2020 Changes in this version + func RegisterMQServer(s *grpc.Server, srv MQServer) + type MQClient interface + Pub func(ctx context.Context, in *PubRequest, opts ...grpc.CallOption) (*PubResponse, error) + Sub func(ctx context.Context, in *SubRequest, opts ...grpc.CallOption) (MQ_SubClient, error) + func NewMQClient(cc *grpc.ClientConn) MQClient + type MQServer interface + Pub func(context.Context, *PubRequest) (*PubResponse, error) + Sub func(*SubRequest, MQ_SubServer) error + type MQ_SubClient interface + Recv func() (*SubResponse, error) + type MQ_SubServer interface + Send func(*SubResponse) error + type PubRequest struct + Payload []byte + Topic string + func (*PubRequest) Descriptor() ([]byte, []int) + func (*PubRequest) ProtoMessage() + func (m *PubRequest) Reset() + func (m *PubRequest) String() string + type PubResponse struct + func (*PubResponse) Descriptor() ([]byte, []int) + func (*PubResponse) ProtoMessage() + func (m *PubResponse) Reset() + func (m *PubResponse) String() string + type SubRequest struct + Topic string + func (*SubRequest) Descriptor() ([]byte, []int) + func (*SubRequest) ProtoMessage() + func (m *SubRequest) Reset() + func (m *SubRequest) String() string + type SubResponse struct + Payload []byte + func (*SubResponse) Descriptor() ([]byte, []int) + func (*SubResponse) ProtoMessage() + func (m *SubResponse) Reset() + func (m *SubResponse) String() string