orchestrator

Documentation

Index

• type GRPCClient
  • func NewClient() (*GRPCClient, error)
  • func (a *GRPCClient) Close() error
• type Orchestrator
  • func New() (*Orchestrator, error)
  • func (o *Orchestrator) Close() error
  • func (o *Orchestrator) CreateSandbox(t trace.Tracer, ctx context.Context, ...) (*api.Sandbox, error)
  • func (o *Orchestrator) DeleteInstance(ctx context.Context, tracer trace.Tracer, sandboxID string) error
  • func (o *Orchestrator) GetInstances(ctx context.Context, tracer trace.Tracer) ([]*instance.InstanceInfo, error)
  • func (o *Orchestrator) KeepInSync(ctx context.Context, tracer trace.Tracer, ...)
  • func (o *Orchestrator) UpdateSandbox(t trace.Tracer, ctx context.Context, sandboxID string, endTime time.Time) error

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 string,
	build *models.EnvBuild,
	maxInstanceLengthHours int64,
	metadata,
	envVars map[string]string,
	kernelVersion,
	firecrackerVersion,
	envdVersion string,
	startTime time.Time,
	endTime time.Time,
) (*api.Sandbox, error)

func (*Orchestrator) DeleteInstance

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

func (*Orchestrator) GetInstances

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

func (*Orchestrator) KeepInSync

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

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

func (*Orchestrator) UpdateSandbox

func (o *Orchestrator) UpdateSandbox(
	t trace.Tracer,
	ctx context.Context,
	sandboxID string,
	endTime time.Time,
) error