Documentation ¶
Index ¶
- Variables
- func BuildEchoYARPCProcedures(server EchoYARPCServer) []transport.Procedure
- func BuildOnewayYARPCProcedures(server OnewayYARPCServer) []transport.Procedure
- func NewFxEchoYARPCClient(name string, options ...protobuf.ClientOption) interface{}
- func NewFxEchoYARPCProcedures() interface{}
- func NewFxOnewayYARPCClient(name string, options ...protobuf.ClientOption) interface{}
- func NewFxOnewayYARPCProcedures() interface{}
- func RegisterEchoServer(s *grpc.Server, srv EchoServer)
- func RegisterOnewayServer(s *grpc.Server, srv OnewayServer)
- type EchoClient
- type EchoServer
- type EchoYARPCClient
- type EchoYARPCServer
- type FxEchoYARPCClientParams
- type FxEchoYARPCClientResult
- type FxEchoYARPCProceduresParams
- type FxEchoYARPCProceduresResult
- type FxOnewayYARPCClientParams
- type FxOnewayYARPCClientResult
- type FxOnewayYARPCProceduresParams
- type FxOnewayYARPCProceduresResult
- type OnewayClient
- type OnewayServer
- type OnewayYARPCClient
- type OnewayYARPCServer
- type Ping
- func (*Ping) Descriptor() ([]byte, []int)
- func (this *Ping) Equal(that interface{}) bool
- func (m *Ping) GetBeep() string
- func (this *Ping) GoString() string
- func (m *Ping) Marshal() (dAtA []byte, err error)
- func (m *Ping) MarshalTo(dAtA []byte) (int, error)
- func (*Ping) ProtoMessage()
- func (m *Ping) Reset()
- func (m *Ping) Size() (n int)
- func (this *Ping) String() string
- func (m *Ping) Unmarshal(dAtA []byte) error
- func (m *Ping) XXX_DiscardUnknown()
- func (m *Ping) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Ping) XXX_Merge(src proto.Message)
- func (m *Ping) XXX_Size() int
- func (m *Ping) XXX_Unmarshal(b []byte) error
- type Pong
- func (*Pong) Descriptor() ([]byte, []int)
- func (this *Pong) Equal(that interface{}) bool
- func (m *Pong) GetBoop() string
- func (this *Pong) GoString() string
- func (m *Pong) Marshal() (dAtA []byte, err error)
- func (m *Pong) MarshalTo(dAtA []byte) (int, error)
- func (*Pong) ProtoMessage()
- func (m *Pong) Reset()
- func (m *Pong) Size() (n int)
- func (this *Pong) String() string
- func (m *Pong) Unmarshal(dAtA []byte) error
- func (m *Pong) XXX_DiscardUnknown()
- func (m *Pong) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Pong) XXX_Merge(src proto.Message)
- func (m *Pong) XXX_Size() int
- func (m *Pong) XXX_Unmarshal(b []byte) error
- type Token
- func (*Token) Descriptor() ([]byte, []int)
- func (this *Token) Equal(that interface{}) bool
- func (m *Token) GetValue() string
- func (this *Token) GoString() string
- func (m *Token) Marshal() (dAtA []byte, err error)
- func (m *Token) MarshalTo(dAtA []byte) (int, error)
- func (*Token) ProtoMessage()
- func (m *Token) Reset()
- func (m *Token) Size() (n int)
- func (this *Token) String() string
- func (m *Token) Unmarshal(dAtA []byte) error
- func (m *Token) XXX_DiscardUnknown()
- func (m *Token) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Token) XXX_Merge(src proto.Message)
- func (m *Token) XXX_Size() int
- func (m *Token) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
var ( ErrInvalidLengthCrossdock = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowCrossdock = fmt.Errorf("proto: integer overflow") )
Functions ¶
func BuildEchoYARPCProcedures ¶
func BuildEchoYARPCProcedures(server EchoYARPCServer) []transport.Procedure
BuildEchoYARPCProcedures prepares an implementation of the Echo service for YARPC registration.
func BuildOnewayYARPCProcedures ¶
func BuildOnewayYARPCProcedures(server OnewayYARPCServer) []transport.Procedure
BuildOnewayYARPCProcedures prepares an implementation of the Oneway service for YARPC registration.
func NewFxEchoYARPCClient ¶
func NewFxEchoYARPCClient(name string, options ...protobuf.ClientOption) interface{}
NewFxEchoYARPCClient provides a EchoYARPCClient to an Fx application using the given name for routing.
fx.Provide( crossdockpb.NewFxEchoYARPCClient("service-name"), ... )
func NewFxEchoYARPCProcedures ¶
func NewFxEchoYARPCProcedures() interface{}
NewFxEchoYARPCProcedures provides EchoYARPCServer procedures to an Fx application. It expects a EchoYARPCServer to be present in the container.
fx.Provide( crossdockpb.NewFxEchoYARPCProcedures(), ... )
func NewFxOnewayYARPCClient ¶
func NewFxOnewayYARPCClient(name string, options ...protobuf.ClientOption) interface{}
NewFxOnewayYARPCClient provides a OnewayYARPCClient to an Fx application using the given name for routing.
fx.Provide( crossdockpb.NewFxOnewayYARPCClient("service-name"), ... )
func NewFxOnewayYARPCProcedures ¶
func NewFxOnewayYARPCProcedures() interface{}
NewFxOnewayYARPCProcedures provides OnewayYARPCServer procedures to an Fx application. It expects a OnewayYARPCServer to be present in the container.
fx.Provide( crossdockpb.NewFxOnewayYARPCProcedures(), ... )
func RegisterEchoServer ¶
func RegisterEchoServer(s *grpc.Server, srv EchoServer)
func RegisterOnewayServer ¶
func RegisterOnewayServer(s *grpc.Server, srv OnewayServer)
Types ¶
type EchoClient ¶
type EchoClient interface {
Echo(ctx context.Context, in *Ping, opts ...grpc.CallOption) (*Pong, error)
}
EchoClient is the client API for Echo service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewEchoClient ¶
func NewEchoClient(cc *grpc.ClientConn) EchoClient
type EchoServer ¶
EchoServer is the server API for Echo service.
type EchoYARPCClient ¶
EchoYARPCClient is the YARPC client-side interface for the Echo service.
func NewEchoYARPCClient ¶
func NewEchoYARPCClient(clientConfig transport.ClientConfig, options ...protobuf.ClientOption) EchoYARPCClient
NewEchoYARPCClient builds a new YARPC client for the Echo service.
type EchoYARPCServer ¶
EchoYARPCServer is the YARPC server-side interface for the Echo service.
type FxEchoYARPCClientParams ¶
type FxEchoYARPCClientParams struct { fx.In Provider yarpc.ClientConfig AnyResolver jsonpb.AnyResolver `name:"yarpcfx" optional:"true"` }
FxEchoYARPCClientParams defines the input for NewFxEchoYARPCClient. It provides the paramaters to get a EchoYARPCClient in an Fx application.
type FxEchoYARPCClientResult ¶
type FxEchoYARPCClientResult struct { fx.Out Client EchoYARPCClient }
FxEchoYARPCClientResult defines the output of NewFxEchoYARPCClient. It provides a EchoYARPCClient to an Fx application.
type FxEchoYARPCProceduresParams ¶
type FxEchoYARPCProceduresParams struct { fx.In Server EchoYARPCServer AnyResolver jsonpb.AnyResolver `name:"yarpcfx" optional:"true"` }
FxEchoYARPCProceduresParams defines the input for NewFxEchoYARPCProcedures. It provides the paramaters to get EchoYARPCServer procedures in an Fx application.
type FxEchoYARPCProceduresResult ¶
type FxEchoYARPCProceduresResult struct { fx.Out Procedures []transport.Procedure `group:"yarpcfx"` ReflectionMeta reflection.ServerMeta `group:"yarpcfx"` }
FxEchoYARPCProceduresResult defines the output of NewFxEchoYARPCProcedures. It provides EchoYARPCServer 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 FxOnewayYARPCClientParams ¶
type FxOnewayYARPCClientParams struct { fx.In Provider yarpc.ClientConfig AnyResolver jsonpb.AnyResolver `name:"yarpcfx" optional:"true"` }
FxOnewayYARPCClientParams defines the input for NewFxOnewayYARPCClient. It provides the paramaters to get a OnewayYARPCClient in an Fx application.
type FxOnewayYARPCClientResult ¶
type FxOnewayYARPCClientResult struct { fx.Out Client OnewayYARPCClient }
FxOnewayYARPCClientResult defines the output of NewFxOnewayYARPCClient. It provides a OnewayYARPCClient to an Fx application.
type FxOnewayYARPCProceduresParams ¶
type FxOnewayYARPCProceduresParams struct { fx.In Server OnewayYARPCServer AnyResolver jsonpb.AnyResolver `name:"yarpcfx" optional:"true"` }
FxOnewayYARPCProceduresParams defines the input for NewFxOnewayYARPCProcedures. It provides the paramaters to get OnewayYARPCServer procedures in an Fx application.
type FxOnewayYARPCProceduresResult ¶
type FxOnewayYARPCProceduresResult struct { fx.Out Procedures []transport.Procedure `group:"yarpcfx"` ReflectionMeta reflection.ServerMeta `group:"yarpcfx"` }
FxOnewayYARPCProceduresResult defines the output of NewFxOnewayYARPCProcedures. It provides OnewayYARPCServer 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 OnewayClient ¶
type OnewayClient interface {
Echo(ctx context.Context, in *Token, opts ...grpc.CallOption) (*yarpcproto.Oneway, error)
}
OnewayClient is the client API for Oneway service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewOnewayClient ¶
func NewOnewayClient(cc *grpc.ClientConn) OnewayClient
type OnewayServer ¶
OnewayServer is the server API for Oneway service.
type OnewayYARPCClient ¶
type OnewayYARPCClient interface {
Echo(context.Context, *Token, ...yarpc.CallOption) (yarpc.Ack, error)
}
OnewayYARPCClient is the YARPC client-side interface for the Oneway service.
func NewOnewayYARPCClient ¶
func NewOnewayYARPCClient(clientConfig transport.ClientConfig, options ...protobuf.ClientOption) OnewayYARPCClient
NewOnewayYARPCClient builds a new YARPC client for the Oneway service.
type OnewayYARPCServer ¶
OnewayYARPCServer is the YARPC server-side interface for the Oneway service.
type Ping ¶
type Ping struct {
Beep string `protobuf:"bytes,1,opt,name=beep,proto3" json:"beep,omitempty"`
}
func (*Ping) Descriptor ¶
func (*Ping) ProtoMessage ¶
func (*Ping) ProtoMessage()
func (*Ping) XXX_DiscardUnknown ¶
func (m *Ping) XXX_DiscardUnknown()
func (*Ping) XXX_Unmarshal ¶
type Pong ¶
type Pong struct {
Boop string `protobuf:"bytes,1,opt,name=boop,proto3" json:"boop,omitempty"`
}
func (*Pong) Descriptor ¶
func (*Pong) ProtoMessage ¶
func (*Pong) ProtoMessage()
func (*Pong) XXX_DiscardUnknown ¶
func (m *Pong) XXX_DiscardUnknown()
func (*Pong) XXX_Unmarshal ¶
type Token ¶
type Token struct {
Value string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
}
func (*Token) Descriptor ¶
func (*Token) ProtoMessage ¶
func (*Token) ProtoMessage()
func (*Token) XXX_DiscardUnknown ¶
func (m *Token) XXX_DiscardUnknown()