echo

package
v0.26.2 Latest Latest
Warning

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

 Go to latest Published: Feb 26, 2024 License: MIT Imports: 13 Imported by: 0

Documentation

Index

Constants

View Source 
const SRPCEchoerServiceID = "echo.Echoer"

Variables

View Source 
var File_github_com_aperturerobotics_starpc_echo_echo_proto protoreflect.FileDescriptor

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() proto.Message

func (*EchoMsg) CloneVT added in v0.12.3 

func (m *EchoMsg) CloneVT() *EchoMsg

func (*EchoMsg) Descriptor deprecated 

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

Deprecated: Use EchoMsg.ProtoReflect.Descriptor instead.

func (*EchoMsg) EqualMessageVT added in v0.18.3 

func (this *EchoMsg) EqualMessageVT(thatMsg proto.Message) bool

func (*EchoMsg) EqualVT 

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

func (*EchoMsg) GetBody 

func (x *EchoMsg) GetBody() 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) ProtoReflect 

func (x *EchoMsg) ProtoReflect() protoreflect.Message

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) 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) 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 (e *EchoServer) Register(mux srpc.Mux) error

Register registers the Echo server with the Mux.

func (*EchoServer) RpcStream added in v0.5.0 

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

RpcStream runs a rpc stream

type SRPCEchoerClient 

type SRPCEchoerClient interface {
	SRPCClient() srpc.Client

	Echo(ctx context.Context, in *EchoMsg) (*EchoMsg, error)
	EchoServerStream(ctx context.Context, in *EchoMsg) (SRPCEchoer_EchoServerStreamClient, error)
	EchoClientStream(ctx context.Context) (SRPCEchoer_EchoClientStreamClient, error)
	EchoBidiStream(ctx context.Context) (SRPCEchoer_EchoBidiStreamClient, error)
	RpcStream(ctx context.Context) (SRPCEchoer_RpcStreamClient, 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_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(context.Context, *EchoMsg) (*EchoMsg, error)
	EchoServerStream(*EchoMsg, SRPCEchoer_EchoServerStreamStream) error
	EchoClientStream(SRPCEchoer_EchoClientStreamStream) (*EchoMsg, error)
	EchoBidiStream(SRPCEchoer_EchoBidiStreamStream) error
	RpcStream(SRPCEchoer_RpcStreamStream) error
}

type SRPCEchoerUnimplementedServer 

type SRPCEchoerUnimplementedServer struct{}

func (*SRPCEchoerUnimplementedServer) Echo 

func (s *SRPCEchoerUnimplementedServer) Echo(context.Context, *EchoMsg) (*EchoMsg, error)

func (*SRPCEchoerUnimplementedServer) EchoBidiStream 

func (s *SRPCEchoerUnimplementedServer) EchoBidiStream(SRPCEchoer_EchoBidiStreamStream) error

func (*SRPCEchoerUnimplementedServer) EchoClientStream 

func (s *SRPCEchoerUnimplementedServer) EchoClientStream(SRPCEchoer_EchoClientStreamStream) (*EchoMsg, error)

func (*SRPCEchoerUnimplementedServer) EchoServerStream 

func (s *SRPCEchoerUnimplementedServer) EchoServerStream(*EchoMsg, SRPCEchoer_EchoServerStreamStream) error

func (*SRPCEchoerUnimplementedServer) RpcStream added in v0.5.0 

func (s *SRPCEchoerUnimplementedServer) RpcStream(SRPCEchoer_RpcStreamStream) error

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.