scale

package

Go to main page

Versions in this module

v0

v0.1.3

Aug 31, 2026

v0.1.2

Aug 31, 2026

Changes in this version

+ const DeadlineAnnotation

type Assignment

+ Deadline time.Time

v0.1.1

Aug 12, 2026

Changes in this version

+ const NetEgress

v0.1.0

Jul 27, 2026

Changes in this version

+ const BoundConditionType

+ const ClaimIDAnnotation

+ const ClaimLabel

+ const NetDefault

+ const NodeLabel

+ const PhaseLabel

+ const RequestUserSelectorKey

+ const SelectorNetKey

+ const SelectorSizeKey

+ const SelectorTemplateKey

+ const SizeClassLarge

+ const SizeClassMedium

+ const SizeClassSmall

+ var ErrNoNodeCapacity = errors.New("scale: node has no warm capacity; fall back to L1 claim path")

+ var ErrNoWarmCapacity = errors.New("scale: no node has warm capacity for the requested pool")

+ var NodeInventoryGVK = extv1beta1.GroupVersion.WithKind("NodeInventory")

+ func AddressIPs(addr string) []string

+ func IsFallback(err error) bool

+ func IsNoWarmCapacity(err error) bool

+ func NewGateway(cfg GatewayConfig) *nodeClaimGateway

+ func NewScatterGatherStore(src InventorySource, opts ...StoreOption) *scatterGatherStore

+ func SizeClassForContainers(containers []corev1.Container) string

+ type Assignment struct

+ Address string

+ Node string

+ SandboxName string

+ Token string

+ type Authorizer interface

+ Authorize func(ctx context.Context, req ClaimRequest) error

+ type ClaimGateway interface

+ Claim func(ctx context.Context, req ClaimRequest) (Assignment, error)

+ Release func(ctx context.Context, assignment Assignment) error

+ type ClaimRecorder interface

+ RecordBound func(ctx context.Context, claimNS, claimName string, a Assignment) error

+ func NewClaimRecorder(c client.Client) ClaimRecorder

+ type ClaimRequest struct

+ ClaimName string

+ Namespace string

+ Selector map[string]string

+ WarmPool string

+ type ClientInventorySource struct

+ func NewClientInventorySource(reader client.Reader) *ClientInventorySource

+ func (s *ClientInventorySource) ListNodes(ctx context.Context) ([]string, error)

+ func (s *ClientInventorySource) NodeInventory(ctx context.Context, node string) (*NodeInventory, error)

+ type Delivery struct

+ Address string

+ ClaimNS string

+ ClaimName string

+ Node string

+ SandboxName string

+ type GatewayConfig struct

+ Authorizer Authorizer

+ BaseContext context.Context

+ Client SandboxdClient

+ DefaultNet string

+ DefaultSize string

+ DefaultTemplate string

+ Logger logr.Logger

+ Node string

+ RecordTimeout time.Duration

+ Recorder ClaimRecorder

+ TTLSeconds int

+ type InventoryApplier interface

+ Apply func(ctx context.Context, inv *NodeInventory) error

+ func NewSSAInventoryApplier(c client.Client, fieldOwner string) InventoryApplier

+ type InventoryEntry = extv1beta1.InventoryEntry

+ type InventorySource interface

+ ListNodes func(ctx context.Context) ([]string, error)

+ NodeInventory func(ctx context.Context, node string) (*NodeInventory, error)

+ type ListOptions struct

+ FieldSelector string

+ LabelSelector string

+ Namespace string

+ type NodeInventory = extv1beta1.NodeInventory

+ type NodeInventoryPublisher struct

+ func NewNodeInventoryPublisher(node string, live NodeLiveSource, applier InventoryApplier, log logr.Logger) *NodeInventoryPublisher

+ func (p *NodeInventoryPublisher) Publish(ctx context.Context) (int, error)

+ func (p *NodeInventoryPublisher) PublishPeriodically(ctx context.Context, interval time.Duration)

+ type NodeInventorySource interface

+ LiveDeliveries func(ctx context.Context) ([]Delivery, error)

+ type NodeLiveSource interface

+ LiveSandboxes func(ctx context.Context) ([]InventoryEntry, error)

+ type OrphanReconciler struct

+ func NewOrphanReconciler(node string, inv NodeInventorySource, reader client.Client, ...) *OrphanReconciler

+ func (o *OrphanReconciler) Reconcile(ctx context.Context) (int, error)

+ type PoolCapacity = extv1beta1.PoolCapacity

+ type PoolKey struct

+ Net string

+ Size string

+ Template string

+ func PoolKeyFor(containers []corev1.Container, net string) PoolKey

+ type QuotaChecker interface

+ Admit func(ctx context.Context, namespace string) error

+ type ReviewAuthorizer struct

+ Group string

+ Quota QuotaChecker

+ Resource string

+ Reviewer SubjectAccessReviewer

+ Verb string

+ func (a *ReviewAuthorizer) Authorize(ctx context.Context, req ClaimRequest) error

+ type SandboxLifecycle interface

+ ClaimSnapshot func(ctx context.Context, node, snapshotID string, ttlSeconds int) (Assignment, error)

+ DeleteSnapshot func(ctx context.Context, node, snapshotID string) error

+ Fork func(ctx context.Context, node, id string, count int, ttlSeconds int) ([]Assignment, error)

+ Pause func(ctx context.Context, node, id string) error

+ Promote func(ctx context.Context, node, id, template string) (PoolKey, error)

+ Resume func(ctx context.Context, node, id string) error

+ Snapshot func(ctx context.Context, node, id, name string) (Snapshot, error)

+ Snapshots func(ctx context.Context, node string) ([]Snapshot, error)

+ Stats func(ctx context.Context, node, id string) (SandboxStats, error)

+ type SandboxStats struct

+ CPUCount int

+ MeasuredAt time.Time

+ MemTotalBytes int64

+ MemUsedBytes int64

+ MemUsedMeasured bool

+ Paused bool

+ type SandboxStore interface

+ Claim func(ctx context.Context, namespace, name string, pool PoolKey) (Assignment, error)

+ Get func(ctx context.Context, namespace, name string) (*sandboxv1beta1.Sandbox, error)

+ List func(ctx context.Context, opts ListOptions) (*sandboxv1beta1.SandboxList, error)

+ Release func(ctx context.Context, node, id string) error

+ Watch func(ctx context.Context, opts ListOptions) (watch.Interface, error)

+ type SandboxdClient interface

+ Checkpoint func(ctx context.Context, id string, spec sandboxd.CheckpointSpec) (sandboxd.Checkpoint, error)

+ Checkpoints func(ctx context.Context) ([]sandboxd.Checkpoint, error)

+ Claim func(ctx context.Context, spec sandboxd.ClaimSpec) (sandboxd.ClaimResult, error)

+ ClaimCheckpoint func(ctx context.Context, checkpointID string, spec sandboxd.CheckpointClaimSpec) (sandboxd.ClaimResult, error)

+ DeleteCheckpoint func(ctx context.Context, checkpointID string) error

+ Fork func(ctx context.Context, id string, spec sandboxd.ForkSpec) (sandboxd.ForkResult, error)

+ Hibernate func(ctx context.Context, id string) error

+ Promote func(ctx context.Context, id string, spec sandboxd.PromoteSpec) (sandboxd.PoolKey, error)

+ Release func(ctx context.Context, id, token string) error

+ Stats func(ctx context.Context, id string) (sandboxd.SandboxStats, error)

+ Wake func(ctx context.Context, id string) error

+ type SandboxdClientFactory func(addr, token string) SandboxdClient

+ func NewSandboxdClientFactory() SandboxdClientFactory

+ type Snapshot struct

+ CreatedAt time.Time

+ ID string

+ Name string

+ Node string

+ Pool PoolKey

+ SandboxID string

+ type StaticInventorySource struct

+ func NewStaticInventorySource() *StaticInventorySource

+ func (s *StaticInventorySource) Apply(_ context.Context, inv *NodeInventory) error

+ func (s *StaticInventorySource) ApplyCount() int

+ func (s *StaticInventorySource) ListNodes(_ context.Context) ([]string, error)

+ func (s *StaticInventorySource) NodeInventory(_ context.Context, node string) (*NodeInventory, error)

+ func (s *StaticInventorySource) ObjectCount() int

+ func (s *StaticInventorySource) Partition(node string)

+ func (s *StaticInventorySource) Put(inv *NodeInventory)

+ func (s *StaticInventorySource) Remove(node string)

+ type StoreOption func(*scatterGatherStore)

+ func WithClaimRouting(token string, factory SandboxdClientFactory) StoreOption

+ func WithConcurrency(n int) StoreOption

+ func WithLogger(log logr.Logger) StoreOption

+ func WithWatchPollInterval(d time.Duration) StoreOption

+ type SubjectAccessReviewer interface

+ Create func(ctx context.Context, sar *authzv1.SubjectAccessReview, ...) (*authzv1.SubjectAccessReview, error)

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