google_protobuf_imports

Documentation

Index

• Variables
• type SvcClient
  • func NewSvcClient(clientID string, bus psrpc.MessageBus, opts ...psrpc.ClientOption) (SvcClient, error)
• type SvcServer
  • func NewSvcServer(serverID string, svc SvcServerImpl, bus psrpc.MessageBus, ...) (SvcServer, error)
• type SvcServerImpl

Variables

var File_service_proto protoreflect.FileDescriptor

Types

type SvcClient

type SvcClient interface {
	Send(context.Context, *google_protobuf1.StringValue, ...psrpc.RequestOption) (*google_protobuf.Empty, error)
}

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.

type SvcServerImpl

type SvcServerImpl interface {
	Send(context.Context, *google_protobuf1.StringValue) (*google_protobuf.Empty, error)
}