llbsolver

type ExporterRequest ¶

type ExporterRequest struct {
	Exporter       exporter.ExporterInstance
	CacheExporters []RemoteCacheExporter
}

type HistoryQueue ¶ added in v0.11.0

type HistoryQueue struct {
	HistoryQueueOpt
	// contains filtered or unexported fields
}

func NewHistoryQueue(opt HistoryQueueOpt) *HistoryQueue

func (h *HistoryQueue) Listen(ctx context.Context, ref string, active bool, f func(*controlapi.BuildHistoryEvent) error) error

func (h *HistoryQueue) Update(ctx context.Context, e *controlapi.BuildHistoryEvent) error

type HistoryQueueOpt ¶ added in v0.11.0

type HistoryQueueOpt struct {
	DB           *bolt.DB
	LeaseManager leases.Manager
}

type LoadOpt ¶

type LoadOpt func(*pb.Op, *pb.OpMetadata, *solver.VertexOptions) error

func NormalizeRuntimePlatforms() LoadOpt

func ValidateEntitlements(ent entitlements.Set) LoadOpt

func WithCacheSources(cms []solver.CacheManager) LoadOpt

func WithValidateCaps() LoadOpt

type Opt ¶ added in v0.11.0

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
}

Opt defines options for new Solver.

type Processor ¶ added in v0.11.0

type Processor func(ctx context.Context, result *Result, s *Solver, j *solver.Job) (*Result, error)

Processor defines a processing function to be applied after solving, but before exporting

type RemoteCacheExporter ¶ added in v0.11.0

type RemoteCacheExporter struct {
	remotecache.Exporter
	solver.CacheExportMode
}

type ResolveWorkerFunc ¶

type ResolveWorkerFunc func() (worker.Worker, error)

ResolveWorkerFunc returns default worker for the temporary default non-distributed use cases

type Result ¶ added in v0.11.0

type Result struct {
	*frontend.Result
	Provenance *provenance.Result
}

type Solver ¶

type Solver struct {
	// contains filtered or unexported fields
}

func New(opt Opt) (*Solver, error)

func (s *Solver) Bridge(b solver.Builder) frontend.FrontendLLBBridge

func (s *Solver) Solve(ctx context.Context, id string, sessionID string, req frontend.SolveRequest, exp ExporterRequest, ent []entitlements.Entitlement, post []Processor) (_ *client.SolveResponse, err error)

func (s *Solver) Status(ctx context.Context, id string, statusChan chan *client.SolveStatus) error