go_micro_srv_message

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

• func RegisterMessageHandler(s server.Server, hdlr MessageHandler, opts ...server.HandlerOption) error
• func RegisterMessageServer(s *grpc.Server, srv MessageServer)
• type MessageClient
  • func NewMessageClient(cc *grpc.ClientConn) MessageClient
• type MessageHandler
• type MessageServer
• type MessageService
  • func NewMessageService(name string, c client.Client) MessageService

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