example

Documentation

Overview

Package example is a generated protocol buffer package.

It is generated from these files:

example.proto

It has these top-level messages:

InputMessage
OutputMessage

Index

• func RegisterExampleServiceServer(s *grpc.Server, srv ExampleServiceServer)
• type ExampleServiceClient
  • func NewExampleServiceClient(cc *grpc.ClientConn) ExampleServiceClient
• type ExampleServiceServer
• type ExampleService_EchoStreamInClient
• type ExampleService_EchoStreamInOutClient
• type ExampleService_EchoStreamInOutServer
• type ExampleService_EchoStreamInServer
• type ExampleService_EchoStreamOutClient
• type ExampleService_EchoStreamOutServer
• type InputMessage
  • func (*InputMessage) Descriptor() ([]byte, []int)
  • func (*InputMessage) ProtoMessage()
  • func (m *InputMessage) Reset()
  • func (m *InputMessage) String() string
• type OutputMessage
  • func (*OutputMessage) Descriptor() ([]byte, []int)
  • func (*OutputMessage) ProtoMessage()
  • func (m *OutputMessage) Reset()
  • func (m *OutputMessage) String() string

Functions

func RegisterExampleServiceServer

func RegisterExampleServiceServer(s *grpc.Server, srv ExampleServiceServer)

Types

type ExampleServiceClient

type ExampleServiceClient interface {
	Echo(ctx context.Context, in *InputMessage, opts ...grpc.CallOption) (*OutputMessage, error)
	EchoStreamOut(ctx context.Context, in *InputMessage, opts ...grpc.CallOption) (ExampleService_EchoStreamOutClient, error)
	EchoStreamIn(ctx context.Context, opts ...grpc.CallOption) (ExampleService_EchoStreamInClient, error)
	EchoStreamInOut(ctx context.Context, opts ...grpc.CallOption) (ExampleService_EchoStreamInOutClient, error)
}

func NewExampleServiceClient

func NewExampleServiceClient(cc *grpc.ClientConn) ExampleServiceClient

type ExampleServiceServer

type ExampleServiceServer interface {
	Echo(context.Context, *InputMessage) (*OutputMessage, error)
	EchoStreamOut(*InputMessage, ExampleService_EchoStreamOutServer) error
	EchoStreamIn(ExampleService_EchoStreamInServer) error
	EchoStreamInOut(ExampleService_EchoStreamInOutServer) error
}

type ExampleService_EchoStreamInClient

type ExampleService_EchoStreamInClient interface {
	Send(*InputMessage) error
	CloseAndRecv() (*OutputMessage, error)
	grpc.ClientStream
}

type ExampleService_EchoStreamInOutClient

type ExampleService_EchoStreamInOutClient interface {
	Send(*InputMessage) error
	Recv() (*OutputMessage, error)
	grpc.ClientStream
}

type ExampleService_EchoStreamInOutServer

type ExampleService_EchoStreamInOutServer interface {
	Send(*OutputMessage) error
	Recv() (*InputMessage, error)
	grpc.ServerStream
}

type ExampleService_EchoStreamInServer

type ExampleService_EchoStreamInServer interface {
	SendAndClose(*OutputMessage) error
	Recv() (*InputMessage, error)
	grpc.ServerStream
}

type ExampleService_EchoStreamOutClient

type ExampleService_EchoStreamOutClient interface {
	Recv() (*OutputMessage, error)
	grpc.ClientStream
}

type ExampleService_EchoStreamOutServer

type ExampleService_EchoStreamOutServer interface {
	Send(*OutputMessage) error
	grpc.ServerStream
}

type InputMessage

type InputMessage struct {
	Value string `protobuf:"bytes,1,opt,name=value" json:"value,omitempty"`
}

func (*InputMessage) Descriptor

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

func (*InputMessage) ProtoMessage

func (*InputMessage) ProtoMessage()

func (*InputMessage) Reset

func (m *InputMessage) Reset()

func (*InputMessage) String

func (m *InputMessage) String() string

type OutputMessage

type OutputMessage struct {
	Value string `protobuf:"bytes,1,opt,name=value" json:"value,omitempty"`
}

func (*OutputMessage) Descriptor

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

func (*OutputMessage) ProtoMessage

func (*OutputMessage) ProtoMessage()

func (*OutputMessage) Reset

func (m *OutputMessage) Reset()

func (*OutputMessage) String

func (m *OutputMessage) String() string