runner

package

Go to main page

Versions in this module

v0

v0.5.0

May 14, 2026

v0.4.0

May 11, 2026

Changes in this version

type Exec

+ func (r *Exec) ReconcileCell(cell intmodel.Cell) (intmodel.Cell, ReconcileOutcome, error)

type Options

+ KukeonGroupGID int

+ type ReconcileOutcome struct

+ Deleted bool

+ Updated bool

type Runner

+ ReconcileCell func(cell intmodel.Cell) (intmodel.Cell, ReconcileOutcome, error)

v0.3.0

Apr 30, 2026

Changes in this version

type Exec

+ func (r *Exec) DeleteImage(namespace, ref string) error

+ func (r *Exec) GetImage(namespace, ref string) (ctr.ImageInfo, error)

+ func (r *Exec) ListContainerdNamespaces() ([]string, error)

+ func (r *Exec) ListImages(namespace string) ([]ctr.ImageInfo, error)

+ func (r *Exec) LoadImage(namespace string, reader io.Reader) ([]string, error)

+ func (r *Exec) WaitCellRootTaskExit(ctx context.Context, cell intmodel.Cell) (<-chan containerd.ExitStatus, error)

type Runner

+ DeleteImage func(namespace, ref string) error

+ GetImage func(namespace, ref string) (ctr.ImageInfo, error)

+ ListContainerdNamespaces func() ([]string, error)

+ ListImages func(namespace string) ([]ctr.ImageInfo, error)

+ LoadImage func(namespace string, reader io.Reader) ([]string, error)

+ WaitCellRootTaskExit func(ctx context.Context, cell intmodel.Cell) (<-chan containerd.ExitStatus, error)

v0.2.4

Apr 26, 2026

v0.2.3

Apr 26, 2026

v0.2.2

Apr 25, 2026

v0.2.1

Apr 25, 2026

v0.2.0

Apr 25, 2026

Changes in this version

type Options

+ ForceRegenerateCNI bool

v0.1.0

Apr 19, 2026

Changes in this version

+ const ContainerIDMinimumParts

+ type Exec struct

+ func (r *Exec) BootstrapCNI(cfgDir, cacheDir, binDir string) (cni.BootstrapReport, error)

+ func (r *Exec) Close() error

+ func (r *Exec) CreateCell(cell intmodel.Cell) (intmodel.Cell, error)

+ func (r *Exec) CreateContainer(cell intmodel.Cell, container intmodel.ContainerSpec) (intmodel.Cell, error)

+ func (r *Exec) CreateRealm(realm intmodel.Realm) (intmodel.Realm, error)

+ func (r *Exec) CreateSpace(space intmodel.Space) (intmodel.Space, error)

+ func (r *Exec) CreateStack(stack intmodel.Stack) (intmodel.Stack, error)

+ func (r *Exec) DeleteCell(cell intmodel.Cell) error

+ func (r *Exec) DeleteContainer(cell intmodel.Cell, containerID string) error

+ func (r *Exec) DeleteRealm(realm intmodel.Realm) error

+ func (r *Exec) DeleteSpace(space intmodel.Space) error

+ func (r *Exec) DeleteStack(stack intmodel.Stack) error

+ func (r *Exec) EnsureCell(cell intmodel.Cell) (intmodel.Cell, error)

+ func (r *Exec) EnsureContainer(cell intmodel.Cell, container intmodel.ContainerSpec) (intmodel.Cell, error)

+ func (r *Exec) EnsureKukeonRootCgroup() (bool, bool, error)

+ func (r *Exec) EnsureRealm(realm intmodel.Realm) (intmodel.Realm, error)

+ func (r *Exec) EnsureSpace(space intmodel.Space) (intmodel.Space, error)

+ func (r *Exec) EnsureStack(stack intmodel.Stack) (intmodel.Stack, error)

+ func (r *Exec) ExistsCellRootContainer(cell intmodel.Cell) (bool, error)

+ func (r *Exec) ExistsCgroup(doc any) (bool, error)

+ func (r *Exec) ExistsContainer(containerdID string) (bool, error)

+ func (r *Exec) ExistsRealmContainerdNamespace(namespace string) (bool, error)

+ func (r *Exec) ExistsSpaceCNIConfig(space intmodel.Space) (bool, error)

+ func (r *Exec) ExtractContainersFromCells(cells []intmodel.Cell) []intmodel.ContainerSpec

+ func (r *Exec) GetCell(cell intmodel.Cell) (intmodel.Cell, error)

+ func (r *Exec) GetContainerState(cell intmodel.Cell, containerID string) (intmodel.ContainerState, error)

+ func (r *Exec) GetRealm(realm intmodel.Realm) (intmodel.Realm, error)

+ func (r *Exec) GetSpace(space intmodel.Space) (intmodel.Space, error)

+ func (r *Exec) GetStack(stack intmodel.Stack) (intmodel.Stack, error)

+ func (r *Exec) KillCell(cell intmodel.Cell) (intmodel.Cell, error)

+ func (r *Exec) KillContainer(cell intmodel.Cell, containerID string) error

+ func (r *Exec) ListCells(realmName, spaceName, stackName string) ([]intmodel.Cell, error)

+ func (r *Exec) ListContainers(realmName, spaceName, stackName, cellName string) ([]intmodel.ContainerSpec, error)

+ func (r *Exec) ListRealms() ([]intmodel.Realm, error)

+ func (r *Exec) ListSpaces(realmName string) ([]intmodel.Space, error)

+ func (r *Exec) ListStacks(realmName, spaceName string) ([]intmodel.Stack, error)

+ func (r *Exec) PopulateAndPersistCellContainerStatuses(cell *intmodel.Cell) error

+ func (r *Exec) PurgeCell(cell intmodel.Cell) error

+ func (r *Exec) PurgeContainer(realm intmodel.Realm, containerID string) error

+ func (r *Exec) PurgeRealm(realm intmodel.Realm) error

+ func (r *Exec) PurgeSpace(space intmodel.Space) error

+ func (r *Exec) PurgeStack(stack intmodel.Stack) error

+ func (r *Exec) RecreateCell(desired intmodel.Cell) (intmodel.Cell, error)

+ func (r *Exec) RefreshCell(cell intmodel.Cell) (intmodel.Cell, int, error)

+ func (r *Exec) RefreshRealm(realm intmodel.Realm) (intmodel.Realm, bool, error)

+ func (r *Exec) RefreshSpace(space intmodel.Space) (intmodel.Space, bool, error)

+ func (r *Exec) RefreshStack(stack intmodel.Stack) (intmodel.Stack, bool, error)

+ func (r *Exec) StartCell(cell intmodel.Cell) (intmodel.Cell, error)

+ func (r *Exec) StartContainer(cell intmodel.Cell, containerID string) (intmodel.Cell, error)

+ func (r *Exec) StopCell(cell intmodel.Cell) (intmodel.Cell, error)

+ func (r *Exec) StopContainer(cell intmodel.Cell, containerID string) error

+ func (r *Exec) UpdateCell(desired intmodel.Cell) (intmodel.Cell, error)

+ func (r *Exec) UpdateCellMetadata(cell intmodel.Cell) error

+ func (r *Exec) UpdateContainer(cell intmodel.Cell, desiredContainer intmodel.ContainerSpec) (intmodel.Cell, error)

+ func (r *Exec) UpdateRealm(desired intmodel.Realm) (intmodel.Realm, error)

+ func (r *Exec) UpdateRealmMetadata(realm intmodel.Realm) error

+ func (r *Exec) UpdateSpace(desired intmodel.Space) (intmodel.Space, error)

+ func (r *Exec) UpdateSpaceMetadata(space intmodel.Space) error

+ func (r *Exec) UpdateStack(desired intmodel.Stack) (intmodel.Stack, error)

+ func (r *Exec) UpdateStackMetadata(stack intmodel.Stack) error

+ type Options struct

+ CniConf cni.Conf

+ ContainerdSocket string

+ RunPath string

+ type Runner interface

+ BootstrapCNI func(cfgDir, cacheDir, binDir string) (cni.BootstrapReport, error)

+ Close func() error

+ CreateCell func(cell intmodel.Cell) (intmodel.Cell, error)

+ CreateContainer func(cell intmodel.Cell, container intmodel.ContainerSpec) (intmodel.Cell, error)

+ CreateRealm func(realm intmodel.Realm) (intmodel.Realm, error)

+ CreateSpace func(space intmodel.Space) (intmodel.Space, error)

+ CreateStack func(stack intmodel.Stack) (intmodel.Stack, error)

+ DeleteCell func(cell intmodel.Cell) error

+ DeleteContainer func(cell intmodel.Cell, containerID string) error

+ DeleteRealm func(realm intmodel.Realm) error

+ DeleteSpace func(space intmodel.Space) error

+ DeleteStack func(stack intmodel.Stack) error

+ EnsureCell func(cell intmodel.Cell) (intmodel.Cell, error)

+ EnsureContainer func(cell intmodel.Cell, container intmodel.ContainerSpec) (intmodel.Cell, error)

+ EnsureKukeonRootCgroup func() (existsPre bool, created bool, err error)

+ EnsureRealm func(realm intmodel.Realm) (intmodel.Realm, error)

+ EnsureSpace func(space intmodel.Space) (intmodel.Space, error)

+ EnsureStack func(stack intmodel.Stack) (intmodel.Stack, error)

+ ExistsCellRootContainer func(cell intmodel.Cell) (bool, error)

+ ExistsCgroup func(doc any) (bool, error)

+ ExistsRealmContainerdNamespace func(namespace string) (bool, error)

+ ExistsSpaceCNIConfig func(space intmodel.Space) (bool, error)

+ GetCell func(cell intmodel.Cell) (intmodel.Cell, error)

+ GetContainerState func(cell intmodel.Cell, containerID string) (intmodel.ContainerState, error)

+ GetRealm func(realm intmodel.Realm) (intmodel.Realm, error)

+ GetSpace func(space intmodel.Space) (intmodel.Space, error)

+ GetStack func(stack intmodel.Stack) (intmodel.Stack, error)

+ KillCell func(cell intmodel.Cell) (intmodel.Cell, error)

+ KillContainer func(cell intmodel.Cell, containerID string) error

+ ListCells func(realmName, spaceName, stackName string) ([]intmodel.Cell, error)

+ ListContainers func(realmName, spaceName, stackName, cellName string) ([]intmodel.ContainerSpec, error)

+ ListRealms func() ([]intmodel.Realm, error)

+ ListSpaces func(realmName string) ([]intmodel.Space, error)

+ ListStacks func(realmName, spaceName string) ([]intmodel.Stack, error)

+ PurgeCell func(cell intmodel.Cell) error

+ PurgeContainer func(realm intmodel.Realm, containerID string) error

+ PurgeRealm func(realm intmodel.Realm) error

+ PurgeSpace func(space intmodel.Space) error

+ PurgeStack func(stack intmodel.Stack) error

+ RecreateCell func(cell intmodel.Cell) (intmodel.Cell, error)

+ RefreshCell func(cell intmodel.Cell) (intmodel.Cell, int, error)

+ RefreshRealm func(realm intmodel.Realm) (intmodel.Realm, bool, error)

+ RefreshSpace func(space intmodel.Space) (intmodel.Space, bool, error)

+ RefreshStack func(stack intmodel.Stack) (intmodel.Stack, bool, error)

+ StartCell func(cell intmodel.Cell) (intmodel.Cell, error)

+ StartContainer func(cell intmodel.Cell, containerID string) (intmodel.Cell, error)

+ StopCell func(cell intmodel.Cell) (intmodel.Cell, error)

+ StopContainer func(cell intmodel.Cell, containerID string) error

+ UpdateCell func(cell intmodel.Cell) (intmodel.Cell, error)

+ UpdateCellMetadata func(cell intmodel.Cell) error

+ UpdateContainer func(cell intmodel.Cell, container intmodel.ContainerSpec) (intmodel.Cell, error)

+ UpdateRealm func(realm intmodel.Realm) (intmodel.Realm, error)

+ UpdateSpace func(space intmodel.Space) (intmodel.Space, error)

+ UpdateStack func(stack intmodel.Stack) (intmodel.Stack, error)

+ func NewRunner(ctx context.Context, logger *slog.Logger, opts Options) Runner

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