unpack

type KeyedLocker ¶ added in v2.2.0

type KeyedLocker interface {
	Lock(ctx context.Context, key string) error
	Unlock(key string)
}

KeyedLocker is an interface for managing job duplication by locking on a given key.

type Limiter ¶ added in v2.2.0

type Limiter interface {
	Acquire(context.Context, int64) error
	Release(int64)
}

Limiter interface is used to restrict the number of concurrent operations by requiring operations to first acquire from the limiter and release when complete.

type Platform ¶

type Platform struct {
	Platform platforms.Matcher

	SnapshotterKey          string
	Snapshotter             snapshots.Snapshotter
	SnapshotOpts            []snapshots.Opt
	SnapshotterExports      map[string]string
	SnapshotterCapabilities []string

	Applier   diff.Applier
	ApplyOpts []diff.ApplyOpt

	// ConfigType is the supported config type to be considered for unpacking
	// Defaults to OCI image config
	ConfigType string

	// LayerTypes are the supported types to be considered layers
	// Defaults to OCI image layers
	LayerTypes []string
}

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(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 ¶

type UnpackerOpt func(*unpackerConfig) error

func WithDuplicationSuppressor(d KeyedLocker) UnpackerOpt

func WithLimiter(l Limiter) UnpackerOpt

func WithUnpackLimiter(l Limiter) UnpackerOpt

func WithUnpackPlatform(u Platform) UnpackerOpt