Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var File_importer_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type Svc2Client ¶
type Svc2Client interface {
Send(context.Context, *psrpc_internal_test_importable.Msg, ...psrpc.RequestOption) (*psrpc_internal_test_importable.Msg, error)
}
func NewSvc2Client ¶
func NewSvc2Client(clientID string, bus psrpc.MessageBus, opts ...psrpc.ClientOption) (Svc2Client, error)
NewSvc2Client creates a psrpc client that implements the Svc2Client interface.
type Svc2Server ¶
type Svc2Server interface {
// Close and wait for pending RPCs to complete
Shutdown()
// Close immediately, without waiting for pending RPCs
Kill()
}
func NewSvc2Server ¶
func NewSvc2Server(serverID string, svc Svc2ServerImpl, bus psrpc.MessageBus, opts ...psrpc.ServerOption) (Svc2Server, error)
NewSvc2Server builds a RPCServer that will route requests to the corresponding method in the provided svc implementation.
type Svc2ServerImpl ¶
type Svc2ServerImpl interface {
Send(context.Context, *psrpc_internal_test_importable.Msg) (*psrpc_internal_test_importable.Msg, error)
}
Source Files
Click to show internal directories.
Click to hide internal directories.