echo

package
v1.3.0 Latest Latest
Warning

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

Go to latest
Published: Aug 3, 2023 License: MIT Imports: 15 Imported by: 12

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrInvalidLengthEcho = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowEcho   = fmt.Errorf("proto: integer overflow")
)

Functions

func BuildEchoInternalYARPCProcedures added in v0.6.1

func BuildEchoInternalYARPCProcedures(server EchoInternalYARPCServer) []transport.Procedure

BuildEchoInternalYARPCProcedures prepares an implementation of the EchoInternal service for YARPC registration.

func BuildEchoYARPCProcedures

func BuildEchoYARPCProcedures(server EchoYARPCServer) []transport.Procedure

BuildEchoYARPCProcedures prepares an implementation of the Echo service for YARPC registration.

func NewFxEchoInternalYARPCClient added in v0.6.1

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

NewFxEchoInternalYARPCClient provides a EchoInternalYARPCClient to an Fx application using the given name for routing.

fx.Provide(
  echo.NewFxEchoInternalYARPCClient("service-name"),
  ...
)

func NewFxEchoInternalYARPCProcedures added in v0.6.1

func NewFxEchoInternalYARPCProcedures() interface{}

NewFxEchoInternalYARPCProcedures provides EchoInternalYARPCServer procedures to an Fx application. It expects a EchoInternalYARPCServer to be present in the container.

fx.Provide(
  echo.NewFxEchoInternalYARPCProcedures(),
  ...
)

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 EchoInternalYARPCClient added in v0.6.1

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

EchoInternalYARPCClient is the YARPC client-side interface for the EchoInternal service.

func NewEchoInternalYARPCClient added in v0.6.1

func NewEchoInternalYARPCClient(clientConfig transport.ClientConfig, options ...protobuf.ClientOption) EchoInternalYARPCClient

NewEchoInternalYARPCClient builds a new YARPC client for the EchoInternal service.

type EchoInternalYARPCServer added in v0.6.1

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

EchoInternalYARPCServer is the YARPC server-side interface for the EchoInternal service.

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 FxEchoInternalYARPCClientParams added in v0.6.1

type FxEchoInternalYARPCClientParams struct {
	fx.In

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

FxEchoInternalYARPCClientParams defines the input for NewFxEchoInternalYARPCClient. It provides the paramaters to get a EchoInternalYARPCClient in an Fx application.

type FxEchoInternalYARPCClientResult added in v0.6.1

type FxEchoInternalYARPCClientResult struct {
	fx.Out

	Client EchoInternalYARPCClient
}

FxEchoInternalYARPCClientResult defines the output of NewFxEchoInternalYARPCClient. It provides a EchoInternalYARPCClient to an Fx application.

type FxEchoInternalYARPCProceduresParams added in v0.6.1

type FxEchoInternalYARPCProceduresParams struct {
	fx.In

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

FxEchoInternalYARPCProceduresParams defines the input for NewFxEchoInternalYARPCProcedures. It provides the paramaters to get EchoInternalYARPCServer procedures in an Fx application.

type FxEchoInternalYARPCProceduresResult added in v0.6.1

type FxEchoInternalYARPCProceduresResult struct {
	fx.Out

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

FxEchoInternalYARPCProceduresResult defines the output of NewFxEchoInternalYARPCProcedures. It provides EchoInternalYARPCServer 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 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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL