go_micro_srv_template

package
v0.0.0-...-e01b0a5 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 6, 2017 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Overview

Package go_micro_srv_template is a generated protocol buffer package.

It is generated from these files:

github.com/micro/examples/template/srv/proto/example/example.proto

It has these top-level messages:

Message
Request
Response
StreamingRequest
StreamingResponse
Ping
Pong

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterExampleHandler

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

func RegisterSubscriber

func RegisterSubscriber(topic string, s server.Server, h interface{}, opts ...server.SubscriberOption) error

Types

type Example

type Example struct {
	ExampleHandler
}

func (*Example) Call

func (h *Example) Call(ctx context.Context, in *Request, out *Response) error

func (*Example) PingPong

func (h *Example) PingPong(ctx context.Context, stream server.Streamer) error

func (*Example) Stream

func (h *Example) Stream(ctx context.Context, stream server.Streamer) error

type ExampleClient

type ExampleClient interface {
	Call(ctx context.Context, in *Request, opts ...client.CallOption) (*Response, error)
	Stream(ctx context.Context, in *StreamingRequest, opts ...client.CallOption) (Example_StreamClient, error)
	PingPong(ctx context.Context, opts ...client.CallOption) (Example_PingPongClient, error)
}

func NewExampleClient

func NewExampleClient(serviceName string, c client.Client) ExampleClient

type Example_PingPongClient

type Example_PingPongClient 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_StreamClient

type Example_StreamClient 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
}

type Message

type Message struct {
	Say string `protobuf:"bytes,1,opt,name=say" json:"say,omitempty"`
}

func (*Message) Descriptor

func (*Message) Descriptor() ([]byte, []int)

func (*Message) GetSay

func (m *Message) GetSay() string

func (*Message) ProtoMessage

func (*Message) ProtoMessage()

func (*Message) Reset

func (m *Message) Reset()

func (*Message) String

func (m *Message) String() string

type Ping

type Ping struct {
	Stroke int64 `protobuf:"varint,1,opt,name=stroke" json:"stroke,omitempty"`
}

func (*Ping) Descriptor

func (*Ping) Descriptor() ([]byte, []int)

func (*Ping) GetStroke

func (m *Ping) GetStroke() int64

func (*Ping) ProtoMessage

func (*Ping) ProtoMessage()

func (*Ping) Reset

func (m *Ping) Reset()

func (*Ping) String

func (m *Ping) String() string

type Pong

type Pong struct {
	Stroke int64 `protobuf:"varint,1,opt,name=stroke" json:"stroke,omitempty"`
}

func (*Pong) Descriptor

func (*Pong) Descriptor() ([]byte, []int)

func (*Pong) GetStroke

func (m *Pong) GetStroke() int64

func (*Pong) ProtoMessage

func (*Pong) ProtoMessage()

func (*Pong) Reset

func (m *Pong) Reset()

func (*Pong) String

func (m *Pong) String() string

type Publisher

type Publisher interface {
	Publish(ctx context.Context, msg interface{}, opts ...client.PublishOption) error
}

func NewPublisher

func NewPublisher(topic string, c client.Client) Publisher

type Request

type Request struct {
	Name string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
}

func (*Request) Descriptor

func (*Request) Descriptor() ([]byte, []int)

func (*Request) GetName

func (m *Request) GetName() string

func (*Request) ProtoMessage

func (*Request) ProtoMessage()

func (*Request) Reset

func (m *Request) Reset()

func (*Request) String

func (m *Request) String() string

type Response

type Response struct {
	Msg string `protobuf:"bytes,1,opt,name=msg" json:"msg,omitempty"`
}

func (*Response) Descriptor

func (*Response) Descriptor() ([]byte, []int)

func (*Response) GetMsg

func (m *Response) GetMsg() string

func (*Response) ProtoMessage

func (*Response) ProtoMessage()

func (*Response) Reset

func (m *Response) Reset()

func (*Response) String

func (m *Response) String() string

type StreamingRequest

type StreamingRequest struct {
	Count int64 `protobuf:"varint,1,opt,name=count" json:"count,omitempty"`
}

func (*StreamingRequest) Descriptor

func (*StreamingRequest) Descriptor() ([]byte, []int)

func (*StreamingRequest) GetCount

func (m *StreamingRequest) GetCount() int64

func (*StreamingRequest) ProtoMessage

func (*StreamingRequest) ProtoMessage()

func (*StreamingRequest) Reset

func (m *StreamingRequest) Reset()

func (*StreamingRequest) String

func (m *StreamingRequest) String() string

type StreamingResponse

type StreamingResponse struct {
	Count int64 `protobuf:"varint,1,opt,name=count" json:"count,omitempty"`
}

func (*StreamingResponse) Descriptor

func (*StreamingResponse) Descriptor() ([]byte, []int)

func (*StreamingResponse) GetCount

func (m *StreamingResponse) GetCount() int64

func (*StreamingResponse) ProtoMessage

func (*StreamingResponse) ProtoMessage()

func (*StreamingResponse) Reset

func (m *StreamingResponse) Reset()

func (*StreamingResponse) String

func (m *StreamingResponse) String() string

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL