Documentation ¶
Overview ¶
Package yupi is a generated protocol buffer package.
It is generated from these files:
proto/servicepq.proto
It has these top-level messages:
MessageRequest MessageResponse
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterCreatorServer ¶
func RegisterCreatorServer(s *grpc.Server, srv CreatorServer)
Types ¶
type CreatorClient ¶
type CreatorClient interface { Create(ctx context.Context, in *MessageRequest, opts ...grpc.CallOption) (*MessageResponse, error) CreateByStream(ctx context.Context, opts ...grpc.CallOption) (Creator_CreateByStreamClient, error) }
func NewCreatorClient ¶
func NewCreatorClient(cc *grpc.ClientConn) CreatorClient
type CreatorServer ¶
type CreatorServer interface { Create(context.Context, *MessageRequest) (*MessageResponse, error) CreateByStream(Creator_CreateByStreamServer) error }
type Creator_CreateByStreamClient ¶
type Creator_CreateByStreamClient interface { Send(*MessageRequest) error Recv() (*MessageResponse, error) grpc.ClientStream }
type Creator_CreateByStreamServer ¶
type Creator_CreateByStreamServer interface { Send(*MessageResponse) error Recv() (*MessageRequest, error) grpc.ServerStream }
type MessageRequest ¶
type MessageRequest struct {
Msg string `protobuf:"bytes,1,opt,name=msg" json:"msg,omitempty"`
}
func (*MessageRequest) Descriptor ¶
func (*MessageRequest) Descriptor() ([]byte, []int)
func (*MessageRequest) ProtoMessage ¶
func (*MessageRequest) ProtoMessage()
func (*MessageRequest) Reset ¶
func (m *MessageRequest) Reset()
func (*MessageRequest) String ¶
func (m *MessageRequest) String() string
type MessageResponse ¶
type MessageResponse struct { Id int64 `protobuf:"varint,1,opt,name=id" json:"id,omitempty"` Time string `protobuf:"bytes,2,opt,name=time" json:"time,omitempty"` Msg string `protobuf:"bytes,3,opt,name=msg" json:"msg,omitempty"` }
func (*MessageResponse) Descriptor ¶
func (*MessageResponse) Descriptor() ([]byte, []int)
func (*MessageResponse) ProtoMessage ¶
func (*MessageResponse) ProtoMessage()
func (*MessageResponse) Reset ¶
func (m *MessageResponse) Reset()
func (*MessageResponse) String ¶
func (m *MessageResponse) String() string
Click to show internal directories.
Click to hide internal directories.