examplepb

package
v1.42.1 Latest Latest
Warning

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

 Go to latest Published: Dec 2, 2019 License: MIT Imports: 16 Imported by: 0

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")
)

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 BuildSinkYARPCProcedures 

func BuildSinkYARPCProcedures(server SinkYARPCServer) []transport.Procedure

BuildSinkYARPCProcedures prepares an implementation of the Sink 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 NewFxSinkYARPCClient 

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

NewFxSinkYARPCClient provides a SinkYARPCClient to an Fx application using the given name for routing. 

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

func NewFxSinkYARPCProcedures 

func NewFxSinkYARPCProcedures() interface{}

NewFxSinkYARPCProcedures provides SinkYARPCServer procedures to an Fx application. It expects a SinkYARPCServer to be present in the container. 

fx.Provide(
  examplepb.NewFxSinkYARPCProcedures(),
  ...
)

func RegisterFooServer 

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

func RegisterKeyValueServer 

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

func RegisterSinkServer 

func RegisterSinkServer(s *grpc.Server, srv SinkServer)

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) 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) 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) 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) 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) 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) 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 FireRequest 

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

func (*FireRequest) Descriptor 

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

func (*FireRequest) Equal 

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

func (*FireRequest) GetValue 

func (m *FireRequest) GetValue() string

func (*FireRequest) GoString 

func (this *FireRequest) GoString() string

func (*FireRequest) Marshal 

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

func (*FireRequest) MarshalTo 

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

func (*FireRequest) ProtoMessage 

func (*FireRequest) ProtoMessage()

func (*FireRequest) Reset 

func (m *FireRequest) Reset()

func (*FireRequest) Size 

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

func (*FireRequest) String 

func (this *FireRequest) String() string

func (*FireRequest) Unmarshal 

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

func (*FireRequest) XXX_DiscardUnknown 

func (m *FireRequest) XXX_DiscardUnknown()

func (*FireRequest) XXX_Marshal 

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

func (*FireRequest) XXX_Merge 

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

func (*FireRequest) XXX_Size 

func (m *FireRequest) XXX_Size() int

func (*FireRequest) XXX_Unmarshal 

func (m *FireRequest) 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 

type FooYARPCClient interface {
	EchoOut(context.Context, ...yarpc.CallOption) (FooServiceEchoOutYARPCClient, error)
	EchoIn(context.Context, *EchoInRequest, ...yarpc.CallOption) (FooServiceEchoInYARPCClient, error)
	EchoBoth(context.Context, ...yarpc.CallOption) (FooServiceEchoBothYARPCClient, error)
}

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 

type FooYARPCServer interface {
	EchoOut(FooServiceEchoOutYARPCServer) (*EchoOutResponse, error)
	EchoIn(*EchoInRequest, FooServiceEchoInYARPCServer) error
	EchoBoth(FooServiceEchoBothYARPCServer) error
}

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"`
}

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"`
}

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 FxSinkYARPCClientParams 

type FxSinkYARPCClientParams struct {
	fx.In

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

FxSinkYARPCClientParams defines the input for NewFxSinkYARPCClient. It provides the paramaters to get a SinkYARPCClient in an Fx application.

type FxSinkYARPCClientResult 

type FxSinkYARPCClientResult struct {
	fx.Out

	Client SinkYARPCClient
}

FxSinkYARPCClientResult defines the output of NewFxSinkYARPCClient. It provides a SinkYARPCClient to an Fx application.

type FxSinkYARPCProceduresParams 

type FxSinkYARPCProceduresParams struct {
	fx.In

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

FxSinkYARPCProceduresParams defines the input for NewFxSinkYARPCProcedures. It provides the paramaters to get SinkYARPCServer procedures in an Fx application.

type FxSinkYARPCProceduresResult 

type FxSinkYARPCProceduresResult struct {
	fx.Out

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

FxSinkYARPCProceduresResult defines the output of NewFxSinkYARPCProcedures. It provides SinkYARPCServer 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) 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) 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) 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) 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 SinkClient 

type SinkClient interface {
	Fire(ctx context.Context, in *FireRequest, opts ...grpc.CallOption) (*yarpcproto.Oneway, error)
}

SinkClient is the client API for Sink service.

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

func NewSinkClient 

func NewSinkClient(cc *grpc.ClientConn) SinkClient

type SinkServer 

type SinkServer interface {
	Fire(context.Context, *FireRequest) (*yarpcproto.Oneway, error)
}

SinkServer is the server API for Sink service.

type SinkYARPCClient 

type SinkYARPCClient interface {
	Fire(context.Context, *FireRequest, ...yarpc.CallOption) (yarpc.Ack, error)
}

SinkYARPCClient is the YARPC client-side interface for the Sink service.

func NewSinkYARPCClient 

func NewSinkYARPCClient(clientConfig transport.ClientConfig, options ...protobuf.ClientOption) SinkYARPCClient

NewSinkYARPCClient builds a new YARPC client for the Sink service.

type SinkYARPCServer 

type SinkYARPCServer interface {
	Fire(context.Context, *FireRequest) error
}

SinkYARPCServer is the YARPC server-side interface for the Sink service.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.