go_micro_srv_template

Documentation

Overview

Package go_micro_srv_template is a generated protocol buffer package.

It is generated from these files:

proto/example/example.proto

It has these top-level messages:

Message
Request
Response
StreamingRequest
StreamingResponse
Ping
Pong

Index

• func RegisterExampleHandler(s server.Server, hdlr ExampleHandler, opts ...server.HandlerOption)
• type ExampleHandler
• type ExampleService
  • func NewExampleService(serviceName string, c client.Client) ExampleService
• type Example_PingPongService
• type Example_PingPongStream
• type Example_StreamService
• type Example_StreamStream

Functions

func RegisterExampleHandler

func RegisterExampleHandler(s server.Server, hdlr ExampleHandler, opts ...server.HandlerOption)

Types

type ExampleHandler

type ExampleHandler interface {
	Call(context.Context, *Request, *Response) error
	Stream(context.Context, *StreamingRequest, Example_StreamStream) error
	PingPong(context.Context, Example_PingPongStream) error
}

type ExampleService

type ExampleService interface {
	Call(ctx context.Context, in *Request, opts ...client.CallOption) (*Response, error)
	Stream(ctx context.Context, in *StreamingRequest, opts ...client.CallOption) (Example_StreamService, error)
	PingPong(ctx context.Context, opts ...client.CallOption) (Example_PingPongService, error)
}

func NewExampleService

func NewExampleService(serviceName string, c client.Client) ExampleService

type Example_PingPongService

type Example_PingPongService interface {
	SendMsg(interface{}) error
	RecvMsg(interface{}) error
	Close() error
	Send(*Ping) error
	Recv() (*Pong, error)
}

type Example_PingPongStream

type Example_PingPongStream interface {
	SendMsg(interface{}) error
	RecvMsg(interface{}) error
	Close() error
	Send(*Pong) error
	Recv() (*Ping, error)
}

type Example_StreamService

type Example_StreamService interface {
	SendMsg(interface{}) error
	RecvMsg(interface{}) error
	Close() error
	Recv() (*StreamingResponse, error)
}

type Example_StreamStream

type Example_StreamStream interface {
	SendMsg(interface{}) error
	RecvMsg(interface{}) error
	Close() error
	Send(*StreamingResponse) error
}