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