containerd

Sep 27, 2019

Changes in this version

+ var ErrCheckpointRWUnsupported = errors.New("rw checkpoint is only supported on v2 runtimes")

+ var ErrImageNameNotFoundInIndex = errors.New("image name not found in index")

+ var ErrMediaTypeNotFound = errors.New("media type not found")

+ var ErrRuntimeNameNotFoundInIndex = errors.New("runtime not found in index")

+ var ErrSnapshotterNameNotFoundInIndex = errors.New("snapshotter not found in index")

+ func CheckRuntime(current, expected string) bool

+ func GetIndexByMediaType(index *imagespec.Index, mt string) (*imagespec.Descriptor, error)

+ func WithCheckpointImage(ctx context.Context, client *Client, c *containers.Container, ...) error

+ func WithCheckpointRW(ctx context.Context, client *Client, c *containers.Container, ...) error

+ func WithCheckpointRuntime(ctx context.Context, client *Client, c *containers.Container, ...) error

+ func WithCheckpointTask(ctx context.Context, client *Client, c *containers.Container, ...) error

+ func WithCheckpointTaskExit(ctx context.Context, client *Client, c *containers.Container, ...) error

+ func WithoutRefreshedMetadata(i *InfoConfig)

+ type CheckpointOpts func(context.Context, *Client, *containers.Container, *imagespec.Index, ...) error

type CheckpointTaskInfo

+ func (i *CheckpointTaskInfo) Runtime() string

type CheckpointTaskOpts

+ func WithCheckpointImagePath(path string) CheckpointTaskOpts

type Client

+ func (c *Client) Conn() *grpc.ClientConn

+ func (c *Client) GetLabel(ctx context.Context, label string) (string, error)

+ func (c *Client) Restore(ctx context.Context, id string, checkpoint Image, opts ...RestoreOpts) (Container, error)

+ func (c *Client) Server(ctx context.Context) (ServerInfo, error)

type ClientOpt

+ func WithDefaultPlatform(platform platforms.MatchComparer) ClientOpt

type Container

+ Checkpoint func(context.Context, string, ...CheckpointOpts) (Image, error)

type ExitStatus

+ func NewExitStatus(code uint32, t time.Time, err error) *ExitStatus

type Image

+ Usage func(context.Context, ...UsageOpt) (int64, error)

type ImportOpt

+ func WithAllPlatforms(allPlatforms bool) ImportOpt

+ func WithImportCompression() ImportOpt

+ type InfoConfig struct

+ Refresh bool

+ type InfoOpts func(*InfoConfig)

type NewContainerOpts

+ func WithImageName(n string) NewContainerOpts

+ func WithRestoreImage(ctx context.Context, id string, client *Client, checkpoint Image, ...) NewContainerOpts

+ func WithRestoreRW(ctx context.Context, id string, client *Client, checkpoint Image, ...) NewContainerOpts

+ func WithRestoreRuntime(ctx context.Context, id string, client *Client, checkpoint Image, ...) NewContainerOpts

+ func WithRestoreSpec(ctx context.Context, id string, client *Client, checkpoint Image, ...) NewContainerOpts

type NewTaskOpts

+ func WithRestoreImagePath(path string) NewTaskOpts

+ func WithShimCgroup(path string) NewTaskOpts

type RemoteContext

+ AllMetadata bool

+ HandlerWrapper func(images.Handler) images.Handler

+ MaxConcurrentDownloads int

+ UnpackOpts []UnpackOpt

type RemoteOpt

+ func WithAllMetadata() RemoteOpt

+ func WithImageHandlerWrapper(w func(images.Handler) images.Handler) RemoteOpt

+ func WithMaxConcurrentDownloads(max int) RemoteOpt

+ type RestoreOpts func(context.Context, string, *Client, Image, *imagespec.Index) NewContainerOpts

+ type ServerInfo struct

+ UUID string

type TaskInfo

+ func (i *TaskInfo) Runtime() string

+ type UnpackConfig struct

+ ApplyOpts []diff.ApplyOpt

+ SnapshotOpts []snapshots.Opt

+ type UnpackOpt func(context.Context, *UnpackConfig) error

+ type UsageOpt func(*usageOptions) error

+ func WithManifestUsage() UsageOpt

+ func WithSnapshotUsage() UsageOpt

+ func WithUsageManifestLimit(i int) UsageOpt

Oct 24, 2018

Changes in this version

+ const StopSignalLabel

+ func GetOCIStopSignal(ctx context.Context, image Image, defaultSignal string) (string, error)

+ func GetStopSignal(ctx context.Context, container Container, defaultSignal syscall.Signal) (syscall.Signal, error)

+ func ParseSignal(rawSignal string) (syscall.Signal, error)

+ func WithInstallLibs(c *InstallConfig)

+ func WithInstallReplace(c *InstallConfig)

+ func WithNoNewKeyring(ctx context.Context, c *Client, ti *TaskInfo) error — darwin/amd64, js/wasm, linux/amd64

type Client

+ func (c *Client) Fetch(ctx context.Context, ref string, opts ...RemoteOpt) (images.Image, error)

+ func (c *Client) Install(ctx context.Context, image Image, opts ...InstallOpts) error

type ClientOpt

+ func WithDefaultRuntime(rt string) ClientOpt

+ func WithTimeout(d time.Duration) ClientOpt

type Image

+ func NewImageWithPlatform(client *Client, i images.Image, platform platforms.MatchComparer) Image

+ Labels func() map[string]string

type ImportOpt

+ func WithDigestRef(f func(digest.Digest) string) ImportOpt

+ func WithImageRefTranslator(f func(string) string) ImportOpt

+ func WithIndexName(name string) ImportOpt

+ type InstallConfig struct

+ Libs bool

+ Path string

+ Replace bool

+ type InstallOpts func(*InstallConfig)

+ func WithInstallPath(path string) InstallOpts

type NewContainerOpts

+ func WithImageStopSignal(image Image, defaultSignal string) NewContainerOpts

type NewTaskOpts — windows/amd64

+ func WithTaskCheckpoint(im Image) NewTaskOpts

type RemoteContext

+ PlatformMatcher platforms.MatchComparer

type RemoteOpt

+ func WithPlatformMatcher(m platforms.MatchComparer) RemoteOpt

type UpdateTaskOpts — darwin/amd64, js/wasm

+ func WithResources(resources interface{}) UpdateTaskOpts

Apr 24, 2018

Changes in this version

+ const DefaultSnapshotter — darwin/amd64, linux/amd64, windows/amd64

+ const UnknownExitStatus

+ func NewContentStoreFromClient(client contentapi.ContentClient) content.Store

+ func NewImageStoreFromClient(client imagesapi.ImagesClient) images.Store

+ func NewNamespaceStoreFromClient(client api.NamespacesClient) namespaces.Store

+ func NewRemoteContainerStore(client containersapi.ContainersClient) containers.Store

+ func NewSnapshotterFromClient(client snapshotsapi.SnapshotsClient, snapshotterName string) snapshots.Snapshotter

+ func WithExit(r *CheckpointTaskInfo) error

+ func WithKillAll(ctx context.Context, i *KillInfo) error

+ func WithNoPivotRoot(_ context.Context, _ *Client, info *TaskInfo) error — darwin/amd64, js/wasm, linux/amd64

+ func WithProcessKill(ctx context.Context, p Process) error

+ func WithPullUnpack(_ *Client, c *RemoteContext) error

+ func WithSchema1Conversion(client *Client, c *RemoteContext) error

+ func WithSnapshotCleanup(ctx context.Context, client *Client, c containers.Container) error

+ func WithStdinCloser(r *IOCloseInfo)

+ type CheckpointTaskInfo struct

+ Name string

+ Options interface{}

+ ParentCheckpoint digest.Digest

+ type CheckpointTaskOpts func(*CheckpointTaskInfo) error

+ func WithCheckpointName(name string) CheckpointTaskOpts

+ type Client struct

+ func New(address string, opts ...ClientOpt) (*Client, error)

+ func NewWithConn(conn *grpc.ClientConn, opts ...ClientOpt) (*Client, error)

+ func (c *Client) Close() error

+ func (c *Client) ContainerService() containers.Store

+ func (c *Client) Containers(ctx context.Context, filters ...string) ([]Container, error)

+ func (c *Client) ContentStore() content.Store

+ func (c *Client) CreateLease(ctx context.Context) (Lease, error)

+ func (c *Client) DiffService() DiffService

+ func (c *Client) EventService() EventService

+ func (c *Client) Export(ctx context.Context, exporter images.Exporter, desc ocispec.Descriptor, ...) (io.ReadCloser, error)

+ func (c *Client) GetImage(ctx context.Context, ref string) (Image, error)

+ func (c *Client) HealthService() grpc_health_v1.HealthClient

+ func (c *Client) ImageService() images.Store

+ func (c *Client) Import(ctx context.Context, importer images.Importer, reader io.Reader, ...) ([]Image, error)

+ func (c *Client) IntrospectionService() introspectionapi.IntrospectionClient

+ func (c *Client) IsServing(ctx context.Context) (bool, error)

+ func (c *Client) LeasesService() leasesapi.LeasesClient

+ func (c *Client) ListImages(ctx context.Context, filters ...string) ([]Image, error)

+ func (c *Client) ListLeases(ctx context.Context) ([]Lease, error)

+ func (c *Client) LoadContainer(ctx context.Context, id string) (Container, error)

+ func (c *Client) NamespaceService() namespaces.Store

+ func (c *Client) NewContainer(ctx context.Context, id string, opts ...NewContainerOpts) (Container, error)

+ func (c *Client) Pull(ctx context.Context, ref string, opts ...RemoteOpt) (Image, error)

+ func (c *Client) Push(ctx context.Context, ref string, desc ocispec.Descriptor, opts ...RemoteOpt) error

+ func (c *Client) Reconnect() error

+ func (c *Client) SnapshotService(snapshotterName string) snapshots.Snapshotter

+ func (c *Client) Subscribe(ctx context.Context, filters ...string) (ch <-chan *events.Envelope, errs <-chan error)

+ func (c *Client) TaskService() tasks.TasksClient

+ func (c *Client) Version(ctx context.Context) (Version, error)

+ func (c *Client) VersionService() versionservice.VersionClient

+ func (c *Client) WithLease(ctx context.Context) (context.Context, func(context.Context) error, error)

+ type ClientOpt func(c *clientOpts) error

+ func WithDefaultNamespace(ns string) ClientOpt

+ func WithDialOpts(opts []grpc.DialOption) ClientOpt

+ func WithServices(opts ...ServicesOpt) ClientOpt

+ type Container interface

+ Delete func(context.Context, ...DeleteOpts) error

+ Extensions func(context.Context) (map[string]prototypes.Any, error)

+ ID func() string

+ Image func(context.Context) (Image, error)

+ Info func(context.Context) (containers.Container, error)

+ Labels func(context.Context) (map[string]string, error)

+ NewTask func(context.Context, cio.Creator, ...NewTaskOpts) (Task, error)

+ SetLabels func(context.Context, map[string]string) (map[string]string, error)

+ Spec func(context.Context) (*specs.Spec, error)

+ Task func(context.Context, cio.Attach) (Task, error)

+ Update func(context.Context, ...UpdateContainerOpts) error

+ type DeleteOpts func(ctx context.Context, client *Client, c containers.Container) error

+ type DiffService interface

+ func NewDiffServiceFromClient(client diffapi.DiffClient) DiffService

+ type EventService interface

+ func NewEventServiceFromClient(client eventsapi.EventsClient) EventService

+ type ExitStatus struct

+ func (s ExitStatus) Error() error

+ func (s ExitStatus) ExitCode() uint32

+ func (s ExitStatus) ExitTime() time.Time

+ func (s ExitStatus) Result() (uint32, time.Time, error)

+ type ExportOpt func(c *exportOpts) error

+ type IOCloseInfo struct

+ Stdin bool

+ type IOCloserOpts func(*IOCloseInfo)

+ type Image interface

+ Config func(ctx context.Context) (ocispec.Descriptor, error)

+ ContentStore func() content.Store

+ IsUnpacked func(context.Context, string) (bool, error)

+ Name func() string

+ RootFS func(ctx context.Context) ([]digest.Digest, error)

+ Size func(ctx context.Context) (int64, error)

+ Target func() ocispec.Descriptor

+ Unpack func(context.Context, string) error

+ func NewImage(client *Client, i images.Image) Image

+ type ImportOpt func(c *importOpts) error

+ type KillInfo struct

+ All bool

+ ExecID string

+ type KillOpts func(context.Context, *KillInfo) error

+ func WithKillExecID(execID string) KillOpts

+ type Lease struct

+ func (l Lease) CreatedAt() time.Time

+ func (l Lease) Delete(ctx context.Context) error

+ func (l Lease) ID() string

+ type NewContainerOpts func(ctx context.Context, client *Client, c *containers.Container) error

+ func WithCheckpoint(im Image, snapshotKey string) NewContainerOpts

+ func WithContainerExtension(name string, extension interface{}) NewContainerOpts

+ func WithContainerLabels(labels map[string]string) NewContainerOpts

+ func WithImage(i Image) NewContainerOpts

+ func WithNewSnapshot(id string, i Image) NewContainerOpts

+ func WithNewSnapshotView(id string, i Image) NewContainerOpts

+ func WithNewSpec(opts ...oci.SpecOpts) NewContainerOpts

+ func WithRemappedSnapshot(id string, i Image, uid, gid uint32) NewContainerOpts

+ func WithRemappedSnapshotView(id string, i Image, uid, gid uint32) NewContainerOpts

+ func WithRuntime(name string, options interface{}) NewContainerOpts

+ func WithSnapshot(id string) NewContainerOpts

+ func WithSnapshotter(name string) NewContainerOpts

+ func WithSpec(s *specs.Spec, opts ...oci.SpecOpts) NewContainerOpts

+ type NewTaskOpts func(context.Context, *Client, *TaskInfo) error

+ func WithRootFS(mounts []mount.Mount) NewTaskOpts

+ func WithTaskCheckpoint(im Image) NewTaskOpts

+ type Process interface

+ CloseIO func(context.Context, ...IOCloserOpts) error

+ Delete func(context.Context, ...ProcessDeleteOpts) (*ExitStatus, error)

+ ID func() string

+ IO func() cio.IO

+ Kill func(context.Context, syscall.Signal, ...KillOpts) error

+ Pid func() uint32

+ Resize func(ctx context.Context, w, h uint32) error

+ Start func(context.Context) error

+ Status func(context.Context) (Status, error)

+ Wait func(context.Context) (<-chan ExitStatus, error)

+ type ProcessDeleteOpts func(context.Context, Process) error

+ type ProcessInfo struct

+ Info *google_protobuf.Any

+ Pid uint32

+ type ProcessStatus string

+ const Created

+ const Paused

+ const Pausing

+ const Running

+ const Stopped

+ const Unknown

+ type RemoteContext struct

+ BaseHandlers []images.Handler

+ ConvertSchema1 bool

+ Labels map[string]string

+ Platforms []string

+ Resolver remotes.Resolver

+ Snapshotter string

+ Unpack bool

+ type RemoteOpt func(*Client, *RemoteContext) error

+ func WithImageHandler(h images.Handler) RemoteOpt

+ func WithPlatform(platform string) RemoteOpt

+ func WithPullLabel(key, value string) RemoteOpt

+ func WithPullLabels(labels map[string]string) RemoteOpt

+ func WithPullSnapshotter(snapshotterName string) RemoteOpt

+ func WithResolver(resolver remotes.Resolver) RemoteOpt

+ type ServicesOpt func(c *services)

+ func WithContainerService(containerService containersapi.ContainersClient) ServicesOpt

+ func WithContentStore(contentStore content.Store) ServicesOpt

+ func WithDiffService(diffService diff.DiffClient) ServicesOpt

+ func WithEventService(eventService EventService) ServicesOpt

+ func WithImageService(imageService imagesapi.ImagesClient) ServicesOpt

+ func WithLeasesService(leasesService leases.LeasesClient) ServicesOpt

+ func WithNamespaceService(namespaceService namespacesapi.NamespacesClient) ServicesOpt

+ func WithSnapshotters(snapshotters map[string]snapshots.Snapshotter) ServicesOpt

+ func WithTaskService(taskService tasks.TasksClient) ServicesOpt

+ type Status struct

+ ExitStatus uint32

+ ExitTime time.Time

+ Status ProcessStatus

+ type Task interface

+ Checkpoint func(context.Context, ...CheckpointTaskOpts) (Image, error)

+ Exec func(context.Context, string, *specs.Process, cio.Creator) (Process, error)

+ LoadProcess func(context.Context, string, cio.Attach) (Process, error)

+ Metrics func(context.Context) (*types.Metric, error)

+ Pause func(context.Context) error

+ Pids func(context.Context) ([]ProcessInfo, error)

+ Resume func(context.Context) error

+ Update func(context.Context, ...UpdateTaskOpts) error

+ type TaskInfo struct

+ Checkpoint *types.Descriptor

+ Options interface{}

+ RootFS []mount.Mount

+ type UpdateContainerOpts func(ctx context.Context, client *Client, c *containers.Container) error

+ type UpdateTaskInfo struct

+ Resources interface{}

+ type UpdateTaskOpts func(context.Context, *Client, *UpdateTaskInfo) error

+ func WithResources(resources *specs.LinuxResources) UpdateTaskOpts

+ func WithResources(resources *specs.WindowsResources) UpdateTaskOpts

+ type Version struct

+ Revision string

+ Version string