package unpack

import "github.com/containerd/containerd/pkg/unpack"

Index ¶

• type Platform
• type Result
• type Unpacker
• func NewUnpacker(ctx context.Context, cs content.Store, opts ...UnpackerOpt) (*Unpacker, error)
• func (u *Unpacker) Unpack(h images.Handler) images.Handler
• func (u *Unpacker) Wait() (Result, error)
• type UnpackerOpt
• func WithDuplicationSuppressor(d kmutex.KeyedLocker) UnpackerOpt
• func WithLimiter(l *semaphore.Weighted) UnpackerOpt
• func WithUnpackPlatform(u Platform) UnpackerOpt

Types ¶

type Platform ¶

type Platform struct {
	Platform platforms.Matcher

	SnapshotterKey string
	Snapshotter    snapshots.Snapshotter
	SnapshotOpts   []snapshots.Opt

	Applier   diff.Applier
	ApplyOpts []diff.ApplyOpt
}

Platform represents a platform-specific unpack configuration which includes the platform matcher as well as snapshotter and applier.

type Result ¶

type Result struct {
	Unpacks int
}

Result returns information about the unpacks which were completed.

type Unpacker ¶

type Unpacker struct {
	// contains filtered or unexported fields
}

Unpacker unpacks images by hooking into the image handler process. Unpacks happen in the backgrounds and waited on to complete.

func NewUnpacker ¶

func NewUnpacker(ctx context.Context, cs content.Store, opts ...UnpackerOpt) (*Unpacker, error)

NewUnpacker creates a new instance of the unpacker which can be used to wrap an image handler and unpack in parallel to handling. The unpacker will handle calling the block handlers when they are needed by the unpack process.

func (*Unpacker) Unpack ¶

func (u *Unpacker) Unpack(h images.Handler) images.Handler

Unpack wraps an image handler to filter out blob handling and scheduling them during the unpack process. When an image config is encountered, the unpack process will be started in a goroutine.

func (*Unpacker) Wait ¶

func (u *Unpacker) Wait() (Result, error)

Wait waits for any ongoing unpack processes to complete then will return the result.

type UnpackerOpt ¶

type UnpackerOpt func(*unpackerConfig) error

func WithDuplicationSuppressor ¶

func WithDuplicationSuppressor(d kmutex.KeyedLocker) UnpackerOpt

func WithLimiter ¶

func WithLimiter(l *semaphore.Weighted) UnpackerOpt

func WithUnpackPlatform ¶

func WithUnpackPlatform(u Platform) UnpackerOpt

Source Files ¶

unpacker.go