no_package_name_importer

Documentation

Index

• Variables
• type Svc2Client
  • func NewSvc2Client(clientID string, bus psrpc.MessageBus, opts ...psrpc.ClientOption) (Svc2Client, error)
• type Svc2Server
  • func NewSvc2Server(serverID string, svc Svc2ServerImpl, bus psrpc.MessageBus, ...) (Svc2Server, error)
• type Svc2ServerImpl

Variables

var File_no_package_name_importer_no_package_name_importer_proto protoreflect.FileDescriptor

Types

type Svc2Client

type Svc2Client interface {
	Method(context.Context, *no_package_name.Msg, ...psrpc.RequestOption) (*no_package_name.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 {
	Method(context.Context, *no_package_name.Msg) (*no_package_name.Msg, error)
}