no_package_name

Documentation

Index

• Variables
• type Msg
  • func (*Msg) Descriptor() ([]byte, []int)
  • func (*Msg) ProtoMessage()
  • func (x *Msg) ProtoReflect() protoreflect.Message
  • func (x *Msg) Reset()
  • func (x *Msg) String() string
• 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_no_package_name_proto protoreflect.FileDescriptor

Types

type Msg

type Msg struct {
	// contains filtered or unexported fields
}

func (*Msg) Descriptor

func (*Msg) Descriptor() ([]byte, []int)

Deprecated: Use Msg.ProtoReflect.Descriptor instead.

func (*Msg) ProtoMessage

func (*Msg) ProtoMessage()

func (*Msg) ProtoReflect

func (x *Msg) ProtoReflect() protoreflect.Message

func (*Msg) Reset

func (x *Msg) Reset()

func (*Msg) String

func (x *Msg) String() string

type SvcClient

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