Documentation
¶
Overview ¶
Package go_micro_srv_message is a generated protocol buffer package.
It is generated from these files:
github.com/microhq/message-api/proto/message/message.proto
It has these top-level messages:
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterMessageHandler ¶
func RegisterMessageHandler(s server.Server, hdlr MessageHandler, opts ...server.HandlerOption) error
func RegisterMessageServer ¶
func RegisterMessageServer(s *grpc.Server, srv MessageServer)
Types ¶
type MessageClient ¶
type MessageClient interface {
Create(ctx context.Context, in *proto1.Request, opts ...grpc.CallOption) (*proto1.Response, error)
Delete(ctx context.Context, in *proto1.Request, opts ...grpc.CallOption) (*proto1.Response, error)
Update(ctx context.Context, in *proto1.Request, opts ...grpc.CallOption) (*proto1.Response, error)
Search(ctx context.Context, in *proto1.Request, opts ...grpc.CallOption) (*proto1.Response, error)
Read(ctx context.Context, in *proto1.Request, opts ...grpc.CallOption) (*proto1.Response, error)
}
MessageClient is the client API for Message service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewMessageClient ¶
func NewMessageClient(cc *grpc.ClientConn) MessageClient
type MessageHandler ¶
type MessageHandler interface {
Create(context.Context, *go_api.Request, *go_api.Response) error
Delete(context.Context, *go_api.Request, *go_api.Response) error
Update(context.Context, *go_api.Request, *go_api.Response) error
Search(context.Context, *go_api.Request, *go_api.Response) error
Read(context.Context, *go_api.Request, *go_api.Response) error
}
type MessageServer ¶
type MessageServer interface {
Create(context.Context, *proto1.Request) (*proto1.Response, error)
Delete(context.Context, *proto1.Request) (*proto1.Response, error)
Update(context.Context, *proto1.Request) (*proto1.Response, error)
Search(context.Context, *proto1.Request) (*proto1.Response, error)
Read(context.Context, *proto1.Request) (*proto1.Response, error)
}
MessageServer is the server API for Message service.
type MessageService ¶
type MessageService interface {
Create(ctx context.Context, in *go_api.Request, opts ...client.CallOption) (*go_api.Response, error)
Delete(ctx context.Context, in *go_api.Request, opts ...client.CallOption) (*go_api.Response, error)
Update(ctx context.Context, in *go_api.Request, opts ...client.CallOption) (*go_api.Response, error)
Search(ctx context.Context, in *go_api.Request, opts ...client.CallOption) (*go_api.Response, error)
Read(ctx context.Context, in *go_api.Request, opts ...client.CallOption) (*go_api.Response, error)
}
func NewMessageService ¶
func NewMessageService(name string, c client.Client) MessageService
Source Files
Click to show internal directories.
Click to hide internal directories.