rpc

Documentation

Index

• func NewClient(ctx *context.T, opts ...rpc.ClientOpt) rpc.Client
• func RequestID(ctx *context.T) uuid.UUID
• func WithNewDispatchingServer(ctx *context.T, name string, dispatcher rpc.Dispatcher, ...) (*context.T, rpc.Server, error)
• func WithNewServer(ctx *context.T, name string, object interface{}, ...) (*context.T, rpc.Server, error)
• func WithRequestID(ctx *context.T, requestID uuid.UUID) *context.T
• type IdleConnectionExpiry
  • func (IdleConnectionExpiry) RPCClientOpt()
  • func (IdleConnectionExpiry) RPCServerOpt()
• type PreferredProtocols
  • func (PreferredProtocols) RPCClientOpt()
• type PreferredServerResolveProtocols
  • func (PreferredServerResolveProtocols) RPCServerOpt()
• type ReservedNameDispatcher
  • func (ReservedNameDispatcher) RPCServerOpt()

Functions

func NewClient

func NewClient(ctx *context.T, opts ...rpc.ClientOpt) rpc.Client

func RequestID

func RequestID(ctx *context.T) uuid.UUID

func WithNewDispatchingServer

func WithNewDispatchingServer(ctx *context.T,
	name string, dispatcher rpc.Dispatcher,
	settingsPublisher *pubsub.Publisher,
	opts ...rpc.ServerOpt) (*context.T, rpc.Server, error)

func WithNewServer

func WithNewServer(ctx *context.T,
	name string, object interface{}, authorizer security.Authorizer,
	settingsPublisher *pubsub.Publisher,
	opts ...rpc.ServerOpt) (*context.T, rpc.Server, error)

func WithRequestID

func WithRequestID(ctx *context.T, requestID uuid.UUID) *context.T

Types

type IdleConnectionExpiry

type IdleConnectionExpiry time.Duration

IdleConnectionExpiry is the amount of the time after which the connection cache will close idle connections.

func (IdleConnectionExpiry) RPCClientOpt

func (IdleConnectionExpiry) RPCClientOpt()

func (IdleConnectionExpiry) RPCServerOpt

func (IdleConnectionExpiry) RPCServerOpt()

type PreferredProtocols

type PreferredProtocols []string

PreferredProtocols instructs the Runtime implementation to select endpoints with the specified protocols when a Client makes a call and to order them in the specified order.

func (PreferredProtocols) RPCClientOpt

func (PreferredProtocols) RPCClientOpt()

type PreferredServerResolveProtocols

type PreferredServerResolveProtocols []string

This option is used to sort and filter the endpoints when resolving the proxy name from a mounttable.

func (PreferredServerResolveProtocols) RPCServerOpt

func (PreferredServerResolveProtocols) RPCServerOpt()

type ReservedNameDispatcher

type ReservedNameDispatcher struct {
	Dispatcher rpc.Dispatcher
}

ReservedNameDispatcher specifies the dispatcher that controls access to framework managed portion of the namespace.

func (ReservedNameDispatcher) RPCServerOpt

func (ReservedNameDispatcher) RPCServerOpt()