rt

Documentation

Index

• type Runtime
  • func Init(ctx *context.T, appCycle v23.AppCycle, discoveryFactory idiscovery.Factory, ...) (*Runtime, *context.T, v23.Shutdown, error)
  • func (*Runtime) GetAppCycle(ctx *context.T) v23.AppCycle
  • func (*Runtime) GetBackgroundContext(ctx *context.T) *context.T
  • func (*Runtime) GetClient(ctx *context.T) rpc.Client
  • func (*Runtime) GetListenSpec(ctx *context.T) rpc.ListenSpec
  • func (*Runtime) GetNamespace(ctx *context.T) namespace.T
  • func (*Runtime) GetPermissionsSpec(ctx *context.T) access.PermissionsSpec
  • func (*Runtime) GetPrincipal(ctx *context.T) security.Principal
  • func (*Runtime) GetReservedNameDispatcher(ctx *context.T) rpc.Dispatcher
  • func (r *Runtime) Init(ctx *context.T) error
  • func (*Runtime) NewDiscovery(ctx *context.T) (discovery.T, error)
  • func (r *Runtime) NewFlowManager(ctx *context.T, channelTimeout time.Duration) (flow.Manager, error)
  • func (*Runtime) WithBackgroundContext(ctx *context.T) *context.T
  • func (*Runtime) WithListenSpec(ctx *context.T, ls rpc.ListenSpec) *context.T
  • func (r *Runtime) WithNewClient(ctx *context.T, opts ...rpc.ClientOpt) (*context.T, rpc.Client, error)
  • func (r *Runtime) WithNewDispatchingServer(ctx *context.T, name string, disp rpc.Dispatcher, opts ...rpc.ServerOpt) (*context.T, rpc.Server, error)
  • func (r *Runtime) WithNewNamespace(ctx *context.T, roots ...string) (*context.T, namespace.T, error)
  • func (r *Runtime) WithNewServer(ctx *context.T, name string, object interface{}, auth security.Authorizer, ...) (*context.T, rpc.Server, error)
  • func (r *Runtime) WithPrincipal(ctx *context.T, principal security.Principal) (*context.T, error)
  • func (*Runtime) WithReservedNameDispatcher(ctx *context.T, d rpc.Dispatcher) *context.T

Types

type Runtime

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

Runtime implements the v23.Runtime interface. Please see the interface definition for documentation of the individiual methods.

func Init

func Init(
	ctx *context.T,
	appCycle v23.AppCycle,
	discoveryFactory idiscovery.Factory,
	namespaceFactory inamespace.Factory,
	protocols []string,
	listenSpec *rpc.ListenSpec,
	settingsPublisher *pubsub.Publisher,
	flags flags.RuntimeFlags,
	reservedDispatcher rpc.Dispatcher,
	permissionsSpec access.PermissionsSpec,
	connIdleExpiry time.Duration) (*Runtime, *context.T, v23.Shutdown, error)

func (*Runtime) GetAppCycle

func (*Runtime) GetAppCycle(ctx *context.T) v23.AppCycle

func (*Runtime) GetBackgroundContext

func (*Runtime) GetBackgroundContext(ctx *context.T) *context.T

func (*Runtime) GetClient

func (*Runtime) GetClient(ctx *context.T) rpc.Client

func (*Runtime) GetListenSpec

func (*Runtime) GetListenSpec(ctx *context.T) rpc.ListenSpec

func (*Runtime) GetNamespace

func (*Runtime) GetNamespace(ctx *context.T) namespace.T

func (*Runtime) GetPermissionsSpec

func (*Runtime) GetPermissionsSpec(ctx *context.T) access.PermissionsSpec

func (*Runtime) GetPrincipal

func (*Runtime) GetPrincipal(ctx *context.T) security.Principal

func (*Runtime) GetReservedNameDispatcher

func (*Runtime) GetReservedNameDispatcher(ctx *context.T) rpc.Dispatcher

func (*Runtime) Init

func (r *Runtime) Init(ctx *context.T) error

func (*Runtime) NewDiscovery

func (*Runtime) NewDiscovery(ctx *context.T) (discovery.T, error)

func (*Runtime) NewFlowManager

func (r *Runtime) NewFlowManager(ctx *context.T, channelTimeout time.Duration) (flow.Manager, error)

func (*Runtime) WithBackgroundContext

func (*Runtime) WithBackgroundContext(ctx *context.T) *context.T

func (*Runtime) WithListenSpec

func (*Runtime) WithListenSpec(ctx *context.T, ls rpc.ListenSpec) *context.T

func (*Runtime) WithNewClient

func (r *Runtime) WithNewClient(ctx *context.T, opts ...rpc.ClientOpt) (*context.T, rpc.Client, error)

func (*Runtime) WithNewDispatchingServer

func (r *Runtime) WithNewDispatchingServer(ctx *context.T, name string, disp rpc.Dispatcher, opts ...rpc.ServerOpt) (*context.T, rpc.Server, error)

func (*Runtime) WithNewNamespace

func (r *Runtime) WithNewNamespace(ctx *context.T, roots ...string) (*context.T, namespace.T, error)

func (*Runtime) WithNewServer

func (r *Runtime) WithNewServer(ctx *context.T, name string, object interface{}, auth security.Authorizer, opts ...rpc.ServerOpt) (*context.T, rpc.Server, error)

func (*Runtime) WithPrincipal

func (r *Runtime) WithPrincipal(ctx *context.T, principal security.Principal) (*context.T, error)

func (*Runtime) WithReservedNameDispatcher

func (*Runtime) WithReservedNameDispatcher(ctx *context.T, d rpc.Dispatcher) *context.T