pipeline

Mar 26, 2024

Changes in this version

+ const StateCreated

+ const StateRunning

+ const StateStarting

+ const StateStopped

+ const StateStopping

+ var ConflictErr *ConflictError

+ var IOErr *IOError

+ var NotFoundErr *NotFoundError

+ var ValidationErr *ValidationError

+ type ConflictError struct

+ Err error

+ func (e *ConflictError) Error() string

+ func (e *ConflictError) Unwrap() error

+ type IOError struct

+ Err error

+ func (e *IOError) Error() string

+ func (e *IOError) Unwrap() error

+ type NotFoundError struct

+ Err error

+ func (e *NotFoundError) Error() string

+ func (e *NotFoundError) Unwrap() error

+ type Pipeline struct

+ func New(config *config.Pipeline, log *slog.Logger) *Pipeline

+ func (p *Pipeline) Build() error

+ func (p *Pipeline) Close() error

+ func (p *Pipeline) Config() *config.Pipeline

+ func (p *Pipeline) LastError() error

+ func (p *Pipeline) Run(ctx context.Context)

+ func (p *Pipeline) State() state

+ func (p *Pipeline) Test() error

+ type Service interface

+ Add func(pipe *config.Pipeline) error

+ Delete func(id string) error

+ Get func(id string) (*config.Pipeline, error)

+ List func() ([]*config.Pipeline, error)

+ Start func(id string) error

+ State func(id string) (string, error, error)

+ Stop func(id string) error

+ Update func(pipe *config.Pipeline) error

+ type Storage interface

+ Add func(pipe *config.Pipeline) error

+ Delete func(id string) error

+ Get func(id string) (*config.Pipeline, error)

+ List func() ([]*config.Pipeline, error)

+ Update func(pipe *config.Pipeline) error

+ type ValidationError struct

+ Err error

+ func (e *ValidationError) Error() string

+ func (e *ValidationError) Unwrap() error