Documentation
¶
Index ¶
- func AddBuildConfig(ctx context.Context, p *provenancetypes.ProvenancePredicate, ...) (map[digest.Digest]int, error)
- func Load(ctx context.Context, def *pb.Definition, polEngine SourcePolicyEvaluator, ...) (solver.Edge, error)
- type Attestation
- type ExporterRequest
- type HistoryQueue
- func (h *HistoryQueue) AcquireFinalizer(ref string) (<-chan struct{}, func())
- func (h *HistoryQueue) Delete(ctx context.Context, ref string) error
- func (h *HistoryQueue) Finalize(ctx context.Context, ref string) error
- func (h *HistoryQueue) ImportError(ctx context.Context, err error) (_ *rpc.Status, _ *controlapi.Descriptor, _ func(), retErr error)
- func (h *HistoryQueue) ImportStatus(ctx context.Context, ch chan *client.SolveStatus) (_ *StatusImportResult, _ func(), err error)
- func (h *HistoryQueue) Listen(ctx context.Context, req *controlapi.BuildHistoryRequest, ...) error
- func (h *HistoryQueue) OpenBlobWriter(ctx context.Context, mt string) (_ *Writer, err error)
- func (h *HistoryQueue) Status(ctx context.Context, ref string, st chan<- *client.SolveStatus) error
- func (h *HistoryQueue) Update(ctx context.Context, e *controlapi.BuildHistoryEvent) error
- func (h *HistoryQueue) UpdateRef(ctx context.Context, ref string, ...) error
- type HistoryQueueOpt
- type LoadOpt
- type Opt
- type Processor
- type ProvenanceCreator
- type RemoteCacheExporter
- type ResolveWorkerFunc
- type Result
- type Solver
- func (s *Solver) Bridge(b solver.Builder) frontend.FrontendLLBBridge
- func (s *Solver) Close() error
- func (s *Solver) Solve(ctx context.Context, id string, sessionID string, req frontend.SolveRequest, ...) (_ *client.SolveResponse, err error)
- func (s *Solver) Status(ctx context.Context, id string, statusChan chan *client.SolveStatus) error
- type SourcePolicyEvaluator
- type StatusImportResult
- type Writer
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AddBuildConfig ¶
func AddBuildConfig(ctx context.Context, p *provenancetypes.ProvenancePredicate, c *provenance.Capture, rp solver.ResultProxy, withUsage bool) (map[digest.Digest]int, error)
Types ¶
type Attestation ¶
type Attestation = frontend.Attestation
type ExporterRequest ¶
type ExporterRequest struct {
Exporters []exporter.ExporterInstance
CacheExporters []RemoteCacheExporter
}
type HistoryQueue ¶
type HistoryQueue struct {
// contains filtered or unexported fields
}
func NewHistoryQueue ¶
func NewHistoryQueue(opt HistoryQueueOpt) (*HistoryQueue, error)
func (*HistoryQueue) AcquireFinalizer ¶
func (h *HistoryQueue) AcquireFinalizer(ref string) (<-chan struct{}, func())
func (*HistoryQueue) Finalize ¶
func (h *HistoryQueue) Finalize(ctx context.Context, ref string) error
func (*HistoryQueue) ImportError ¶
func (h *HistoryQueue) ImportError(ctx context.Context, err error) (_ *rpc.Status, _ *controlapi.Descriptor, _ func(), retErr error)
func (*HistoryQueue) ImportStatus ¶
func (h *HistoryQueue) ImportStatus(ctx context.Context, ch chan *client.SolveStatus) (_ *StatusImportResult, _ func(), err error)
func (*HistoryQueue) Listen ¶
func (h *HistoryQueue) Listen(ctx context.Context, req *controlapi.BuildHistoryRequest, f func(*controlapi.BuildHistoryEvent) error) error
func (*HistoryQueue) OpenBlobWriter ¶
func (*HistoryQueue) Status ¶
func (h *HistoryQueue) Status(ctx context.Context, ref string, st chan<- *client.SolveStatus) error
func (*HistoryQueue) Update ¶
func (h *HistoryQueue) Update(ctx context.Context, e *controlapi.BuildHistoryEvent) error
func (*HistoryQueue) UpdateRef ¶
func (h *HistoryQueue) UpdateRef(ctx context.Context, ref string, upt func(r *controlapi.BuildHistoryRecord) error) error
type HistoryQueueOpt ¶
type HistoryQueueOpt struct {
DB db.Transactor
LeaseManager *leaseutil.Manager
ContentStore *containerdsnapshot.Store
CleanConfig *config.HistoryConfig
}
type LoadOpt ¶
type LoadOpt func(*pb.Op, *pb.OpMetadata, *solver.VertexOptions) error
func NormalizeRuntimePlatforms ¶
func NormalizeRuntimePlatforms() LoadOpt
func ValidateEntitlements ¶
func ValidateEntitlements(ent entitlements.Set) LoadOpt
func WithCacheSources ¶
func WithCacheSources(cms []solver.CacheManager) LoadOpt
func WithValidateCaps ¶
func WithValidateCaps() LoadOpt
type Opt ¶
type Opt struct {
CacheManager solver.CacheManager
CacheResolvers map[string]remotecache.ResolveCacheImporterFunc
Entitlements []string
Frontends map[string]frontend.Frontend
GatewayForwarder *controlgateway.GatewayForwarder
SessionManager *session.Manager
WorkerController *worker.Controller
HistoryQueue *HistoryQueue
ResourceMonitor *resources.Monitor
}
Opt defines options for new Solver.
type Processor ¶
type Processor func(ctx context.Context, result *Result, s *Solver, j *solver.Job, usage *resources.SysSampler) (*Result, error)
Processor defines a processing function to be applied after solving, but before exporting
type ProvenanceCreator ¶
type ProvenanceCreator struct {
// contains filtered or unexported fields
}
func NewProvenanceCreator ¶
func NewProvenanceCreator(ctx context.Context, cp *provenance.Capture, res solver.ResultProxy, attrs map[string]string, j *solver.Job, usage *resources.SysSampler) (*ProvenanceCreator, error)
func (*ProvenanceCreator) Predicate ¶
func (p *ProvenanceCreator) Predicate() (*provenancetypes.ProvenancePredicate, error)
type RemoteCacheExporter ¶
type RemoteCacheExporter struct {
remotecache.Exporter
solver.CacheExportMode
IgnoreError bool
}
type ResolveWorkerFunc ¶
ResolveWorkerFunc returns default worker for the temporary default non-distributed use cases
type Solver ¶
type Solver struct {
// contains filtered or unexported fields
}
func (*Solver) Solve ¶
func (s *Solver) Solve(ctx context.Context, id string, sessionID string, req frontend.SolveRequest, exp ExporterRequest, ent []entitlements.Entitlement, post []Processor, internal bool, srcPol *spb.Policy) (_ *client.SolveResponse, err error)
type SourcePolicyEvaluator ¶
type StatusImportResult ¶
Source Files
¶
Click to show internal directories.
Click to hide internal directories.