ops

Documentation

Index

• func NewDiffOp(v solver.Vertex, op *pb.Op_Diff, w worker.Worker) (solver.Op, error)
• func NewFileOp(v solver.Vertex, op *pb.Op_File, cm cache.Manager, ...) (solver.Op, error)
• func NewMergeOp(v solver.Vertex, op *pb.Op_Merge, w worker.Worker) (solver.Op, error)
• type BuildOp
  • func NewBuildOp(v solver.Vertex, op *pb.Op_Build, b frontend.FrontendLLBBridge, ...) (*BuildOp, error)
  • func (b *BuildOp) Acquire(ctx context.Context) (solver.ReleaseFunc, error)
  • func (b *BuildOp) CacheMap(ctx context.Context, g session.Group, index int) (*solver.CacheMap, bool, error)
  • func (b *BuildOp) Exec(ctx context.Context, g session.Group, inputs []solver.Result) (outputs []solver.Result, retErr error)
  • func (b *BuildOp) IsProvenanceProvider()
• type ExecOp
  • func NewExecOp(v solver.Vertex, op *pb.Op_Exec, platform *pb.Platform, cm cache.Manager, ...) (*ExecOp, error)
  • func (e *ExecOp) Acquire(ctx context.Context) (solver.ReleaseFunc, error)
  • func (e *ExecOp) CacheMap(ctx context.Context, g session.Group, index int) (*solver.CacheMap, bool, error)
  • func (e *ExecOp) Exec(ctx context.Context, g session.Group, inputs []solver.Result) (results []solver.Result, err error)
  • func (e *ExecOp) IsProvenanceProvider()
  • func (e *ExecOp) Proto() *pb.ExecOp
• type FileOpSolver
  • func NewFileOpSolver(w worker.Worker, b fileoptypes.Backend, r fileoptypes.RefManager) *FileOpSolver
  • func (s *FileOpSolver) Solve(ctx context.Context, inputs []fileoptypes.Ref, actions []*pb.FileAction, ...) ([]fileoptypes.Ref, error)
• type SourceOp
  • func NewSourceOp(vtx solver.Vertex, op *pb.Op_Source, platform *pb.Platform, sm *source.Manager, ...) (*SourceOp, error)
  • func (s *SourceOp) Acquire(ctx context.Context) (solver.ReleaseFunc, error)
  • func (s *SourceOp) CacheMap(ctx context.Context, g session.Group, index int) (*solver.CacheMap, bool, error)
  • func (s *SourceOp) Exec(ctx context.Context, g session.Group, _ []solver.Result) (outputs []solver.Result, err error)
  • func (s *SourceOp) IsProvenanceProvider()
  • func (s *SourceOp) Pin() (source.Identifier, string)

Functions

func NewDiffOp

func NewDiffOp(v solver.Vertex, op *pb.Op_Diff, w worker.Worker) (solver.Op, error)

func NewFileOp

func NewFileOp(v solver.Vertex, op *pb.Op_File, cm cache.Manager, parallelism *semaphore.Weighted, w worker.Worker) (solver.Op, error)

func NewMergeOp

func NewMergeOp(v solver.Vertex, op *pb.Op_Merge, w worker.Worker) (solver.Op, error)

Types

type BuildOp

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

func NewBuildOp

func NewBuildOp(v solver.Vertex, op *pb.Op_Build, b frontend.FrontendLLBBridge, _ worker.Worker) (*BuildOp, error)

func (*BuildOp) Acquire

func (b *BuildOp) Acquire(ctx context.Context) (solver.ReleaseFunc, error)

func (*BuildOp) CacheMap

func (b *BuildOp) CacheMap(ctx context.Context, g session.Group, index int) (*solver.CacheMap, bool, error)

func (*BuildOp) Exec

func (b *BuildOp) Exec(ctx context.Context, g session.Group, inputs []solver.Result) (outputs []solver.Result, retErr error)

func (*BuildOp) IsProvenanceProvider

func (b *BuildOp) IsProvenanceProvider()

type ExecOp

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

func NewExecOp

func NewExecOp(v solver.Vertex, op *pb.Op_Exec, platform *pb.Platform, cm cache.Manager, parallelism *semaphore.Weighted, sm *session.Manager, exec executor.Executor, w worker.Worker) (*ExecOp, error)

func (*ExecOp) Acquire

func (e *ExecOp) Acquire(ctx context.Context) (solver.ReleaseFunc, error)

func (*ExecOp) CacheMap

func (e *ExecOp) CacheMap(ctx context.Context, g session.Group, index int) (*solver.CacheMap, bool, error)

func (*ExecOp) Exec

func (e *ExecOp) Exec(ctx context.Context, g session.Group, inputs []solver.Result) (results []solver.Result, err error)

func (*ExecOp) IsProvenanceProvider

func (e *ExecOp) IsProvenanceProvider()

func (*ExecOp) Proto

func (e *ExecOp) Proto() *pb.ExecOp

type FileOpSolver

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

func NewFileOpSolver

func NewFileOpSolver(w worker.Worker, b fileoptypes.Backend, r fileoptypes.RefManager) *FileOpSolver

func (*FileOpSolver) Solve

func (s *FileOpSolver) Solve(ctx context.Context, inputs []fileoptypes.Ref, actions []*pb.FileAction, g session.Group) ([]fileoptypes.Ref, error)

type SourceOp

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

func NewSourceOp

func NewSourceOp(vtx solver.Vertex, op *pb.Op_Source, platform *pb.Platform, sm *source.Manager, parallelism *semaphore.Weighted, sessM *session.Manager, w worker.Worker) (*SourceOp, error)

func (*SourceOp) Acquire

func (s *SourceOp) Acquire(ctx context.Context) (solver.ReleaseFunc, error)

func (*SourceOp) CacheMap

func (s *SourceOp) CacheMap(ctx context.Context, g session.Group, index int) (*solver.CacheMap, bool, error)

func (*SourceOp) Exec

func (s *SourceOp) Exec(ctx context.Context, g session.Group, _ []solver.Result) (outputs []solver.Result, err error)

func (*SourceOp) IsProvenanceProvider

func (s *SourceOp) IsProvenanceProvider()

func (*SourceOp) Pin

func (s *SourceOp) Pin() (source.Identifier, string)