Versions in this module Expand all Collapse all v0 v0.3.0 Jul 12, 2023 Changes in this version + func CompilePipeline(ctx context.Context, d *dagger.Client, name, src, gomod, pipeline string) (*dagger.Directory, error) + func New(ctx context.Context, opts clients.CommonOpts) (pipeline.Client, error) + type Client struct + Log *logrus.Logger + Opts clients.CommonOpts + State *state.Observer + func (c *Client) Done(ctx context.Context, w *pipeline.Collection) error + func (c *Client) HandleRequiredArgs(ctx context.Context, d *dagger.Client, container *dagger.Container, ...) (*dagger.Container, map[string]string, error) + func (c *Client) HandleStep(ctx context.Context, step pipeline.Step, d *dagger.Client, ...) error + func (c *Client) PipelineWalkFunc(w *pipeline.Collection, wg *syncutil.WaitGroup, bin, src *dagger.Directory, ...) pipeline.PipelineWalkFunc + func (c *Client) StepWalkFunc(d *dagger.Client, wg *syncutil.WaitGroup, bin *dagger.Directory, ...) pipeline.StepWalkFunc + func (c *Client) Validate(step pipeline.Step) error + func (c *Client) WaitForArgs(ctx context.Context, log logrus.FieldLogger, args state.Arguments)