worker

Documentation

Index

• func DefaultGCPolicy(p string, defaultKeepBytes int64) []client.PruneInfo
• type ContainerdWorker
  • func NewContainerdWorker(ctx context.Context, wo base.WorkerOpt, callbacks exporter.BuildkitCallbacks) (*ContainerdWorker, error)
  • func (w *ContainerdWorker) Exporter(name string, sm *session.Manager) (bkexporter.Exporter, error)
• type LayerAccess
• type Opt
• type Worker
  • func NewWorker(opt Opt) (*Worker, error)
  • func (w *Worker) BuildkitVersion() client.BuildkitVersion
  • func (w *Worker) CacheManager() cache.Manager
  • func (w *Worker) Close() error
  • func (w *Worker) ContentStore() *containerdsnapshot.Store
  • func (w *Worker) DiskUsage(ctx context.Context, opt client.DiskUsageInfo) ([]*client.UsageInfo, error)
  • func (w *Worker) Executor() executor.Executor
  • func (w *Worker) Exporter(name string, sm *session.Manager) (exporter.Exporter, error)
  • func (w *Worker) FromRemote(ctx context.Context, remote *solver.Remote) (cache.ImmutableRef, error)
  • func (w *Worker) GCPolicy() []client.PruneInfo
  • func (w *Worker) GarbageCollect(ctx context.Context) error
  • func (w *Worker) GetRemotes(ctx context.Context, ref cache.ImmutableRef, createIfNeeded bool, ...) ([]*solver.Remote, error)
  • func (w *Worker) ID() string
  • func (w *Worker) Labels() map[string]string
  • func (w *Worker) LeaseManager() *leaseutil.Manager
  • func (w *Worker) LoadRef(ctx context.Context, id string, hidden bool) (cache.ImmutableRef, error)
  • func (w *Worker) Platforms(noCache bool) []ocispec.Platform
  • func (w *Worker) Prune(ctx context.Context, ch chan client.UsageInfo, info ...client.PruneInfo) error
  • func (w *Worker) PruneCacheMounts(ctx context.Context, ids map[string]bool) error
  • func (w *Worker) ResolveImageConfig(ctx context.Context, ref string, opt sourceresolver.Opt, sm *session.Manager, ...) (digest.Digest, []byte, error)
  • func (w *Worker) ResolveOp(v solver.Vertex, s frontend.FrontendLLBBridge, sm *session.Manager) (solver.Op, error)
  • func (w *Worker) ResolveSourceMetadata(ctx context.Context, op *pb.SourceOp, opt sourceresolver.Opt, ...) (*sourceresolver.MetaResponse, error)

Functions

func DefaultGCPolicy

func DefaultGCPolicy(p string, defaultKeepBytes int64) []client.PruneInfo

DefaultGCPolicy returns a default builder GC policy

Types

type ContainerdWorker

type ContainerdWorker struct {
	*base.Worker
	// contains filtered or unexported fields
}

ContainerdWorker is a local worker instance with dedicated snapshotter, cache, and so on.

func NewContainerdWorker

func NewContainerdWorker(ctx context.Context, wo base.WorkerOpt, callbacks exporter.BuildkitCallbacks) (*ContainerdWorker, error)

NewContainerdWorker instantiates a local worker.

func (*ContainerdWorker) Exporter

func (w *ContainerdWorker) Exporter(name string, sm *session.Manager) (bkexporter.Exporter, error)

Exporter returns exporter by name

type LayerAccess

type LayerAccess interface {
	GetDiffIDs(ctx context.Context, key string) ([]layer.DiffID, error)
	EnsureLayer(ctx context.Context, key string) ([]layer.DiffID, error)
}

LayerAccess provides access to a moby layer from a snapshot

type Opt

type Opt struct {
	ID                string
	Labels            map[string]string
	GCPolicy          []client.PruneInfo
	Executor          executor.Executor
	Snapshotter       snapshot.Snapshotter
	ContentStore      *containerdsnapshot.Store
	CacheManager      cache.Manager
	LeaseManager      *leaseutil.Manager
	GarbageCollect    func(context.Context) (gc.Stats, error)
	ImageSource       *imageadapter.Source
	DownloadManager   *xfer.LayerDownloadManager
	V2MetadataService distmetadata.V2MetadataService
	Transport         nethttp.RoundTripper
	Exporter          exporter.Exporter
	Layers            LayerAccess
	Platforms         []ocispec.Platform
}

Opt defines a structure for creating a worker.

type Worker

type Worker struct {
	Opt
	SourceManager *source.Manager
}

Worker is a local worker instance with dedicated snapshotter, cache, and so on. TODO: s/Worker/OpWorker/g ?

func NewWorker

func NewWorker(opt Opt) (*Worker, error)

NewWorker instantiates a local worker

func (*Worker) BuildkitVersion

func (w *Worker) BuildkitVersion() client.BuildkitVersion

BuildkitVersion returns BuildKit version

func (*Worker) CacheManager

func (w *Worker) CacheManager() cache.Manager

CacheManager returns cache.Manager for accessing local storage

func (*Worker) Close

func (w *Worker) Close() error

Close closes the worker and releases all resources

func (*Worker) ContentStore

func (w *Worker) ContentStore() *containerdsnapshot.Store

ContentStore returns the wrapped content store

func (*Worker) DiskUsage

func (w *Worker) DiskUsage(ctx context.Context, opt client.DiskUsageInfo) ([]*client.UsageInfo, error)

DiskUsage returns disk usage report

func (*Worker) Executor

func (w *Worker) Executor() executor.Executor

Executor returns executor.Executor for running processes

func (*Worker) Exporter

func (w *Worker) Exporter(name string, sm *session.Manager) (exporter.Exporter, error)

Exporter returns exporter by name

func (*Worker) FromRemote

func (w *Worker) FromRemote(ctx context.Context, remote *solver.Remote) (cache.ImmutableRef, error)

FromRemote converts a remote snapshot reference to a local one

func (*Worker) GCPolicy

func (w *Worker) GCPolicy() []client.PruneInfo

GCPolicy returns automatic GC Policy

func (*Worker) GarbageCollect

func (w *Worker) GarbageCollect(ctx context.Context) error

func (*Worker) GetRemotes

func (w *Worker) GetRemotes(ctx context.Context, ref cache.ImmutableRef, createIfNeeded bool, _ cacheconfig.RefConfig, all bool, s session.Group) ([]*solver.Remote, error)

GetRemotes returns the remote snapshot references given a local reference

func (*Worker) ID

func (w *Worker) ID() string

ID returns worker ID

func (*Worker) Labels

func (w *Worker) Labels() map[string]string

Labels returns map of all worker labels

func (*Worker) LeaseManager

func (w *Worker) LeaseManager() *leaseutil.Manager

LeaseManager returns the wrapped lease manager

func (*Worker) LoadRef

func (w *Worker) LoadRef(ctx context.Context, id string, hidden bool) (cache.ImmutableRef, error)

LoadRef loads a reference by ID

func (*Worker) Platforms

func (w *Worker) Platforms(noCache bool) []ocispec.Platform

Platforms returns one or more platforms supported by the image.

func (*Worker) Prune

func (w *Worker) Prune(ctx context.Context, ch chan client.UsageInfo, info ...client.PruneInfo) error

Prune deletes reclaimable build cache

func (*Worker) PruneCacheMounts

func (w *Worker) PruneCacheMounts(ctx context.Context, ids map[string]bool) error

PruneCacheMounts removes the current cache snapshots for specified IDs

func (*Worker) ResolveImageConfig

func (w *Worker) ResolveImageConfig(ctx context.Context, ref string, opt sourceresolver.Opt, sm *session.Manager, g session.Group) (digest.Digest, []byte, error)

ResolveImageConfig returns image config for an image

func (*Worker) ResolveOp

func (w *Worker) ResolveOp(v solver.Vertex, s frontend.FrontendLLBBridge, sm *session.Manager) (solver.Op, error)

ResolveOp converts a LLB vertex into a LLB operation

func (*Worker) ResolveSourceMetadata

func (w *Worker) ResolveSourceMetadata(ctx context.Context, op *pb.SourceOp, opt sourceresolver.Opt, sm *session.Manager, g session.Group) (*sourceresolver.MetaResponse, error)