examplepb

package
v1.72.1 Latest Latest
Warning

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

 Go to latest Published: Mar 14, 2024 License: MIT Imports: 19 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")
	ErrUnexpectedEndOfGroupExample = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var FooReflectionMeta = reflection.ServerMeta{
	ServiceName:     "uber.yarpc.internal.examples.protobuf.example.Foo",
	FileDescriptors: yarpcFileDescriptorClosurebab15b635bbc13f7,
}

FooReflectionMeta is the reflection server metadata required for using the gRPC reflection protocol with YARPC.

See https://github.com/grpc/grpc/blob/master/doc/server-reflection.md.

View Source 
var KeyValueReflectionMeta = reflection.ServerMeta{
	ServiceName:     "uber.yarpc.internal.examples.protobuf.example.KeyValue",
	FileDescriptors: yarpcFileDescriptorClosurebab15b635bbc13f7,
}

KeyValueReflectionMeta is the reflection server metadata required for using the gRPC reflection protocol with YARPC.

See https://github.com/grpc/grpc/blob/master/doc/server-reflection.md.

View Source 
var TestMessageNameParityReflectionMeta = reflection.ServerMeta{
	ServiceName:     "uber.yarpc.internal.examples.protobuf.example.TestMessageNameParity",
	FileDescriptors: yarpcFileDescriptorClosurebab15b635bbc13f7,
}

TestMessageNameParityReflectionMeta is the reflection server metadata required for using the gRPC reflection protocol with YARPC.

See https://github.com/grpc/grpc/blob/master/doc/server-reflection.md.

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 BuildTestMessageNameParityYARPCProcedures added in v1.55.1 

func BuildTestMessageNameParityYARPCProcedures(server TestMessageNameParityYARPCServer) []transport.Procedure

BuildTestMessageNameParityYARPCProcedures prepares an implementation of the TestMessageNameParity 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 NewFxTestMessageNameParityYARPCClient added in v1.55.1 

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

NewFxTestMessageNameParityYARPCClient provides a TestMessageNameParityYARPCClient to an Fx application using the given name for routing. 

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

func NewFxTestMessageNameParityYARPCProcedures added in v1.55.1 

func NewFxTestMessageNameParityYARPCProcedures() interface{}

NewFxTestMessageNameParityYARPCProcedures provides TestMessageNameParityYARPCServer procedures to an Fx application. It expects a TestMessageNameParityYARPCServer to be present in the container. 

fx.Provide(
  examplepb.NewFxTestMessageNameParityYARPCProcedures(),
  ...
)

func RegisterFooServer 

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

func RegisterKeyValueServer 

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

func RegisterTestMessageNameParityServer added in v1.55.1 

func RegisterTestMessageNameParityServer(s *grpc.Server, srv TestMessageNameParityServer)

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 

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"`
	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 FxTestMessageNameParityYARPCClientParams added in v1.55.1 

type FxTestMessageNameParityYARPCClientParams struct {
	fx.In

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

FxTestMessageNameParityYARPCClientParams defines the input for NewFxTestMessageNameParityYARPCClient. It provides the paramaters to get a TestMessageNameParityYARPCClient in an Fx application.

type FxTestMessageNameParityYARPCClientResult added in v1.55.1 

type FxTestMessageNameParityYARPCClientResult struct {
	fx.Out

	Client TestMessageNameParityYARPCClient
}

FxTestMessageNameParityYARPCClientResult defines the output of NewFxTestMessageNameParityYARPCClient. It provides a TestMessageNameParityYARPCClient to an Fx application.

type FxTestMessageNameParityYARPCProceduresParams added in v1.55.1 

type FxTestMessageNameParityYARPCProceduresParams struct {
	fx.In

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

FxTestMessageNameParityYARPCProceduresParams defines the input for NewFxTestMessageNameParityYARPCProcedures. It provides the paramaters to get TestMessageNameParityYARPCServer procedures in an Fx application.

type FxTestMessageNameParityYARPCProceduresResult added in v1.55.1 

type FxTestMessageNameParityYARPCProceduresResult struct {
	fx.Out

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

FxTestMessageNameParityYARPCProceduresResult defines the output of NewFxTestMessageNameParityYARPCProcedures. It provides TestMessageNameParityYARPCServer 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 Get2NdMessageRequest added in v1.55.1 

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

Get2ndMessageRequest and Get2ndMessageResponse are messages used to test that messages generated by the yarpc protoc plugin and by protoc-gen-gogo follows the same GoType conventions as gogo/protobuf.

func (*Get2NdMessageRequest) Descriptor added in v1.55.1 

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

func (*Get2NdMessageRequest) Equal added in v1.55.1 

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

func (*Get2NdMessageRequest) GetMessage added in v1.55.1 

func (m *Get2NdMessageRequest) GetMessage() string

func (*Get2NdMessageRequest) GoString added in v1.55.1 

func (this *Get2NdMessageRequest) GoString() string

func (*Get2NdMessageRequest) Marshal added in v1.55.1 

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

func (*Get2NdMessageRequest) MarshalTo added in v1.55.1 

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

func (*Get2NdMessageRequest) MarshalToSizedBuffer added in v1.55.1 

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

func (*Get2NdMessageRequest) ProtoMessage added in v1.55.1 

func (*Get2NdMessageRequest) ProtoMessage()

func (*Get2NdMessageRequest) Reset added in v1.55.1 

func (m *Get2NdMessageRequest) Reset()

func (*Get2NdMessageRequest) Size added in v1.55.1 

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

func (*Get2NdMessageRequest) String added in v1.55.1 

func (this *Get2NdMessageRequest) String() string

func (*Get2NdMessageRequest) Unmarshal added in v1.55.1 

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

func (*Get2NdMessageRequest) XXX_DiscardUnknown added in v1.55.1 

func (m *Get2NdMessageRequest) XXX_DiscardUnknown()

func (*Get2NdMessageRequest) XXX_Marshal added in v1.55.1 

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

func (*Get2NdMessageRequest) XXX_Merge added in v1.55.1 

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

func (*Get2NdMessageRequest) XXX_Size added in v1.55.1 

func (m *Get2NdMessageRequest) XXX_Size() int

func (*Get2NdMessageRequest) XXX_Unmarshal added in v1.55.1 

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

type Get2NdMessageResponse added in v1.55.1 

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

func (*Get2NdMessageResponse) Descriptor added in v1.55.1 

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

func (*Get2NdMessageResponse) Equal added in v1.55.1 

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

func (*Get2NdMessageResponse) GetMessage added in v1.55.1 

func (m *Get2NdMessageResponse) GetMessage() string

func (*Get2NdMessageResponse) GoString added in v1.55.1 

func (this *Get2NdMessageResponse) GoString() string

func (*Get2NdMessageResponse) Marshal added in v1.55.1 

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

func (*Get2NdMessageResponse) MarshalTo added in v1.55.1 

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

func (*Get2NdMessageResponse) MarshalToSizedBuffer added in v1.55.1 

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

func (*Get2NdMessageResponse) ProtoMessage added in v1.55.1 

func (*Get2NdMessageResponse) ProtoMessage()

func (*Get2NdMessageResponse) Reset added in v1.55.1 

func (m *Get2NdMessageResponse) Reset()

func (*Get2NdMessageResponse) Size added in v1.55.1 

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

func (*Get2NdMessageResponse) String added in v1.55.1 

func (this *Get2NdMessageResponse) String() string

func (*Get2NdMessageResponse) Unmarshal added in v1.55.1 

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

func (*Get2NdMessageResponse) XXX_DiscardUnknown added in v1.55.1 

func (m *Get2NdMessageResponse) XXX_DiscardUnknown()

func (*Get2NdMessageResponse) XXX_Marshal added in v1.55.1 

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

func (*Get2NdMessageResponse) XXX_Merge added in v1.55.1 

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

func (*Get2NdMessageResponse) XXX_Size added in v1.55.1 

func (m *Get2NdMessageResponse) XXX_Size() int

func (*Get2NdMessageResponse) XXX_Unmarshal added in v1.55.1 

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

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 TestMessageNameParityClient added in v1.55.1 

type TestMessageNameParityClient interface {
	MessageName(ctx context.Context, in *Get2NdMessageRequest, opts ...grpc.CallOption) (*Get2NdMessageResponse, error)
}

TestMessageNameParityClient is the client API for TestMessageNameParity service.

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

func NewTestMessageNameParityClient added in v1.55.1 

func NewTestMessageNameParityClient(cc *grpc.ClientConn) TestMessageNameParityClient

type TestMessageNameParityServer added in v1.55.1 

type TestMessageNameParityServer interface {
	MessageName(context.Context, *Get2NdMessageRequest) (*Get2NdMessageResponse, error)
}

TestMessageNameParityServer is the server API for TestMessageNameParity service.

type TestMessageNameParityYARPCClient added in v1.55.1 

type TestMessageNameParityYARPCClient interface {
	MessageName(context.Context, *Get2NdMessageRequest, ...yarpc.CallOption) (*Get2NdMessageResponse, error)
}

TestMessageNameParityYARPCClient is the YARPC client-side interface for the TestMessageNameParity service.

func NewTestMessageNameParityYARPCClient added in v1.55.1 

func NewTestMessageNameParityYARPCClient(clientConfig transport.ClientConfig, options ...protobuf.ClientOption) TestMessageNameParityYARPCClient

NewTestMessageNameParityYARPCClient builds a new YARPC client for the TestMessageNameParity service.

type TestMessageNameParityYARPCServer added in v1.55.1 

type TestMessageNameParityYARPCServer interface {
	MessageName(context.Context, *Get2NdMessageRequest) (*Get2NdMessageResponse, error)
}

TestMessageNameParityYARPCServer is the YARPC server-side interface for the TestMessageNameParity service.

type UnimplementedFooServer 

type UnimplementedFooServer struct {
}

UnimplementedFooServer can be embedded to have forward compatible implementations.

func (*UnimplementedFooServer) EchoBoth 

func (*UnimplementedFooServer) EchoBoth(srv Foo_EchoBothServer) error

func (*UnimplementedFooServer) EchoIn 

func (*UnimplementedFooServer) EchoIn(req *EchoInRequest, srv Foo_EchoInServer) error

func (*UnimplementedFooServer) EchoOut 

func (*UnimplementedFooServer) EchoOut(srv Foo_EchoOutServer) error

type UnimplementedKeyValueServer 

type UnimplementedKeyValueServer struct {
}

UnimplementedKeyValueServer can be embedded to have forward compatible implementations.

func (*UnimplementedKeyValueServer) GetValue 

func (*UnimplementedKeyValueServer) GetValue(ctx context.Context, req *GetValueRequest) (*GetValueResponse, error)

func (*UnimplementedKeyValueServer) SetValue 

func (*UnimplementedKeyValueServer) SetValue(ctx context.Context, req *SetValueRequest) (*SetValueResponse, error)

type UnimplementedTestMessageNameParityServer added in v1.55.1 

type UnimplementedTestMessageNameParityServer struct {
}

UnimplementedTestMessageNameParityServer can be embedded to have forward compatible implementations.

func (*UnimplementedTestMessageNameParityServer) MessageName added in v1.55.1 

func (*UnimplementedTestMessageNameParityServer) MessageName(ctx context.Context, req *Get2NdMessageRequest) (*Get2NdMessageResponse, error)

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.