echo

package
v0.4.2 Latest Latest
Warning

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

 Go to latest Published: Jun 26, 2022 License: MIT Imports: 12 Imported by: 0

Documentation

Index

Constants

View Source 
const SRPCEchoerServiceID = "echo.Echoer"

Variables

View Source 
var (
	ErrInvalidLength        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflow          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroup = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var File_github_com_aperturerobotics_starpc_echo_echo_proto protoreflect.FileDescriptor

Functions

func SRPCRegisterEchoer 

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

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) Descriptor deprecated 

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

Deprecated: Use EchoMsg.ProtoReflect.Descriptor instead.

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 {
}

EchoServer implements the server side of Echo.

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) error

EchoClientStream implements SRPCEchoerServer

func (*EchoServer) EchoServerStream 

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

EchoServerStream implements SRPCEchoerServer

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)
}

func NewSRPCEchoerClient 

func NewSRPCEchoerClient(cc srpc.Client) SRPCEchoerClient

type SRPCEchoerHandler 

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

func (SRPCEchoerHandler) GetMethodIDs 

func (SRPCEchoerHandler) GetMethodIDs() []string

func (SRPCEchoerHandler) GetServiceID 

func (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

type SRPCEchoerServer 

type SRPCEchoerServer interface {
	Echo(context.Context, *EchoMsg) (*EchoMsg, error)
	EchoServerStream(*EchoMsg, SRPCEchoer_EchoServerStreamStream) error
	EchoClientStream(SRPCEchoer_EchoClientStreamStream) error
	EchoBidiStream(SRPCEchoer_EchoBidiStreamStream) 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) error

func (*SRPCEchoerUnimplementedServer) EchoServerStream 

func (s *SRPCEchoerUnimplementedServer) EchoServerStream(*EchoMsg, SRPCEchoer_EchoServerStreamStream) 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
	Recv() (*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
	SendAndClose(*EchoMsg) error
	Recv() (*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
}

type SRPCEchoer_EchoStream 

type SRPCEchoer_EchoStream interface {
	srpc.Stream
	SendAndClose(*EchoMsg) 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.