activator

Documentation

Index

• Variables
• type AppActivator
  • func NewLocalActivator(ctx context.Context, log *slog.Logger, ...) AppActivator
• type Lease
  • func NewTestLease(sb *compute_v1alpha.Sandbox, size int, url string) *Lease
  • func (l *Lease) Pool() string
  • func (l *Lease) Sandbox() *compute_v1alpha.Sandbox
  • func (l *Lease) SandboxEntity() *entity.Entity
  • func (l *Lease) Version() *core_v1alpha.AppVersion
• type PoolCreator
• type SandboxInvalidation

Variables

var ErrPoolTimeout = fmt.Errorf("timeout waiting for sandbox from pool")

var ErrSandboxDiedEarly = fmt.Errorf("sandbox died while booting")

Types

type AppActivator

type AppActivator interface {
	AcquireLease(ctx context.Context, ver *core_v1alpha.AppVersion, service string) (*Lease, error)
	ReleaseLease(ctx context.Context, lease *Lease) error
	RenewLease(ctx context.Context, lease *Lease) (*Lease, error)

	// Invalidations returns a channel that receives notifications when
	// sandboxes become non-RUNNING. Consumers should invalidate any cached
	// leases referencing the invalidated sandbox.
	Invalidations() <-chan SandboxInvalidation

	// SetPoolCreator registers a callback for on-demand pool creation.
	// This is used by ephemeral deployments where the DeploymentLauncher
	// doesn't pre-create pools.
	SetPoolCreator(pc PoolCreator)
}

func NewLocalActivator

func NewLocalActivator(ctx context.Context, log *slog.Logger, eac *entityserver_v1alpha.EntityAccessClient) AppActivator

type Lease

type Lease struct {
	Size int
	URL  string
	// contains filtered or unexported fields
}

func NewTestLease

func NewTestLease(sb *compute_v1alpha.Sandbox, size int, url string) *Lease

NewTestLease creates a Lease with the given sandbox, size, and URL. This is only intended for use in tests outside the activator package.

func (*Lease) Pool

func (l *Lease) Pool() string

func (*Lease) Sandbox

func (l *Lease) Sandbox() *compute_v1alpha.Sandbox

func (*Lease) SandboxEntity

func (l *Lease) SandboxEntity() *entity.Entity

func (*Lease) Version

func (l *Lease) Version() *core_v1alpha.AppVersion

type PoolCreator

type PoolCreator interface {
	CreatePoolForVersion(ctx context.Context, ver *core_v1alpha.AppVersion, service string) (entity.Id, error)
}

PoolCreator creates sandbox pools on demand for versions that don't have one pre-created by the DeploymentLauncher (e.g., ephemeral versions).

type SandboxInvalidation

type SandboxInvalidation struct {
	SandboxID entity.Id
}

SandboxInvalidation is sent when a sandbox transitions away from RUNNING, signaling that any cached leases pointing to it should be invalidated.