echo

Documentation

Index

• Variables
• func BuildEchoYARPCProcedures(server EchoYARPCServer) []transport.Procedure
• func NewFxEchoYARPCClient(name string, options ...protobuf.ClientOption) interface{}
• func NewFxEchoYARPCProcedures() interface{}
• type EchoYARPCClient
  • func NewEchoYARPCClient(clientConfig transport.ClientConfig, options ...protobuf.ClientOption) EchoYARPCClient
• type EchoYARPCServer
• type FxEchoYARPCClientParams
• type FxEchoYARPCClientResult
• type FxEchoYARPCProceduresParams
• type FxEchoYARPCProceduresResult
• type Request
  • func (*Request) Descriptor() ([]byte, []int)
  • func (this *Request) Equal(that interface{}) bool
  • func (m *Request) GetMessage() string
  • func (this *Request) GoString() string
  • func (m *Request) Marshal() (dAtA []byte, err error)
  • func (m *Request) MarshalTo(dAtA []byte) (int, error)
  • func (*Request) ProtoMessage()
  • func (m *Request) Reset()
  • func (m *Request) Size() (n int)
  • func (this *Request) String() string
  • func (m *Request) Unmarshal(dAtA []byte) error
  • func (m *Request) XXX_DiscardUnknown()
  • func (m *Request) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *Request) XXX_Merge(src proto.Message)
  • func (m *Request) XXX_Size() int
  • func (m *Request) XXX_Unmarshal(b []byte) error
• type Response
  • func (*Response) Descriptor() ([]byte, []int)
  • func (this *Response) Equal(that interface{}) bool
  • func (m *Response) GetMessage() string
  • func (this *Response) GoString() string
  • func (m *Response) Marshal() (dAtA []byte, err error)
  • func (m *Response) MarshalTo(dAtA []byte) (int, error)
  • func (*Response) ProtoMessage()
  • func (m *Response) Reset()
  • func (m *Response) Size() (n int)
  • func (this *Response) String() string
  • func (m *Response) Unmarshal(dAtA []byte) error
  • func (m *Response) XXX_DiscardUnknown()
  • func (m *Response) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *Response) XXX_Merge(src proto.Message)
  • func (m *Response) XXX_Size() int
  • func (m *Response) XXX_Unmarshal(b []byte) error

Variables

var (
	ErrInvalidLengthEcho = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowEcho   = 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 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(
  echo.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(
  echo.NewFxEchoYARPCProcedures(),
  ...
)

Types

type EchoYARPCClient

type EchoYARPCClient interface {
	Echo(context.Context, *Request, ...yarpc.CallOption) (*Response, error)
}

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

type EchoYARPCServer interface {
	Echo(context.Context, *Request) (*Response, error)
}

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"`
	Restriction restriction.Checker `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 Request

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

func (*Request) Descriptor

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

func (*Request) Equal

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

func (*Request) GetMessage

func (m *Request) GetMessage() string

func (*Request) GoString

func (this *Request) GoString() string

func (*Request) Marshal

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

func (*Request) MarshalTo

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

func (*Request) ProtoMessage

func (*Request) ProtoMessage()

func (*Request) Reset

func (m *Request) Reset()

func (*Request) Size

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

func (*Request) String

func (this *Request) String() string

func (*Request) Unmarshal

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

func (*Request) XXX_DiscardUnknown

func (m *Request) XXX_DiscardUnknown()

func (*Request) XXX_Marshal

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

func (*Request) XXX_Merge

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

func (*Request) XXX_Size

func (m *Request) XXX_Size() int

func (*Request) XXX_Unmarshal

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

type Response

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

func (*Response) Descriptor

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

func (*Response) Equal

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

func (*Response) GetMessage

func (m *Response) GetMessage() string

func (*Response) GoString

func (this *Response) GoString() string

func (*Response) Marshal

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

func (*Response) MarshalTo

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

func (*Response) ProtoMessage

func (*Response) ProtoMessage()

func (*Response) Reset

func (m *Response) Reset()

func (*Response) Size

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

func (*Response) String

func (this *Response) String() string

func (*Response) Unmarshal

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

func (*Response) XXX_DiscardUnknown

func (m *Response) XXX_DiscardUnknown()

func (*Response) XXX_Marshal

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

func (*Response) XXX_Merge

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

func (*Response) XXX_Size

func (m *Response) XXX_Size() int

func (*Response) XXX_Unmarshal

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