Versions in this module Expand all Collapse all v0 v0.3.0 Jul 12, 2023 Changes in this version + var KnownValues = map[state.Argument]func(context.Context, state.Writer) error + func New(ctx context.Context, opts clients.CommonOpts) (pipeline.Client, error) + type Client struct + Log *logrus.Logger + Opts clients.CommonOpts + State *StateWrapper + func (c *Client) Done(ctx context.Context, w *pipeline.Collection) error + func (c *Client) HandleEvents(events []pipeline.Event) error + func (c *Client) HandlePipeline(ctx context.Context, p pipeline.Pipeline) error + func (c *Client) Validate(step pipeline.Step) error + type StateHandler struct + func (n *StateHandler) SetBool(ctx context.Context, arg state.Argument, val bool) error + func (n *StateHandler) SetDirectory(ctx context.Context, arg state.Argument, dir string) error + func (n *StateHandler) SetFile(ctx context.Context, arg state.Argument, path string) error + func (n *StateHandler) SetFileReader(ctx context.Context, arg state.Argument, r io.Reader) (string, error) + func (n *StateHandler) SetFloat64(ctx context.Context, arg state.Argument, val float64) error + func (n *StateHandler) SetInt64(ctx context.Context, arg state.Argument, val int64) error + func (n *StateHandler) SetString(ctx context.Context, arg state.Argument, val string) error + type StateWrapper struct + func NewStateWrapper(r state.Reader, w state.Writer) *StateWrapper + func (w *StateWrapper) Exists(ctx context.Context, arg state.Argument) (bool, error) + func (w *StateWrapper) GetBool(ctx context.Context, arg state.Argument) (bool, error) + func (w *StateWrapper) GetDirectory(ctx context.Context, arg state.Argument) (fs.FS, error) + func (w *StateWrapper) GetDirectoryString(ctx context.Context, arg state.Argument) (string, error) + func (w *StateWrapper) GetFile(ctx context.Context, arg state.Argument) (*os.File, error) + func (w *StateWrapper) GetFloat64(ctx context.Context, arg state.Argument) (float64, error) + func (w *StateWrapper) GetInt64(ctx context.Context, arg state.Argument) (int64, error) + func (w *StateWrapper) GetString(ctx context.Context, arg state.Argument) (string, error) + func (w *StateWrapper) SetBool(ctx context.Context, key state.Argument, val bool) error + func (w *StateWrapper) SetDirectory(ctx context.Context, key state.Argument, val string) error + func (w *StateWrapper) SetFile(ctx context.Context, key state.Argument, val string) error + func (w *StateWrapper) SetFileReader(ctx context.Context, key state.Argument, r io.Reader) (string, error) + func (w *StateWrapper) SetFloat64(ctx context.Context, key state.Argument, val float64) error + func (w *StateWrapper) SetInt64(ctx context.Context, key state.Argument, val int64) error + func (w *StateWrapper) SetString(ctx context.Context, key state.Argument, val string) error