runtime

package

v0.0.0-...-12a582f Latest Latest Go to latest Published: May 17, 2024 License: MPL-2.0 Imports: 6 Imported by: 0

Details

View Source

const (
	DefaultExec = 10 * time.Second
)

This section is empty.

This section is empty.

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

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(ctx context.Context) *Runtime

New creates a new Runtime with defaults

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

NewWithConfiguration creates a new Runtime with optional configuration settings

func (r *Runtime) Await() chan bool

func (r *Runtime) Run()

Run begins the runtime mechanism

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