v0.0.0-...-ff5f600 Latest Latest

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

Go to latest
Published: Apr 30, 2016 License: BSD-3-Clause Imports: 21 Imported by: 0



Package fake implements a fake RuntimeFactory, useful in tests for mocking out certain components.



This section is empty.


This section is empty.


func Init

func Init(ctx *context.T) (v23.Runtime, *context.T, v23.Shutdown, error)

func InjectRuntime

func InjectRuntime(runtime v23.Runtime, ctx *context.T, shutdown v23.Shutdown)

InjectRuntime allows packages to inject whichever runtime, ctx, and shutdown. This allows a package that needs different runtimes in tests to swap them as needed. The injected runtime will be valid until the shutdown returned from v23.Init is called.

func SetClientFactory

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

SetClientFactory can be used to inject a mock Client implementation into the context. When v23.WithNewClient is called passed function will be invoked.

func SetFlowManagerFactory

func SetFlowManagerFactory(ctx *context.T, factory func(ctx *context.T, channelTimeout time.Duration) flow.Manager) *context.T

SetFlowManagerFactory can be used to inject a mock FlowManager implementation into the context. When v23.NewFlowManager is called passed function will be invoked.

func SetServerFactory

func SetServerFactory(ctx *context.T, factory func(*context.T, string, interface{}, security.Authorizer, ...rpc.ServerOpt) (*context.T, rpc.Server)) *context.T

SetServerFactory can be used to inject a mock Server implementation into the context. When v23.WithNewServer is called the passed function will be invoked.


type Runtime

type Runtime struct {
	// contains filtered or unexported fields

func (*Runtime) GetAppCycle

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

func (*Runtime) GetBackgroundContext

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

func (*Runtime) GetClient

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

func (*Runtime) GetListenSpec

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

func (*Runtime) GetNamespace

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

func (*Runtime) GetPrincipal

func (r *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 (r *Runtime) NewDiscovery(ctx *context.T) (discovery.T, error)

func (*Runtime) NewEndpoint

func (r *Runtime) NewEndpoint(ep string) (naming.Endpoint, error)

func (*Runtime) NewFlowManager

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

func (*Runtime) WithBackgroundContext

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

func (*Runtime) WithListenSpec

func (r *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