lifecycle

type Action string

type ActiveSessionCanceller interface {
	CancelSandboxSessions(context.Context, string, int64, string, time.Time) (int64, error)
}

type AssignmentScheduler interface {
	Schedule(context.Context, scheduler.ScheduleRequest) (scheduler.DurableAssignment, bool, error)
}

type BatchReconcileStore interface {
	ClaimLifecycleBatch(ctx context.Context, workerID string, now time.Time, claimDuration time.Duration, batchSize int, wakeTrigger ports.LifecycleWakeTrigger) ([]ports.LifecycleReconcileClaim, error)
}

type Decision struct {
	Action            Action
	TerminationReason string
}

type EffectBrokerConfig struct {
	AssignmentClaimDuration time.Duration
	AssignmentDeadline      time.Duration
	HeartbeatTimeout        time.Duration
	RetryLimit              int64
	SerializationRetryLimit int
	AssetCatalog            SignedAssetCatalog
	SessionCanceller        ActiveSessionCanceller
	NewID                   func(string) string
	NewFencingToken         func() ([]byte, error)
	Now                     func() time.Time
}

type EffectExecutor interface {
	ExecuteLifecycleEffect(
		ctx context.Context,
		claim ports.LifecycleReconcileClaim,
		decision Decision,
		now time.Time,
		nextReconcileAt time.Time,
	) error
}

type FileAssetCatalog = assetcatalog.FileAssetCatalog

type GarbageCatalog interface {
	ListGarbageObjectsDue(ctx context.Context, now time.Time, grace time.Duration, limit int) ([]ports.GarbageObject, error)
	CompleteGarbageObject(ctx context.Context, object ports.GarbageObject, now time.Time) error
}

type GarbageCollector struct {
	Catalog   GarbageCatalog
	Objects   objectstore.Store
	Grace     time.Duration
	BatchSize int
}

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

type ReconcileStore interface {
	ClaimLifecycle(ctx context.Context, workerID string, now time.Time, claimDuration time.Duration, wakeTrigger ports.LifecycleWakeTrigger) (ports.LifecycleReconcileClaim, bool, error)
	ApplyLifecycleAction(ctx context.Context, claim ports.LifecycleReconcileClaim, action, terminationReason string, now, nextReconcileAt time.Time) error
}

type Reconciler struct {
	Store         ReconcileStore
	Effects       EffectExecutor
	WorkerID      string
	ClaimDuration time.Duration
	PollInterval  time.Duration
	BatchSize     int
}

type SignedAsset = assetcatalog.SignedAsset

type SignedAssetCatalog = assetcatalog.SignedAssetCatalog

type SnapshotRetentionStore interface {
	QueueExpiredSnapshotDelete(
		context.Context,
		ports.SnapshotRetentionInput,
	) (bool, error)
}

type SnapshotRetentionWorker struct {
	Store           SnapshotRetentionStore
	PollInterval    time.Duration
	NewID           func(string) string
	NewFencingToken func() ([]byte, error)
}

type View struct {
	Observed                  string
	Desired                   string
	StopEffectState           string
	GuestLiveness             string
	InstanceTerminationReason string
	IntentTerminationReason   string
	HasInstance               bool
	ActiveSessions            int64
	ReadyAt                   time.Time
	LastUsefulActivityAt      time.Time
	DrainStartedAt            time.Time
	DrainGrace                time.Duration
	IdleTimeout               time.Duration
	MaximumDuration           time.Duration
}