lib

package
v0.1.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 30, 2025 License: Apache-2.0 Imports: 26 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var ErrIsNonCrioContainer = errors.New("non CRI-O container")

Functions

func ShutdownWasUnclean

func ShutdownWasUnclean(config *libconfig.Config) bool

Types

type ContainerServer

type ContainerServer struct {
	Hooks *hooks.Manager
	*statsserver.StatsServer
	// contains filtered or unexported fields
}

ContainerServer implements the ImageServer.

func New

func New(ctx context.Context, configIface libconfig.Iface) (*ContainerServer, error)

New creates a new ContainerServer with options provided.

func (*ContainerServer) AddContainer

func (c *ContainerServer) AddContainer(ctx context.Context, ctr *oci.Container)

AddContainer adds a container to the container state store.

func (*ContainerServer) AddInfraContainer

func (c *ContainerServer) AddInfraContainer(ctx context.Context, ctr *oci.Container)

AddInfraContainer adds a container to the container state store.

func (*ContainerServer) AddSandbox

func (c *ContainerServer) AddSandbox(ctx context.Context, sb *sandbox.Sandbox) error

AddSandbox adds a sandbox to the sandbox state store.

func (*ContainerServer) Config

func (c *ContainerServer) Config() *libconfig.Config

Config gets the configuration for the ContainerServer.

func (*ContainerServer) ContainerIDForName

func (c *ContainerServer) ContainerIDForName(name string) (string, error)

ContainerIDForName gets the container ID given the container name from the ID Index.

func (*ContainerServer) ContainerStateToDisk

func (c *ContainerServer) ContainerStateToDisk(ctx context.Context, ctr *oci.Container) error

ContainerStateToDisk writes the container's state information to a JSON file on disk.

func (*ContainerServer) CtrIDIndex

func (c *ContainerServer) CtrIDIndex() *truncindex.TruncIndex

CtrIDIndex returns the TruncIndex for the ContainerServer.

func (*ContainerServer) GetContainer

func (c *ContainerServer) GetContainer(ctx context.Context, id string) *oci.Container

GetContainer returns a container by its ID.

func (*ContainerServer) GetContainerFromShortID

func (c *ContainerServer) GetContainerFromShortID(ctx context.Context, cid string) (*oci.Container, error)

GetContainerFromShortID gets an oci container matching the specified full or partial id.

func (*ContainerServer) GetInfraContainer

func (c *ContainerServer) GetInfraContainer(ctx context.Context, id string) *oci.Container

GetInfraContainer returns a container by its ID.

func (*ContainerServer) GetSandbox

func (c *ContainerServer) GetSandbox(id string) *sandbox.Sandbox

GetSandbox returns a sandbox by its ID.

func (*ContainerServer) GetSandboxContainer

func (c *ContainerServer) GetSandboxContainer(id string) *oci.Container

GetSandboxContainer returns a sandbox's infra container.

func (*ContainerServer) HasContainer

func (c *ContainerServer) HasContainer(id string) bool

HasContainer checks if a container exists in the state.

func (*ContainerServer) HasSandbox

func (c *ContainerServer) HasSandbox(id string) bool

HasSandbox checks if a sandbox exists in the state.

func (*ContainerServer) ListContainers

func (c *ContainerServer) ListContainers(filters ...func(*oci.Container) bool) ([]*oci.Container, error)

ListContainers returns a list of all containers stored by the server state that match the given filter function.

func (*ContainerServer) ListSandboxes

func (c *ContainerServer) ListSandboxes() []*sandbox.Sandbox

ListSandboxes lists all sandboxes in the state store.

func (*ContainerServer) LoadContainer

func (c *ContainerServer) LoadContainer(ctx context.Context, id string) (retErr error)

LoadContainer loads a container from the disk into the container store.

func (*ContainerServer) LoadSandbox

func (c *ContainerServer) LoadSandbox(ctx context.Context, id string) (sb *sandbox.Sandbox, retErr error)

LoadSandbox loads a sandbox from the disk into the sandbox store.

func (*ContainerServer) LookupContainer

func (c *ContainerServer) LookupContainer(ctx context.Context, idOrName string) (*oci.Container, error)

LookupContainer returns the container with the given name or full or partial id.

func (*ContainerServer) LookupSandbox

func (c *ContainerServer) LookupSandbox(idOrName string) (*sandbox.Sandbox, error)

LookupSandbox returns the pod sandbox with the given name or full or partial id.

func (*ContainerServer) PodIDForName

func (c *ContainerServer) PodIDForName(name string) (string, error)

PodIDForName gets the pod ID given the pod name from the ID Index.

func (*ContainerServer) PodIDIndex

func (c *ContainerServer) PodIDIndex() *truncindex.TruncIndex

PodIDIndex returns the index of pod IDs.

func (*ContainerServer) ReleaseContainerName

func (c *ContainerServer) ReleaseContainerName(ctx context.Context, name string)

ReleaseContainerName releases a container name from the index so that it can be used by other containers.

func (*ContainerServer) ReleasePodName

func (c *ContainerServer) ReleasePodName(name string)

ReleasePodName releases a pod name from the index so it can be used by other pods.

func (*ContainerServer) RemoveContainer

func (c *ContainerServer) RemoveContainer(ctx context.Context, ctr *oci.Container)

RemoveContainer removes a container from the container state store.

func (*ContainerServer) RemoveInfraContainer

func (c *ContainerServer) RemoveInfraContainer(ctx context.Context, ctr *oci.Container)

RemoveInfraContainer removes a container from the container state store.

func (*ContainerServer) RemoveSandbox

func (c *ContainerServer) RemoveSandbox(ctx context.Context, id string) error

RemoveSandbox removes a sandbox from the state store.

func (*ContainerServer) ReserveContainerName

func (c *ContainerServer) ReserveContainerName(id, name string) (string, error)

ReserveContainerName holds a name for a container that is being created.

func (*ContainerServer) ReservePodName

func (c *ContainerServer) ReservePodName(id, name string) (string, error)

ReservePodName holds a name for a pod that is being created.

func (*ContainerServer) Runtime

func (c *ContainerServer) Runtime() *oci.Runtime

Runtime returns the oci runtime for the ContainerServer.

func (*ContainerServer) Shutdown

func (c *ContainerServer) Shutdown() error

Shutdown attempts to shut down the server's storage cleanly.

func (*ContainerServer) StorageService

func (c *ContainerServer) StorageService() *storage.StorageService

StorageService returns the StorageService for the ContainerServer.

func (*ContainerServer) UpdateContainerLinuxResources

func (c *ContainerServer) UpdateContainerLinuxResources(ctr *oci.Container, resources *rspec.LinuxResources)

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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