Versions in this module Expand all Collapse all v1 v1.0.5 Feb 10, 2023 v1.0.4 Feb 10, 2023 v1.0.3 Feb 9, 2023 v1.0.2 Feb 9, 2023 v1.0.1 Feb 9, 2023 Changes in this version + var File_ysgrpc_proto_MQ_proto protoreflect.FileDescriptor + var File_ysgrpc_proto_helloworld_proto protoreflect.FileDescriptor + var Greeter_ServiceDesc = grpc.ServiceDesc + var MQ_ServiceDesc = grpc.ServiceDesc + func RegisterGreeterServer(s grpc.ServiceRegistrar, srv GreeterServer) + func RegisterMQServer(s grpc.ServiceRegistrar, srv MQServer) + type GreeterClient interface + SayHello func(ctx context.Context, in *HelloRequest, opts ...grpc.CallOption) (*HelloReply, error) + func NewGreeterClient(cc grpc.ClientConnInterface) GreeterClient + type GreeterServer interface + SayHello func(context.Context, *HelloRequest) (*HelloReply, error) + type HelloReply struct + Message string + func (*HelloReply) Descriptor() ([]byte, []int) + func (*HelloReply) ProtoMessage() + func (x *HelloReply) GetMessage() string + func (x *HelloReply) ProtoReflect() protoreflect.Message + func (x *HelloReply) Reset() + func (x *HelloReply) String() string + type HelloRequest struct + Name string + func (*HelloRequest) Descriptor() ([]byte, []int) + func (*HelloRequest) ProtoMessage() + func (x *HelloRequest) GetName() string + func (x *HelloRequest) ProtoReflect() protoreflect.Message + func (x *HelloRequest) Reset() + func (x *HelloRequest) String() string + type MQClient interface + Pub func(ctx context.Context, in *Message, opts ...grpc.CallOption) (*PubReply, error) + Sub func(ctx context.Context, in *SubRequest, opts ...grpc.CallOption) (MQ_SubClient, error) + UnSub func(ctx context.Context, in *UnSubRequest, opts ...grpc.CallOption) (*Message, error) + func NewMQClient(cc grpc.ClientConnInterface) MQClient + type MQServer interface + Pub func(context.Context, *Message) (*PubReply, error) + Sub func(*SubRequest, MQ_SubServer) error + UnSub func(context.Context, *UnSubRequest) (*Message, error) + type MQ_SubClient interface + Recv func() (*Message, error) + type MQ_SubServer interface + Send func(*Message) error + type Message struct + Message []byte + Topic string + func (*Message) Descriptor() ([]byte, []int) + func (*Message) ProtoMessage() + func (x *Message) GetMessage() []byte + func (x *Message) GetTopic() string + func (x *Message) ProtoReflect() protoreflect.Message + func (x *Message) Reset() + func (x *Message) String() string + type PubReply struct + Num int32 + func (*PubReply) Descriptor() ([]byte, []int) + func (*PubReply) ProtoMessage() + func (x *PubReply) GetNum() int32 + func (x *PubReply) ProtoReflect() protoreflect.Message + func (x *PubReply) Reset() + func (x *PubReply) String() string + type SubRequest struct + Topics string + func (*SubRequest) Descriptor() ([]byte, []int) + func (*SubRequest) ProtoMessage() + func (x *SubRequest) GetTopics() string + func (x *SubRequest) ProtoReflect() protoreflect.Message + func (x *SubRequest) Reset() + func (x *SubRequest) String() string + type UnSubRequest struct + Id int32 + func (*UnSubRequest) Descriptor() ([]byte, []int) + func (*UnSubRequest) ProtoMessage() + func (x *UnSubRequest) GetId() int32 + func (x *UnSubRequest) ProtoReflect() protoreflect.Message + func (x *UnSubRequest) Reset() + func (x *UnSubRequest) String() string + type UnimplementedGreeterServer struct + func (UnimplementedGreeterServer) SayHello(context.Context, *HelloRequest) (*HelloReply, error) + type UnimplementedMQServer struct + func (UnimplementedMQServer) Pub(context.Context, *Message) (*PubReply, error) + func (UnimplementedMQServer) Sub(*SubRequest, MQ_SubServer) error + func (UnimplementedMQServer) UnSub(context.Context, *UnSubRequest) (*Message, error) + type UnsafeGreeterServer interface + type UnsafeMQServer interface