multi

Documentation

Overview

Package multi implements support for a runtime host aggregator that handles multiplexing multiple instances of other runtime hosts, to enable seamless transitions between versions.

Index

• Variables
• func New(id common.Namespace, rts map[version.Version]host.Runtime) (host.Runtime, error)
• type Aggregate
  • func (agg *Aggregate) Abort(ctx context.Context, force bool) error
  • func (agg *Aggregate) Call(ctx context.Context, body *protocol.Body) (*protocol.Body, error)
  • func (agg *Aggregate) Component(id component.ID) (host.Runtime, bool)
  • func (agg *Aggregate) GetActiveVersion() (*version.Version, error)
  • func (agg *Aggregate) GetCapabilityTEE() (*node.CapabilityTEE, error)
  • func (agg *Aggregate) GetInfo(ctx context.Context) (*protocol.RuntimeInfoResponse, error)
  • func (agg *Aggregate) GetVersion(version version.Version) (host.Runtime, error)
  • func (agg *Aggregate) ID() common.Namespace
  • func (agg *Aggregate) SetVersion(active version.Version, next *version.Version) error
  • func (agg *Aggregate) Start()
  • func (agg *Aggregate) Stop()
  • func (agg *Aggregate) UpdateCapabilityTEE()
  • func (agg *Aggregate) WatchEvents() (<-chan *host.Event, pubsub.ClosableSubscription)

Variables

var (
	// ErrNoActiveVersion is the error returned if there is no active version.
	ErrNoActiveVersion = errors.New("runtime/host/multi: no active version")

	// ErrNoSuchVersion is the error returned if the requested version is unknown.
	ErrNoSuchVersion = errors.New("runtime/host/multi: no such version")
)

Functions

func New

func New(
	id common.Namespace,
	rts map[version.Version]host.Runtime,
) (host.Runtime, error)

New returns a new aggregated runtime. The runtimes provided must be freshly provisioned (ie: Start() must not have been called).

Types

type Aggregate

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

Aggregate is an aggregated runtime consisting of multiple instances of the same runtime (by ID), all with different versions.

func (*Aggregate) Abort

func (agg *Aggregate) Abort(ctx context.Context, force bool) error

Abort implements host.Runtime.

func (*Aggregate) Call

func (agg *Aggregate) Call(ctx context.Context, body *protocol.Body) (*protocol.Body, error)

Call implements host.Runtime.

func (*Aggregate) Component

func (agg *Aggregate) Component(id component.ID) (host.Runtime, bool)

Component implements host.CompositeRuntime.

func (*Aggregate) GetActiveVersion

func (agg *Aggregate) GetActiveVersion() (*version.Version, error)

GetActiveVersion implements host.Runtime.

func (*Aggregate) GetCapabilityTEE

func (agg *Aggregate) GetCapabilityTEE() (*node.CapabilityTEE, error)

GetCapabilityTEE implements host.Runtime.

func (*Aggregate) GetInfo

func (agg *Aggregate) GetInfo(ctx context.Context) (*protocol.RuntimeInfoResponse, error)

GetInfo implements host.Runtime.

func (*Aggregate) GetVersion

func (agg *Aggregate) GetVersion(version version.Version) (host.Runtime, error)

GetVersion retrieves the runtime host for the specified version.

func (*Aggregate) ID

func (agg *Aggregate) ID() common.Namespace

ID implements host.Runtime.

func (*Aggregate) SetVersion

func (agg *Aggregate) SetVersion(active version.Version, next *version.Version) error

SetVersion sets the active and next runtime versions. This routine will:

• Do nothing if the active version is already the requested version.
• Unconditionally tear down the currently active version (via Stop()).
• Start the newly active version if it exists.
• Do nothing if the next version is already the requested version.
• Start the next version if it exists.

func (*Aggregate) Start

func (agg *Aggregate) Start()

Start implements host.Runtime.

func (*Aggregate) Stop

func (agg *Aggregate) Stop()

Stop implements host.Runtime.

func (*Aggregate) UpdateCapabilityTEE

func (agg *Aggregate) UpdateCapabilityTEE()

UpdateCapabilityTEE implements host.Runtime.

func (*Aggregate) WatchEvents

func (agg *Aggregate) WatchEvents() (<-chan *host.Event, pubsub.ClosableSubscription)

WatchEvents implements host.Runtime.