Documentation
¶
Index ¶
- func ID(root string) (string, error)
- type Worker
- func (w *Worker) BuildkitVersion() client.BuildkitVersion
- func (w *Worker) CDIManager() *cdidevices.Manager
- 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) (ref cache.ImmutableRef, err error)
- func (w *Worker) GCPolicy() []client.PruneInfo
- func (w *Worker) GarbageCollect(ctx context.Context) 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) ParseSource(op *pb.SourceOp, platform *pb.Platform) (source.Identifier, error)
- func (w *Worker) Platforms(noCache bool) []ocispecs.Platform
- func (w *Worker) Prune(ctx context.Context, ch chan client.UsageInfo, opt ...client.PruneInfo) error
- func (w *Worker) PruneCacheMounts(ctx context.Context, ids map[string]bool) 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)
- type WorkerOpt
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Worker ¶
type Worker struct {
WorkerOpt
CacheMgr cache.Manager
SourceManager *source.Manager
ImageSource *containerimage.Source
OCILayoutSource *containerimage.Source
GitSource *git.Source
HTTPSource *http.Source
// contains filtered or unexported fields
}
Worker is a local worker instance with dedicated snapshotter, cache, and so on. TODO: s/Worker/OpWorker/g ?
func (*Worker) BuildkitVersion ¶ added in v0.11.0
func (w *Worker) BuildkitVersion() client.BuildkitVersion
func (*Worker) CDIManager ¶ added in v0.20.0
func (w *Worker) CDIManager() *cdidevices.Manager
func (*Worker) CacheManager ¶
func (*Worker) ContentStore ¶ added in v0.7.0
func (w *Worker) ContentStore() *containerdsnapshot.Store
func (*Worker) FromRemote ¶
func (*Worker) GarbageCollect ¶ added in v0.18.0
func (*Worker) LeaseManager ¶ added in v0.11.0
func (*Worker) ParseSource ¶ added in v0.32.0
func (*Worker) PruneCacheMounts ¶ added in v0.6.0
func (*Worker) ResolveSourceMetadata ¶ added in v0.13.0
func (w *Worker) ResolveSourceMetadata(ctx context.Context, op *pb.SourceOp, opt sourceresolver.Opt, sm *session.Manager, jobCtx solver.JobContext) (*sourceresolver.MetaResponse, error)
type WorkerOpt ¶
type WorkerOpt struct {
ID string
Root string
Labels map[string]string
Platforms []ocispecs.Platform
GCPolicy []client.PruneInfo
BuildkitVersion client.BuildkitVersion
NetworkProviders map[pb.NetMode]network.Provider
ProxyProvider network.ProxyProvider
Executor executor.Executor
Snapshotter snapshot.Snapshotter
ContentStore *containerdsnapshot.Store
Applier diff.Applier
Differ diff.Comparer
ImageStore images.Store // optional
RegistryHosts docker.RegistryHosts
IdentityMapping *user.IdentityMapping
LeaseManager *leaseutil.Manager
GarbageCollect func(context.Context) (gc.Stats, error)
ParallelismSem *semaphore.Weighted
MetadataStore *metadata.Store
ContentMetadata io.Closer
MountPoolRoot string
ResourceMonitor *resources.Monitor
CDIManager *cdidevices.Manager
}
WorkerOpt is specific to a worker. See also CommonOpt.
Source Files
Click to show internal directories.
Click to hide internal directories.