Version: v0.0.0-...-ba1c585 Latest Latest

This package is not in the latest version of its module.

Go to latest
Published: Jun 29, 2017 License: BSD-3-Clause Imports: 41 Imported by: 0




This section is empty.


This section is empty.


This section is empty.


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,
	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) 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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL