pipeline

Documentation

Index

• type API
  • func New(cfgs ...Configuration) (API, error)
• type Configuration
  • func WithSQLiteRepository(r pipeline.Repository) Configuration

Types

type API

type API interface {
	CreatePipelineFromFile(context.Context, string) (uuid.UUID, error)
	CreatePipeline(context.Context, valueobjects.Definition) (uuid.UUID, error)
	Schedule(pipelineID uuid.UUID) error
}

func New

func New(cfgs ...Configuration) (API, error)

type Configuration

type Configuration func(*service) error

func WithSQLiteRepository

func WithSQLiteRepository(r pipeline.Repository) Configuration