runtime

Documentation

Index

• Constants
• type Config
• type Runtime
  • func New(ctx context.Context) *Runtime
  • func NewWithConfiguration(ctx context.Context, cfg Config) *Runtime
  • func (r *Runtime) Await() chan bool
  • func (r *Runtime) Run()
  • func (r *Runtime) Start()

Constants

const (
	DefaultExec = 10 * time.Second
)

Types

type Config

type Config struct {
	Interval time.Duration
	ErrChan  <-chan error
}

type Runtime

type Runtime struct {
	Orchestrator orchestrator.Orchestrator

	Dispatcher *dispatcher.Dispatcher
	// contains filtered or unexported fields
}

Runtime is the standlone control plane orchestration runtime for receiving and coordinating submitted experiment plans

func New

func New(ctx context.Context) *Runtime

New creates a new Runtime with defaults

func NewWithConfiguration

func NewWithConfiguration(ctx context.Context, cfg Config) *Runtime

NewWithConfiguration creates a new Runtime with optional configuration settings

func (*Runtime) Await

func (r *Runtime) Await() chan bool

func (*Runtime) Run

func (r *Runtime) Run()

Run begins the runtime mechanism

func (*Runtime) Start

func (r *Runtime) Start()

Start starts the runtime reconciliation process to fix state on submitted provision or management events

though it can be set up and called directly, it is managed by the runtime.Run command