Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrInvalidLengthExample        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowExample          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupExample = fmt.Errorf("proto: unexpected end of group")
)

Functions

func BuildFooYARPCProcedures

func BuildFooYARPCProcedures(server FooYARPCServer) []transport.Procedure

BuildFooYARPCProcedures prepares an implementation of the Foo service for YARPC registration.

func BuildKeyValueYARPCProcedures

func BuildKeyValueYARPCProcedures(server KeyValueYARPCServer) []transport.Procedure

BuildKeyValueYARPCProcedures prepares an implementation of the KeyValue service for YARPC registration.

func NewFxFooYARPCClient

func NewFxFooYARPCClient(name string, options ...protobuf.ClientOption) interface{}

NewFxFooYARPCClient provides a FooYARPCClient to an Fx application using the given name for routing.

fx.Provide(
  examplepb.NewFxFooYARPCClient("service-name"),
  ...
)

func NewFxFooYARPCProcedures

func NewFxFooYARPCProcedures() interface{}

NewFxFooYARPCProcedures provides FooYARPCServer procedures to an Fx application. It expects a FooYARPCServer to be present in the container.

fx.Provide(
  examplepb.NewFxFooYARPCProcedures(),
  ...
)

func NewFxKeyValueYARPCClient

func NewFxKeyValueYARPCClient(name string, options ...protobuf.ClientOption) interface{}

NewFxKeyValueYARPCClient provides a KeyValueYARPCClient to an Fx application using the given name for routing.

fx.Provide(
  examplepb.NewFxKeyValueYARPCClient("service-name"),
  ...
)

func NewFxKeyValueYARPCProcedures

func NewFxKeyValueYARPCProcedures() interface{}

NewFxKeyValueYARPCProcedures provides KeyValueYARPCServer procedures to an Fx application. It expects a KeyValueYARPCServer to be present in the container.

fx.Provide(
  examplepb.NewFxKeyValueYARPCProcedures(),
  ...
)

func RegisterFooServer

func RegisterFooServer(s *grpc.Server, srv FooServer)

func RegisterKeyValueServer

func RegisterKeyValueServer(s *grpc.Server, srv KeyValueServer)

Types

type EchoBothRequest

type EchoBothRequest struct {
	Message      string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	NumResponses int64  `protobuf:"varint,2,opt,name=num_responses,json=numResponses,proto3" json:"num_responses,omitempty"`
}

func (*EchoBothRequest) Descriptor

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

func (*EchoBothRequest) Equal

func (this *EchoBothRequest) Equal(that interface{}) bool

func (*EchoBothRequest) GetMessage

func (m *EchoBothRequest) GetMessage() string

func (*EchoBothRequest) GetNumResponses

func (m *EchoBothRequest) GetNumResponses() int64

func (*EchoBothRequest) GoString

func (this *EchoBothRequest) GoString() string

func (*EchoBothRequest) Marshal

func (m *EchoBothRequest) Marshal() (dAtA []byte, err error)

func (*EchoBothRequest) MarshalTo

func (m *EchoBothRequest) MarshalTo(dAtA []byte) (int, error)

func (*EchoBothRequest) MarshalToSizedBuffer

func (m *EchoBothRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EchoBothRequest) ProtoMessage

func (*EchoBothRequest) ProtoMessage()

func (*EchoBothRequest) Reset

func (m *EchoBothRequest) Reset()

func (*EchoBothRequest) Size

func (m *EchoBothRequest) Size() (n int)

func (*EchoBothRequest) String

func (this *EchoBothRequest) String() string

func (*EchoBothRequest) Unmarshal

func (m *EchoBothRequest) Unmarshal(dAtA []byte) error

func (*EchoBothRequest) XXX_DiscardUnknown

func (m *EchoBothRequest) XXX_DiscardUnknown()

func (*EchoBothRequest) XXX_Marshal

func (m *EchoBothRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EchoBothRequest) XXX_Merge

func (m *EchoBothRequest) XXX_Merge(src proto.Message)

func (*EchoBothRequest) XXX_Size

func (m *EchoBothRequest) XXX_Size() int

func (*EchoBothRequest) XXX_Unmarshal

func (m *EchoBothRequest) XXX_Unmarshal(b []byte) error

type EchoBothResponse

type EchoBothResponse struct {
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
}

func (*EchoBothResponse) Descriptor

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

func (*EchoBothResponse) Equal

func (this *EchoBothResponse) Equal(that interface{}) bool

func (*EchoBothResponse) GetMessage

func (m *EchoBothResponse) GetMessage() string

func (*EchoBothResponse) GoString

func (this *EchoBothResponse) GoString() string

func (*EchoBothResponse) Marshal

func (m *EchoBothResponse) Marshal() (dAtA []byte, err error)

func (*EchoBothResponse) MarshalTo

func (m *EchoBothResponse) MarshalTo(dAtA []byte) (int, error)

func (*EchoBothResponse) MarshalToSizedBuffer

func (m *EchoBothResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EchoBothResponse) ProtoMessage

func (*EchoBothResponse) ProtoMessage()

func (*EchoBothResponse) Reset

func (m *EchoBothResponse) Reset()

func (*EchoBothResponse) Size

func (m *EchoBothResponse) Size() (n int)

func (*EchoBothResponse) String

func (this *EchoBothResponse) String() string

func (*EchoBothResponse) Unmarshal

func (m *EchoBothResponse) Unmarshal(dAtA []byte) error

func (*EchoBothResponse) XXX_DiscardUnknown

func (m *EchoBothResponse) XXX_DiscardUnknown()

func (*EchoBothResponse) XXX_Marshal

func (m *EchoBothResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EchoBothResponse) XXX_Merge

func (m *EchoBothResponse) XXX_Merge(src proto.Message)

func (*EchoBothResponse) XXX_Size

func (m *EchoBothResponse) XXX_Size() int

func (*EchoBothResponse) XXX_Unmarshal

func (m *EchoBothResponse) XXX_Unmarshal(b []byte) error

type EchoInRequest

type EchoInRequest struct {
	Message      string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	NumResponses int64  `protobuf:"varint,2,opt,name=num_responses,json=numResponses,proto3" json:"num_responses,omitempty"`
}

func (*EchoInRequest) Descriptor

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

func (*EchoInRequest) Equal

func (this *EchoInRequest) Equal(that interface{}) bool

func (*EchoInRequest) GetMessage

func (m *EchoInRequest) GetMessage() string

func (*EchoInRequest) GetNumResponses

func (m *EchoInRequest) GetNumResponses() int64

func (*EchoInRequest) GoString

func (this *EchoInRequest) GoString() string

func (*EchoInRequest) Marshal

func (m *EchoInRequest) Marshal() (dAtA []byte, err error)

func (*EchoInRequest) MarshalTo

func (m *EchoInRequest) MarshalTo(dAtA []byte) (int, error)

func (*EchoInRequest) MarshalToSizedBuffer

func (m *EchoInRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EchoInRequest) ProtoMessage

func (*EchoInRequest) ProtoMessage()

func (*EchoInRequest) Reset

func (m *EchoInRequest) Reset()

func (*EchoInRequest) Size

func (m *EchoInRequest) Size() (n int)

func (*EchoInRequest) String

func (this *EchoInRequest) String() string

func (*EchoInRequest) Unmarshal

func (m *EchoInRequest) Unmarshal(dAtA []byte) error

func (*EchoInRequest) XXX_DiscardUnknown

func (m *EchoInRequest) XXX_DiscardUnknown()

func (*EchoInRequest) XXX_Marshal

func (m *EchoInRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EchoInRequest) XXX_Merge

func (m *EchoInRequest) XXX_Merge(src proto.Message)

func (*EchoInRequest) XXX_Size

func (m *EchoInRequest) XXX_Size() int

func (*EchoInRequest) XXX_Unmarshal

func (m *EchoInRequest) XXX_Unmarshal(b []byte) error

type EchoInResponse

type EchoInResponse struct {
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
}

func (*EchoInResponse) Descriptor

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

func (*EchoInResponse) Equal

func (this *EchoInResponse) Equal(that interface{}) bool

func (*EchoInResponse) GetMessage

func (m *EchoInResponse) GetMessage() string

func (*EchoInResponse) GoString

func (this *EchoInResponse) GoString() string

func (*EchoInResponse) Marshal

func (m *EchoInResponse) Marshal() (dAtA []byte, err error)

func (*EchoInResponse) MarshalTo

func (m *EchoInResponse) MarshalTo(dAtA []byte) (int, error)

func (*EchoInResponse) MarshalToSizedBuffer

func (m *EchoInResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EchoInResponse) ProtoMessage

func (*EchoInResponse) ProtoMessage()

func (*EchoInResponse) Reset

func (m *EchoInResponse) Reset()

func (*EchoInResponse) Size

func (m *EchoInResponse) Size() (n int)

func (*EchoInResponse) String

func (this *EchoInResponse) String() string

func (*EchoInResponse) Unmarshal

func (m *EchoInResponse) Unmarshal(dAtA []byte) error

func (*EchoInResponse) XXX_DiscardUnknown

func (m *EchoInResponse) XXX_DiscardUnknown()

func (*EchoInResponse) XXX_Marshal

func (m *EchoInResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EchoInResponse) XXX_Merge

func (m *EchoInResponse) XXX_Merge(src proto.Message)

func (*EchoInResponse) XXX_Size

func (m *EchoInResponse) XXX_Size() int

func (*EchoInResponse) XXX_Unmarshal

func (m *EchoInResponse) XXX_Unmarshal(b []byte) error

type EchoOutRequest

type EchoOutRequest struct {
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
}

func (*EchoOutRequest) Descriptor

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

func (*EchoOutRequest) Equal

func (this *EchoOutRequest) Equal(that interface{}) bool

func (*EchoOutRequest) GetMessage

func (m *EchoOutRequest) GetMessage() string

func (*EchoOutRequest) GoString

func (this *EchoOutRequest) GoString() string

func (*EchoOutRequest) Marshal

func (m *EchoOutRequest) Marshal() (dAtA []byte, err error)

func (*EchoOutRequest) MarshalTo

func (m *EchoOutRequest) MarshalTo(dAtA []byte) (int, error)

func (*EchoOutRequest) MarshalToSizedBuffer

func (m *EchoOutRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EchoOutRequest) ProtoMessage

func (*EchoOutRequest) ProtoMessage()

func (*EchoOutRequest) Reset

func (m *EchoOutRequest) Reset()

func (*EchoOutRequest) Size

func (m *EchoOutRequest) Size() (n int)

func (*EchoOutRequest) String

func (this *EchoOutRequest) String() string

func (*EchoOutRequest) Unmarshal

func (m *EchoOutRequest) Unmarshal(dAtA []byte) error

func (*EchoOutRequest) XXX_DiscardUnknown

func (m *EchoOutRequest) XXX_DiscardUnknown()

func (*EchoOutRequest) XXX_Marshal

func (m *EchoOutRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EchoOutRequest) XXX_Merge

func (m *EchoOutRequest) XXX_Merge(src proto.Message)

func (*EchoOutRequest) XXX_Size

func (m *EchoOutRequest) XXX_Size() int

func (*EchoOutRequest) XXX_Unmarshal

func (m *EchoOutRequest) XXX_Unmarshal(b []byte) error

type EchoOutResponse

type EchoOutResponse struct {
	AllMessages []string `protobuf:"bytes,2,rep,name=all_messages,json=allMessages,proto3" json:"all_messages,omitempty"`
}

func (*EchoOutResponse) Descriptor

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

func (*EchoOutResponse) Equal

func (this *EchoOutResponse) Equal(that interface{}) bool

func (*EchoOutResponse) GetAllMessages

func (m *EchoOutResponse) GetAllMessages() []string

func (*EchoOutResponse) GoString

func (this *EchoOutResponse) GoString() string

func (*EchoOutResponse) Marshal

func (m *EchoOutResponse) Marshal() (dAtA []byte, err error)

func (*EchoOutResponse) MarshalTo

func (m *EchoOutResponse) MarshalTo(dAtA []byte) (int, error)

func (*EchoOutResponse) MarshalToSizedBuffer

func (m *EchoOutResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EchoOutResponse) ProtoMessage

func (*EchoOutResponse) ProtoMessage()

func (*EchoOutResponse) Reset

func (m *EchoOutResponse) Reset()

func (*EchoOutResponse) Size

func (m *EchoOutResponse) Size() (n int)

func (*EchoOutResponse) String

func (this *EchoOutResponse) String() string

func (*EchoOutResponse) Unmarshal

func (m *EchoOutResponse) Unmarshal(dAtA []byte) error

func (*EchoOutResponse) XXX_DiscardUnknown

func (m *EchoOutResponse) XXX_DiscardUnknown()

func (*EchoOutResponse) XXX_Marshal

func (m *EchoOutResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EchoOutResponse) XXX_Merge

func (m *EchoOutResponse) XXX_Merge(src proto.Message)

func (*EchoOutResponse) XXX_Size

func (m *EchoOutResponse) XXX_Size() int

func (*EchoOutResponse) XXX_Unmarshal

func (m *EchoOutResponse) XXX_Unmarshal(b []byte) error

type FooClient

type FooClient interface {
	EchoOut(ctx context.Context, opts ...grpc.CallOption) (Foo_EchoOutClient, error)
	EchoIn(ctx context.Context, in *EchoInRequest, opts ...grpc.CallOption) (Foo_EchoInClient, error)
	EchoBoth(ctx context.Context, opts ...grpc.CallOption) (Foo_EchoBothClient, error)
}

FooClient is the client API for Foo service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewFooClient

func NewFooClient(cc *grpc.ClientConn) FooClient

type FooServer

type FooServer interface {
	EchoOut(Foo_EchoOutServer) error
	EchoIn(*EchoInRequest, Foo_EchoInServer) error
	EchoBoth(Foo_EchoBothServer) error
}

FooServer is the server API for Foo service.

type FooServiceEchoBothYARPCClient

type FooServiceEchoBothYARPCClient interface {
	Context() context.Context
	Send(*EchoBothRequest, ...yarpc.StreamOption) error
	Recv(...yarpc.StreamOption) (*EchoBothResponse, error)
	CloseSend(...yarpc.StreamOption) error
}

FooServiceEchoBothYARPCClient sends EchoBothRequests and receives EchoBothResponses, returning io.EOF when the stream is complete.

type FooServiceEchoBothYARPCServer

type FooServiceEchoBothYARPCServer interface {
	Context() context.Context
	Recv(...yarpc.StreamOption) (*EchoBothRequest, error)
	Send(*EchoBothResponse, ...yarpc.StreamOption) error
}

FooServiceEchoBothYARPCServer receives EchoBothRequests and sends EchoBothResponse.

type FooServiceEchoInYARPCClient

type FooServiceEchoInYARPCClient interface {
	Context() context.Context
	Recv(...yarpc.StreamOption) (*EchoInResponse, error)
	CloseSend(...yarpc.StreamOption) error
}

FooServiceEchoInYARPCClient receives EchoInResponses, returning io.EOF when the stream is complete.

type FooServiceEchoInYARPCServer

type FooServiceEchoInYARPCServer interface {
	Context() context.Context
	Send(*EchoInResponse, ...yarpc.StreamOption) error
}

FooServiceEchoInYARPCServer sends EchoInResponses.

type FooServiceEchoOutYARPCClient

type FooServiceEchoOutYARPCClient interface {
	Context() context.Context
	Send(*EchoOutRequest, ...yarpc.StreamOption) error
	CloseAndRecv(...yarpc.StreamOption) (*EchoOutResponse, error)
}

FooServiceEchoOutYARPCClient sends EchoOutRequests and receives the single EchoOutResponse when sending is done.

type FooServiceEchoOutYARPCServer

type FooServiceEchoOutYARPCServer interface {
	Context() context.Context
	Recv(...yarpc.StreamOption) (*EchoOutRequest, error)
}

FooServiceEchoOutYARPCServer receives EchoOutRequests.

type FooYARPCClient

FooYARPCClient is the YARPC client-side interface for the Foo service.

func NewFooYARPCClient

func NewFooYARPCClient(clientConfig transport.ClientConfig, options ...protobuf.ClientOption) FooYARPCClient

NewFooYARPCClient builds a new YARPC client for the Foo service.

type FooYARPCServer

FooYARPCServer is the YARPC server-side interface for the Foo service.

type Foo_EchoBothClient

type Foo_EchoBothClient interface {
	Send(*EchoBothRequest) error
	Recv() (*EchoBothResponse, error)
	grpc.ClientStream
}

type Foo_EchoBothServer

type Foo_EchoBothServer interface {
	Send(*EchoBothResponse) error
	Recv() (*EchoBothRequest, error)
	grpc.ServerStream
}

type Foo_EchoInClient

type Foo_EchoInClient interface {
	Recv() (*EchoInResponse, error)
	grpc.ClientStream
}

type Foo_EchoInServer

type Foo_EchoInServer interface {
	Send(*EchoInResponse) error
	grpc.ServerStream
}

type Foo_EchoOutClient

type Foo_EchoOutClient interface {
	Send(*EchoOutRequest) error
	CloseAndRecv() (*EchoOutResponse, error)
	grpc.ClientStream
}

type Foo_EchoOutServer

type Foo_EchoOutServer interface {
	SendAndClose(*EchoOutResponse) error
	Recv() (*EchoOutRequest, error)
	grpc.ServerStream
}

type FxFooYARPCClientParams

type FxFooYARPCClientParams struct {
	fx.In

	Provider    yarpc.ClientConfig
	AnyResolver jsonpb.AnyResolver  `name:"yarpcfx" optional:"true"`
	Restriction restriction.Checker `optional:"true"`
}

FxFooYARPCClientParams defines the input for NewFxFooYARPCClient. It provides the paramaters to get a FooYARPCClient in an Fx application.

type FxFooYARPCClientResult

type FxFooYARPCClientResult struct {
	fx.Out

	Client FooYARPCClient
}

FxFooYARPCClientResult defines the output of NewFxFooYARPCClient. It provides a FooYARPCClient to an Fx application.

type FxFooYARPCProceduresParams

type FxFooYARPCProceduresParams struct {
	fx.In

	Server      FooYARPCServer
	AnyResolver jsonpb.AnyResolver `name:"yarpcfx" optional:"true"`
}

FxFooYARPCProceduresParams defines the input for NewFxFooYARPCProcedures. It provides the paramaters to get FooYARPCServer procedures in an Fx application.

type FxFooYARPCProceduresResult

type FxFooYARPCProceduresResult struct {
	fx.Out

	Procedures     []transport.Procedure `group:"yarpcfx"`
	ReflectionMeta reflection.ServerMeta `group:"yarpcfx"`
}

FxFooYARPCProceduresResult defines the output of NewFxFooYARPCProcedures. It provides FooYARPCServer procedures to an Fx application.

The procedures are provided to the "yarpcfx" value group. Dig 1.2 or newer must be used for this feature to work.

type FxKeyValueYARPCClientParams

type FxKeyValueYARPCClientParams struct {
	fx.In

	Provider    yarpc.ClientConfig
	AnyResolver jsonpb.AnyResolver  `name:"yarpcfx" optional:"true"`
	Restriction restriction.Checker `optional:"true"`
}

FxKeyValueYARPCClientParams defines the input for NewFxKeyValueYARPCClient. It provides the paramaters to get a KeyValueYARPCClient in an Fx application.

type FxKeyValueYARPCClientResult

type FxKeyValueYARPCClientResult struct {
	fx.Out

	Client KeyValueYARPCClient
}

FxKeyValueYARPCClientResult defines the output of NewFxKeyValueYARPCClient. It provides a KeyValueYARPCClient to an Fx application.

type FxKeyValueYARPCProceduresParams

type FxKeyValueYARPCProceduresParams struct {
	fx.In

	Server      KeyValueYARPCServer
	AnyResolver jsonpb.AnyResolver `name:"yarpcfx" optional:"true"`
}

FxKeyValueYARPCProceduresParams defines the input for NewFxKeyValueYARPCProcedures. It provides the paramaters to get KeyValueYARPCServer procedures in an Fx application.

type FxKeyValueYARPCProceduresResult

type FxKeyValueYARPCProceduresResult struct {
	fx.Out

	Procedures     []transport.Procedure `group:"yarpcfx"`
	ReflectionMeta reflection.ServerMeta `group:"yarpcfx"`
}

FxKeyValueYARPCProceduresResult defines the output of NewFxKeyValueYARPCProcedures. It provides KeyValueYARPCServer procedures to an Fx application.

The procedures are provided to the "yarpcfx" value group. Dig 1.2 or newer must be used for this feature to work.

type GetValueRequest

type GetValueRequest struct {
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
}

func (*GetValueRequest) Descriptor

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

func (*GetValueRequest) Equal

func (this *GetValueRequest) Equal(that interface{}) bool

func (*GetValueRequest) GetKey

func (m *GetValueRequest) GetKey() string

func (*GetValueRequest) GoString

func (this *GetValueRequest) GoString() string

func (*GetValueRequest) Marshal

func (m *GetValueRequest) Marshal() (dAtA []byte, err error)

func (*GetValueRequest) MarshalTo

func (m *GetValueRequest) MarshalTo(dAtA []byte) (int, error)

func (*GetValueRequest) MarshalToSizedBuffer

func (m *GetValueRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetValueRequest) ProtoMessage

func (*GetValueRequest) ProtoMessage()

func (*GetValueRequest) Reset

func (m *GetValueRequest) Reset()

func (*GetValueRequest) Size

func (m *GetValueRequest) Size() (n int)

func (*GetValueRequest) String

func (this *GetValueRequest) String() string

func (*GetValueRequest) Unmarshal

func (m *GetValueRequest) Unmarshal(dAtA []byte) error

func (*GetValueRequest) XXX_DiscardUnknown

func (m *GetValueRequest) XXX_DiscardUnknown()

func (*GetValueRequest) XXX_Marshal

func (m *GetValueRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetValueRequest) XXX_Merge

func (m *GetValueRequest) XXX_Merge(src proto.Message)

func (*GetValueRequest) XXX_Size

func (m *GetValueRequest) XXX_Size() int

func (*GetValueRequest) XXX_Unmarshal

func (m *GetValueRequest) XXX_Unmarshal(b []byte) error

type GetValueResponse

type GetValueResponse struct {
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
}

func (*GetValueResponse) Descriptor

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

func (*GetValueResponse) Equal

func (this *GetValueResponse) Equal(that interface{}) bool

func (*GetValueResponse) GetValue

func (m *GetValueResponse) GetValue() string

func (*GetValueResponse) GoString

func (this *GetValueResponse) GoString() string

func (*GetValueResponse) Marshal

func (m *GetValueResponse) Marshal() (dAtA []byte, err error)

func (*GetValueResponse) MarshalTo

func (m *GetValueResponse) MarshalTo(dAtA []byte) (int, error)

func (*GetValueResponse) MarshalToSizedBuffer

func (m *GetValueResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetValueResponse) ProtoMessage

func (*GetValueResponse) ProtoMessage()

func (*GetValueResponse) Reset

func (m *GetValueResponse) Reset()

func (*GetValueResponse) Size

func (m *GetValueResponse) Size() (n int)

func (*GetValueResponse) String

func (this *GetValueResponse) String() string

func (*GetValueResponse) Unmarshal

func (m *GetValueResponse) Unmarshal(dAtA []byte) error

func (*GetValueResponse) XXX_DiscardUnknown

func (m *GetValueResponse) XXX_DiscardUnknown()

func (*GetValueResponse) XXX_Marshal

func (m *GetValueResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetValueResponse) XXX_Merge

func (m *GetValueResponse) XXX_Merge(src proto.Message)

func (*GetValueResponse) XXX_Size

func (m *GetValueResponse) XXX_Size() int

func (*GetValueResponse) XXX_Unmarshal

func (m *GetValueResponse) XXX_Unmarshal(b []byte) error

type KeyValueClient

type KeyValueClient interface {
	GetValue(ctx context.Context, in *GetValueRequest, opts ...grpc.CallOption) (*GetValueResponse, error)
	SetValue(ctx context.Context, in *SetValueRequest, opts ...grpc.CallOption) (*SetValueResponse, error)
}

KeyValueClient is the client API for KeyValue service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewKeyValueClient

func NewKeyValueClient(cc *grpc.ClientConn) KeyValueClient

type KeyValueServer

type KeyValueServer interface {
	GetValue(context.Context, *GetValueRequest) (*GetValueResponse, error)
	SetValue(context.Context, *SetValueRequest) (*SetValueResponse, error)
}

KeyValueServer is the server API for KeyValue service.

type KeyValueYARPCClient

type KeyValueYARPCClient interface {
	GetValue(context.Context, *GetValueRequest, ...yarpc.CallOption) (*GetValueResponse, error)
	SetValue(context.Context, *SetValueRequest, ...yarpc.CallOption) (*SetValueResponse, error)
}

KeyValueYARPCClient is the YARPC client-side interface for the KeyValue service.

func NewKeyValueYARPCClient

func NewKeyValueYARPCClient(clientConfig transport.ClientConfig, options ...protobuf.ClientOption) KeyValueYARPCClient

NewKeyValueYARPCClient builds a new YARPC client for the KeyValue service.

type KeyValueYARPCServer

type KeyValueYARPCServer interface {
	GetValue(context.Context, *GetValueRequest) (*GetValueResponse, error)
	SetValue(context.Context, *SetValueRequest) (*SetValueResponse, error)
}

KeyValueYARPCServer is the YARPC server-side interface for the KeyValue service.

type SetValueRequest

type SetValueRequest struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
}

func (*SetValueRequest) Descriptor

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

func (*SetValueRequest) Equal

func (this *SetValueRequest) Equal(that interface{}) bool

func (*SetValueRequest) GetKey

func (m *SetValueRequest) GetKey() string

func (*SetValueRequest) GetValue

func (m *SetValueRequest) GetValue() string

func (*SetValueRequest) GoString

func (this *SetValueRequest) GoString() string

func (*SetValueRequest) Marshal

func (m *SetValueRequest) Marshal() (dAtA []byte, err error)

func (*SetValueRequest) MarshalTo

func (m *SetValueRequest) MarshalTo(dAtA []byte) (int, error)

func (*SetValueRequest) MarshalToSizedBuffer

func (m *SetValueRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SetValueRequest) ProtoMessage

func (*SetValueRequest) ProtoMessage()

func (*SetValueRequest) Reset

func (m *SetValueRequest) Reset()

func (*SetValueRequest) Size

func (m *SetValueRequest) Size() (n int)

func (*SetValueRequest) String

func (this *SetValueRequest) String() string

func (*SetValueRequest) Unmarshal

func (m *SetValueRequest) Unmarshal(dAtA []byte) error

func (*SetValueRequest) XXX_DiscardUnknown

func (m *SetValueRequest) XXX_DiscardUnknown()

func (*SetValueRequest) XXX_Marshal

func (m *SetValueRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SetValueRequest) XXX_Merge

func (m *SetValueRequest) XXX_Merge(src proto.Message)

func (*SetValueRequest) XXX_Size

func (m *SetValueRequest) XXX_Size() int

func (*SetValueRequest) XXX_Unmarshal

func (m *SetValueRequest) XXX_Unmarshal(b []byte) error

type SetValueResponse

type SetValueResponse struct {
}

func (*SetValueResponse) Descriptor

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

func (*SetValueResponse) Equal

func (this *SetValueResponse) Equal(that interface{}) bool

func (*SetValueResponse) GoString

func (this *SetValueResponse) GoString() string

func (*SetValueResponse) Marshal

func (m *SetValueResponse) Marshal() (dAtA []byte, err error)

func (*SetValueResponse) MarshalTo

func (m *SetValueResponse) MarshalTo(dAtA []byte) (int, error)

func (*SetValueResponse) MarshalToSizedBuffer

func (m *SetValueResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SetValueResponse) ProtoMessage

func (*SetValueResponse) ProtoMessage()

func (*SetValueResponse) Reset

func (m *SetValueResponse) Reset()

func (*SetValueResponse) Size

func (m *SetValueResponse) Size() (n int)

func (*SetValueResponse) String

func (this *SetValueResponse) String() string

func (*SetValueResponse) Unmarshal

func (m *SetValueResponse) Unmarshal(dAtA []byte) error

func (*SetValueResponse) XXX_DiscardUnknown

func (m *SetValueResponse) XXX_DiscardUnknown()

func (*SetValueResponse) XXX_Marshal

func (m *SetValueResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SetValueResponse) XXX_Merge

func (m *SetValueResponse) XXX_Merge(src proto.Message)

func (*SetValueResponse) XXX_Size

func (m *SetValueResponse) XXX_Size() int

func (*SetValueResponse) XXX_Unmarshal

func (m *SetValueResponse) XXX_Unmarshal(b []byte) error

type UnimplementedFooServer

type UnimplementedFooServer struct {
}

UnimplementedFooServer can be embedded to have forward compatible implementations.

func (*UnimplementedFooServer) EchoBoth

func (*UnimplementedFooServer) EchoIn

func (*UnimplementedFooServer) EchoOut

type UnimplementedKeyValueServer

type UnimplementedKeyValueServer struct {
}

UnimplementedKeyValueServer can be embedded to have forward compatible implementations.

func (*UnimplementedKeyValueServer) GetValue

func (*UnimplementedKeyValueServer) SetValue