Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Container ¶
type Container struct {
// Metadata is the metadata of the container, it is **immutable** after created.
Metadata
// Status stores the status of the container.
Status StatusStorage
// Containerd container
Container containerd.Container
// Container IO
IO *cio.ContainerIO
}
Container contains all resources associated with the container. All methods to mutate the internal state are thread-safe.
func NewContainer ¶
NewContainer creates an internally used container type.
type Metadata ¶
type Metadata struct {
// ID is the container id.
ID string
// Name is the container name.
Name string
// SandboxID is the sandbox id the container belongs to.
SandboxID string
// Config is the CRI container config.
Config *runtime.ContainerConfig
// ImageRef is the reference of image used by the container.
ImageRef string
// LogPath is the container log path.
LogPath string
}
Metadata is the unversioned container metadata.
func (*Metadata) MarshalJSON ¶
MarshalJSON encodes Metadata into bytes in json format.
func (*Metadata) UnmarshalJSON ¶
UnmarshalJSON decodes Metadata from bytes.
type Opts ¶
Opts sets specific information to newly created Container.
func WithContainer ¶
func WithContainer(cntr containerd.Container) Opts
WithContainer adds the containerd Container to the internal data store.
func WithContainerIO ¶
func WithContainerIO(io *cio.ContainerIO) Opts
WithContainerIO adds IO into the container.
func WithFakeStatus ¶
WithFakeStatus adds fake status to the container.
func WithStatus ¶
WithStatus adds status to the container.
type Status ¶
type Status struct {
// Pid is the init process id of the container.
Pid uint32
// CreatedAt is the created timestamp.
CreatedAt int64
// StartedAt is the started timestamp.
StartedAt int64
// FinishedAt is the finished timestamp.
FinishedAt int64
// ExitCode is the container exit code.
ExitCode int32
// CamelCase string explaining why container is in its current state.
Reason string
// Human-readable message indicating details about why container is in its
// current state.
Message string
// Removing indicates that the container is in removing state.
// This field doesn't need to be checkpointed.
Removing bool `json:"-"`
}
Status is the status of a container.
func LoadStatus ¶
LoadStatus loads container status from checkpoint. There shouldn't be threads writing to the file during loading.
func (Status) State ¶
func (s Status) State() runtime.ContainerState
State returns current state of the container based on the container status.
type StatusStorage ¶
type StatusStorage interface {
// Get a container status.
Get() Status
// Update the container status. Note that the update MUST be applied
// in one transaction.
// TODO(random-liu): Distinguish `UpdateSync` and `Update`, only
// `UpdateSync` should sync data onto disk, so that disk operation
// for non-critical status change could be avoided.
Update(UpdateFunc) error
// Delete the container status.
// Note:
// * Delete should be idempotent.
// * The status must be deleted in one trasaction.
Delete() error
}
StatusStorage manages the container status with a storage backend.
func StoreStatus ¶
func StoreStatus(root, id string, status Status) (StatusStorage, error)
StoreStatus creates the storage containing the passed in container status with the specified id. The status MUST be created in one transaction.
type Store ¶
type Store struct {
// contains filtered or unexported fields
}
Store stores all Containers.
func LoadStore ¶
func LoadStore() *Store
LoadStore loads containers from runtime. TODO(random-liu): Implement LoadStore.
func (*Store) Add ¶
Add a container into the store. Returns store.ErrAlreadyExist if the container already exists.
type UpdateFunc ¶
UpdateFunc is function used to update the container status. If there is an error, the update will be rolled back.
Source Files