importer_local

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.ClientOpt) (SvcClient, error)
• type SvcServer
  • func NewSvcServer(serverID string, svc SvcServerImpl, bus psrpc.MessageBus, ...) (SvcServer, error)
• type SvcServerImpl

Variables

var File_importer_local_msgdef_proto protoreflect.FileDescriptor

var File_importer_local_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.RequestOpt) (*Msg, error)
}

func NewSvcClient

func NewSvcClient(clientID string, bus psrpc.MessageBus, opts ...psrpc.ClientOpt) (SvcClient, error)

NewSvcClient creates a psrpc client that implements the SvcClient interface.

type SvcServer

type SvcServer interface {
}

func NewSvcServer

func NewSvcServer(serverID string, svc SvcServerImpl, bus psrpc.MessageBus, opts ...psrpc.ServerOpt) (SvcServer, error)

NewSvcServer builds a RPCServer that can be used to handle requests that are routed to the right method in the provided svc implementation.

type SvcServerImpl

type SvcServerImpl interface {
	Send(context.Context, *Msg) (*Msg, error)
}