Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var File_no_package_name_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
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
type SvcClient ¶
func NewSvcClient ¶
func NewSvcClient(clientID string, bus psrpc.MessageBus, opts ...psrpc.ClientOption) (SvcClient, error)
NewSvcClient creates a psrpc client that implements the SvcClient interface.
type SvcServer ¶
type SvcServer interface {
// Close and wait for pending RPCs to complete
Shutdown()
// Close immediately, without waiting for pending RPCs
Kill()
}
func NewSvcServer ¶
func NewSvcServer(serverID string, svc SvcServerImpl, bus psrpc.MessageBus, opts ...psrpc.ServerOption) (SvcServer, error)
NewSvcServer builds a RPCServer that will route requests to the corresponding method in the provided svc implementation.
Click to show internal directories.
Click to hide internal directories.