Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var File_service_method_same_name_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type EchoClient ¶
func NewEchoClient ¶
func NewEchoClient(clientID string, bus psrpc.MessageBus, opts ...psrpc.ClientOption) (EchoClient, error)
NewEchoClient creates a psrpc client that implements the EchoClient interface.
type EchoServer ¶
type EchoServer interface {
// Close and wait for pending RPCs to complete
Shutdown()
// Close immediately, without waiting for pending RPCs
Kill()
}
func NewEchoServer ¶
func NewEchoServer(serverID string, svc EchoServerImpl, bus psrpc.MessageBus, opts ...psrpc.ServerOption) (EchoServer, error)
NewEchoServer builds a RPCServer that will route requests to the corresponding method in the provided svc implementation.
type Msg ¶
type Msg struct {
// contains filtered or unexported fields
}
func (*Msg) Descriptor
deprecated
func (*Msg) ProtoMessage ¶
func (*Msg) ProtoMessage()
func (*Msg) ProtoReflect ¶
func (x *Msg) ProtoReflect() protoreflect.Message
Click to show internal directories.
Click to hide internal directories.