composite

Documentation

Overview

Package composite implements support for runtimes composed of multiple components, like having both on-chain and off-chain logic.

Index

• func NewProvisioner(kinds map[component.TEEKind]host.Provisioner) host.Provisioner
• type Host
  • func NewHost(id common.Namespace) *Host
  • func (h *Host) Abort(ctx context.Context, force bool) error
  • func (h *Host) AddVersion(id component.ID, version version.Version, rt host.Runtime) error
  • func (h *Host) Call(ctx context.Context, body *protocol.Body) (*protocol.Body, error)
  • func (h *Host) Component(id component.ID) (*multi.Aggregate, bool)
  • func (h *Host) Components() map[component.ID]*multi.Aggregate
  • func (h *Host) GetActiveVersion() (*version.Version, error)
  • func (h *Host) GetCapabilityTEE() (*node.CapabilityTEE, error)
  • func (h *Host) GetInfo(ctx context.Context) (*protocol.RuntimeInfoResponse, error)
  • func (h *Host) HasVersion(id component.ID, version version.Version) bool
  • func (h *Host) ID() common.Namespace
  • func (h *Host) Start()
  • func (h *Host) Stop()
  • func (h *Host) UpdateCapabilityTEE()
  • func (h *Host) WatchEvents() (<-chan *host.Event, pubsub.ClosableSubscription)

Functions

func NewProvisioner

func NewProvisioner(kinds map[component.TEEKind]host.Provisioner) host.Provisioner

NewProvisioner returns a new composite provisioner that dispatches to the actual provisioner based on the component kind.

Types

type Host

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

func NewHost

func NewHost(id common.Namespace) *Host

NewHost creates a new composite runtime host that consists of one aggregated RONL component runtime host and zero or more aggregated ROFL component runtime hosts.

func (*Host) Abort

func (h *Host) Abort(ctx context.Context, force bool) error

Abort implements host.Runtime.

func (*Host) AddVersion

func (h *Host) AddVersion(id component.ID, version version.Version, rt host.Runtime) error

AddVersion adds a new version of the runtime component.

func (*Host) Call

func (h *Host) Call(ctx context.Context, body *protocol.Body) (*protocol.Body, error)

Call implements host.Runtime.

func (*Host) Component

func (h *Host) Component(id component.ID) (*multi.Aggregate, bool)

Component implements host.CompositeRuntime.

func (*Host) Components

func (h *Host) Components() map[component.ID]*multi.Aggregate

Components returns all runtime component hosts.

func (*Host) GetActiveVersion

func (h *Host) GetActiveVersion() (*version.Version, error)

GetActiveVersion implements host.Runtime.

func (*Host) GetCapabilityTEE

func (h *Host) GetCapabilityTEE() (*node.CapabilityTEE, error)

GetCapabilityTEE implements host.Runtime.

func (*Host) GetInfo

func (h *Host) GetInfo(ctx context.Context) (*protocol.RuntimeInfoResponse, error)

GetInfo implements host.Runtime.

func (*Host) HasVersion

func (h *Host) HasVersion(id component.ID, version version.Version) bool

HasVersion checks if the runtime component host exists for the given version.

func (*Host) ID

func (h *Host) ID() common.Namespace

ID implements host.Runtime.

func (*Host) Start

func (h *Host) Start()

Start implements host.Runtime.

func (*Host) Stop

func (h *Host) Stop()

Stop implements host.Runtime.

func (*Host) UpdateCapabilityTEE

func (h *Host) UpdateCapabilityTEE()

UpdateCapabilityTEE implements host.Runtime.

func (*Host) WatchEvents

func (h *Host) WatchEvents() (<-chan *host.Event, pubsub.ClosableSubscription)

WatchEvents implements host.Runtime.