Help us shape the future of Go! Take the 2026 Go Developer Survey

echo

package
v0.52.3 Latest Latest
Warning

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

 Go to latest Published: Oct 18, 2026 License: MIT Imports: 11 Imported by: 0

Documentation

Index

Constants

View Source 
const SRPCEchoerServiceID = "echo.Echoer"

Variables

This section is empty.

Functions

func NewSRPCEchoerHandler added in v0.10.9 

func NewSRPCEchoerHandler(impl SRPCEchoerServer, serviceID string) srpc.Handler

NewSRPCEchoerHandler constructs a new RPC handler. serviceID: if empty, uses default: echo.Echoer

func SRPCRegisterEchoer 

func SRPCRegisterEchoer(mux srpc.Mux, impl SRPCEchoerServer) error

SRPCRegisterEchoer registers the implementation with the mux. Uses the default serviceID: echo.Echoer

Types

type EchoMsg 

type EchoMsg struct {
	Body string `protobuf:"bytes,1,opt,name=body,proto3" json:"body,omitempty"`
	// contains filtered or unexported fields
}

EchoMsg is the message body for Echo.

func (*EchoMsg) CloneMessageVT added in v0.18.3 

func (m *EchoMsg) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*EchoMsg) CloneVT added in v0.12.3 

func (m *EchoMsg) CloneVT() *EchoMsg

func (*EchoMsg) EqualMessageVT added in v0.18.3 

func (this *EchoMsg) EqualMessageVT(thatMsg any) bool

func (*EchoMsg) EqualVT 

func (this *EchoMsg) EqualVT(that *EchoMsg) bool

func (*EchoMsg) GetBody 

func (x *EchoMsg) GetBody() string

func (*EchoMsg) MarshalJSON added in v0.30.0 

func (x *EchoMsg) MarshalJSON() ([]byte, error)

MarshalJSON marshals the EchoMsg to JSON.

func (*EchoMsg) MarshalProtoJSON added in v0.30.0 

func (x *EchoMsg) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the EchoMsg message to JSON.

func (*EchoMsg) MarshalProtoText added in v0.31.4 

func (x *EchoMsg) MarshalProtoText() string

func (*EchoMsg) MarshalToSizedBufferVT 

func (m *EchoMsg) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*EchoMsg) MarshalToVT 

func (m *EchoMsg) MarshalToVT(dAtA []byte) (int, error)

func (*EchoMsg) MarshalVT 

func (m *EchoMsg) MarshalVT() (dAtA []byte, err error)

func (*EchoMsg) ProtoMessage 

func (*EchoMsg) ProtoMessage()

func (*EchoMsg) Reset 

func (x *EchoMsg) Reset()

func (*EchoMsg) SizeVT 

func (m *EchoMsg) SizeVT() (n int)

func (*EchoMsg) String 

func (x *EchoMsg) String() string

func (*EchoMsg) UnmarshalJSON added in v0.30.1 

func (x *EchoMsg) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the EchoMsg from JSON.

func (*EchoMsg) UnmarshalProtoJSON added in v0.30.1 

func (x *EchoMsg) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the EchoMsg message from JSON.

func (*EchoMsg) UnmarshalVT 

func (m *EchoMsg) UnmarshalVT(dAtA []byte) error

type EchoServer 

type EchoServer struct {
	// contains filtered or unexported fields
}

EchoServer implements the server side of Echo.

func NewEchoServer added in v0.5.0 

func NewEchoServer(rpcStreamMux srpc.Mux) *EchoServer

NewEchoServer constructs a EchoServer with a RpcStream mux.

func (*EchoServer) DoNothing added in v0.32.9 

func (s *EchoServer) DoNothing(ctx context.Context, empty *emptypb.Empty) (*emptypb.Empty, error)

DoNothing does nothing.

func (*EchoServer) Echo 

func (*EchoServer) Echo(ctx context.Context, msg *EchoMsg) (*EchoMsg, error)

Echo implements echo.SRPCEchoerServer

func (*EchoServer) EchoBidiStream 

func (s *EchoServer) EchoBidiStream(strm SRPCEchoer_EchoBidiStreamStream) error

EchoBidiStream implements SRPCEchoerServer

func (*EchoServer) EchoClientStream 

func (*EchoServer) EchoClientStream(strm SRPCEchoer_EchoClientStreamStream) (*EchoMsg, error)

EchoClientStream implements SRPCEchoerServer

func (*EchoServer) EchoServerStream 

func (*EchoServer) EchoServerStream(msg *EchoMsg, strm SRPCEchoer_EchoServerStreamStream) error

EchoServerStream implements SRPCEchoerServer

func (*EchoServer) Register added in v0.8.4 

func (s *EchoServer) Register(mux srpc.Mux) error

Register registers the Echo server with the Mux.

func (*EchoServer) RpcStream added in v0.5.0 

func (s *EchoServer) RpcStream(stream SRPCEchoer_RpcStreamStream) error

RpcStream runs a rpc stream

type SRPCEchoerClient 

type SRPCEchoerClient interface {
	// SRPCClient returns the underlying SRPC client.
	SRPCClient() srpc.Client

	// Echo returns the given message.
	Echo(ctx context.Context, in *EchoMsg) (*EchoMsg, error)
	// EchoServerStream is an example of a server -> client one-way stream.
	EchoServerStream(ctx context.Context, in *EchoMsg) (SRPCEchoer_EchoServerStreamClient, error)
	// EchoClientStream is an example of client->server one-way stream.
	EchoClientStream(ctx context.Context) (SRPCEchoer_EchoClientStreamClient, error)
	// EchoBidiStream is an example of a two-way stream.
	EchoBidiStream(ctx context.Context) (SRPCEchoer_EchoBidiStreamClient, error)
	// RpcStream opens a nested rpc call stream.
	RpcStream(ctx context.Context) (SRPCEchoer_RpcStreamClient, error)
	// DoNothing does nothing.
	DoNothing(ctx context.Context, in *emptypb.Empty) (*emptypb.Empty, error)
}

func NewSRPCEchoerClient 

func NewSRPCEchoerClient(cc srpc.Client) SRPCEchoerClient

func NewSRPCEchoerClientWithServiceID added in v0.11.2 

func NewSRPCEchoerClientWithServiceID(cc srpc.Client, serviceID string) SRPCEchoerClient

type SRPCEchoerHandler 

type SRPCEchoerHandler struct {
	// contains filtered or unexported fields
}

func (SRPCEchoerHandler) GetMethodIDs 

func (SRPCEchoerHandler) GetMethodIDs() []string

func (*SRPCEchoerHandler) GetServiceID 

func (d *SRPCEchoerHandler) GetServiceID() string

func (*SRPCEchoerHandler) InvokeMethod 

func (d *SRPCEchoerHandler) InvokeMethod(
	serviceID, methodID string,
	strm srpc.Stream,
) (bool, error)

func (SRPCEchoerHandler) InvokeMethod_DoNothing added in v0.32.9 

func (SRPCEchoerHandler) InvokeMethod_DoNothing(impl SRPCEchoerServer, strm srpc.Stream) error

func (SRPCEchoerHandler) InvokeMethod_Echo 

func (SRPCEchoerHandler) InvokeMethod_Echo(impl SRPCEchoerServer, strm srpc.Stream) error

func (SRPCEchoerHandler) InvokeMethod_EchoBidiStream 

func (SRPCEchoerHandler) InvokeMethod_EchoBidiStream(impl SRPCEchoerServer, strm srpc.Stream) error

func (SRPCEchoerHandler) InvokeMethod_EchoClientStream 

func (SRPCEchoerHandler) InvokeMethod_EchoClientStream(impl SRPCEchoerServer, strm srpc.Stream) error

func (SRPCEchoerHandler) InvokeMethod_EchoServerStream 

func (SRPCEchoerHandler) InvokeMethod_EchoServerStream(impl SRPCEchoerServer, strm srpc.Stream) error

func (SRPCEchoerHandler) InvokeMethod_RpcStream added in v0.5.0 

func (SRPCEchoerHandler) InvokeMethod_RpcStream(impl SRPCEchoerServer, strm srpc.Stream) error

type SRPCEchoerServer 

type SRPCEchoerServer interface {
	// Echo returns the given message.
	Echo(context.Context, *EchoMsg) (*EchoMsg, error)
	// EchoServerStream is an example of a server -> client one-way stream.
	EchoServerStream(*EchoMsg, SRPCEchoer_EchoServerStreamStream) error
	// EchoClientStream is an example of client->server one-way stream.
	EchoClientStream(SRPCEchoer_EchoClientStreamStream) (*EchoMsg, error)
	// EchoBidiStream is an example of a two-way stream.
	EchoBidiStream(SRPCEchoer_EchoBidiStreamStream) error
	// RpcStream opens a nested rpc call stream.
	RpcStream(SRPCEchoer_RpcStreamStream) error
	// DoNothing does nothing.
	DoNothing(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
}

type SRPCEchoer_DoNothingStream added in v0.32.9 

type SRPCEchoer_DoNothingStream interface {
	srpc.Stream
}

type SRPCEchoer_EchoBidiStreamClient 

type SRPCEchoer_EchoBidiStreamClient interface {
	srpc.Stream
	Send(*EchoMsg) error
	Recv() (*EchoMsg, error)
	RecvTo(*EchoMsg) error
}

type SRPCEchoer_EchoBidiStreamStream 

type SRPCEchoer_EchoBidiStreamStream interface {
	srpc.Stream
	Send(*EchoMsg) error
	SendAndClose(*EchoMsg) error
	Recv() (*EchoMsg, error)
	RecvTo(*EchoMsg) error
}

type SRPCEchoer_EchoClientStreamClient 

type SRPCEchoer_EchoClientStreamClient interface {
	srpc.Stream
	Send(*EchoMsg) error
	CloseAndRecv() (*EchoMsg, error)
}

type SRPCEchoer_EchoClientStreamStream 

type SRPCEchoer_EchoClientStreamStream interface {
	srpc.Stream
	Recv() (*EchoMsg, error)
	RecvTo(*EchoMsg) error
}

type SRPCEchoer_EchoServerStreamClient 

type SRPCEchoer_EchoServerStreamClient interface {
	srpc.Stream
	Recv() (*EchoMsg, error)
	RecvTo(*EchoMsg) error
}

type SRPCEchoer_EchoServerStreamStream 

type SRPCEchoer_EchoServerStreamStream interface {
	srpc.Stream
	Send(*EchoMsg) error
	SendAndClose(*EchoMsg) error
}

type SRPCEchoer_EchoStream 

type SRPCEchoer_EchoStream interface {
	srpc.Stream
}

type SRPCEchoer_RpcStreamClient added in v0.5.0 

type SRPCEchoer_RpcStreamClient interface {
	srpc.Stream
	Send(*rpcstream.RpcStreamPacket) error
	Recv() (*rpcstream.RpcStreamPacket, error)
	RecvTo(*rpcstream.RpcStreamPacket) error
}

type SRPCEchoer_RpcStreamStream added in v0.5.0 

type SRPCEchoer_RpcStreamStream interface {
	srpc.Stream
	Send(*rpcstream.RpcStreamPacket) error
	SendAndClose(*rpcstream.RpcStreamPacket) error
	Recv() (*rpcstream.RpcStreamPacket, error)
	RecvTo(*rpcstream.RpcStreamPacket) 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.