orchestrator

package
v0.0.0-...-c009a92 Latest Latest
Warning

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

Go to latest
Published: May 5, 2024 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type GRPCClient

type GRPCClient struct {
	Sandbox orchestrator.SandboxClient
	// contains filtered or unexported fields
}

func NewClient

func NewClient() (*GRPCClient, error)

func (*GRPCClient) Close

func (a *GRPCClient) Close() error

type Orchestrator

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

func New

func New() (*Orchestrator, error)

func (*Orchestrator) Close

func (o *Orchestrator) Close() error

func (*Orchestrator) CreateSandbox

func (o *Orchestrator) CreateSandbox(
	t trace.Tracer,
	ctx context.Context,
	sandboxID,
	templateID,
	alias,
	teamID,
	buildID string,
	maxInstanceLengthHours int64,
	metadata map[string]string,
	kernelVersion,
	firecrackerVersion string,
) (*api.Sandbox, error)

func (*Orchestrator) DeleteInstance

func (o *Orchestrator) DeleteInstance(ctx context.Context, sandboxID string) error

func (*Orchestrator) GetInstances

func (o *Orchestrator) GetInstances(ctx context.Context) ([]*instance.InstanceInfo, error)

func (*Orchestrator) KeepInSync

func (o *Orchestrator) KeepInSync(ctx context.Context, instanceCache *instance.InstanceCache)

KeepInSync the cache with the actual instances in Orchestrator to handle instances that died.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL