func DefaultGCPolicy(pstring, reservedSpace, maxUsedSpace, minFreeSpaceint64) []client.PruneInfo

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

funcNewContainerdWorker¶

func NewContainerdWorker(ctxcontext.Context, wobase.WorkerOpt, callbacksexporter.BuildkitCallbacks, rtnethttp.RoundTripper) (*ContainerdWorker,error)

NewContainerdWorker instantiates a local worker.

func (*ContainerdWorker)Exporter¶

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

Exporter returns exporter by name

type LayerAccess interface {GetDiffIDs(ctxcontext.Context, keystring) ([]layer.DiffID,error)EnsureLayer(ctxcontext.Context, keystring) ([]layer.DiffID,error)}

type Opt struct {IDstringLabels         map[string]stringGCPolicy       []client.PruneInfoExecutorexecutor.ExecutorSnapshottersnapshot.SnapshotterContentStore   *containerdsnapshot.StoreCacheManagercache.ManagerLeaseManager   *leaseutil.ManagerGarbageCollect func(context.Context) (gc.Stats,error)ImageSource    *imageadapter.SourceDownloadManager   *xfer.LayerDownloadManagerV2MetadataServicedistmetadata.V2MetadataServiceTransportnethttp.RoundTripperExporterexporter.ExporterLayersLayerAccessPlatforms         []ocispec.PlatformCDIManager        *cdidevices.Manager}

type Worker struct {OptSourceManager *source.ManagerGitSource     *git.SourceHTTPSource    *http.Source}

funcNewWorker¶

func NewWorker(optOpt) (*Worker,error)

NewWorker instantiates a local worker

func (*Worker)BuildkitVersion¶

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

BuildkitVersion returns BuildKit version

func (*Worker)CDIManager¶

func (w *Worker) CDIManager() *cdidevices.Manager

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(ctxcontext.Context, optclient.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(namestring, sm *session.Manager) (exporter.Exporter,error)

Exporter returns exporter by name

func (*Worker)FromRemote¶

func (w *Worker) FromRemote(ctxcontext.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(ctxcontext.Context)error

func (*Worker)GetRemotes¶

func (w *Worker) GetRemotes(ctxcontext.Context, refcache.ImmutableRef, createIfNeededbool, _cacheconfig.RefConfig, allbool, ssession.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(ctxcontext.Context, idstring, hiddenbool) (cache.ImmutableRef,error)

LoadRef loads a reference by ID

func (*Worker)Platforms¶

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

Platforms returns one or more platforms supported by the image.

func (*Worker)Prune¶

func (w *Worker) Prune(ctxcontext.Context, ch chanclient.UsageInfo, info ...client.PruneInfo)error

Prune deletes reclaimable build cache

func (*Worker)PruneCacheMounts¶

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

PruneCacheMounts removes the current cache snapshots for specified IDs

func (*Worker)ResolveImageConfig¶

func (w *Worker) ResolveImageConfig(ctxcontext.Context, refstring, optsourceresolver.Opt, sm *session.Manager, jobCtxsolver.JobContext) (digest.Digest, []byte,error)

ResolveImageConfig returns image config for an image

func (*Worker)ResolveOp¶

func (w *Worker) ResolveOp(vsolver.Vertex, sfrontend.FrontendLLBBridge, sm *session.Manager) (solver.Op,error)

ResolveOp converts a LLB vertex into a LLB operation

func (*Worker)ResolveSourceMetadata¶

func (w *Worker) ResolveSourceMetadata(ctxcontext.Context, op *pb.SourceOp, optsourceresolver.Opt, sm *session.Manager, jobCtxsolver.JobContext) (*sourceresolver.MetaResponse,error)