proc

Feb 7, 2023

Changes in this version

+ type CommandExecutor struct

+ func NewCommandExecutor(commands []entity.Command, dir string, logger entity.Logger) *CommandExecutor

+ func (p *CommandExecutor) Exec() error

+ type CommandListExecutor struct

+ func NewCommandListExecutor(executors []entity.Executor) *CommandListExecutor

+ func (e *CommandListExecutor) Exec() error

+ type DryRunCommandExecutor struct

+ func NewDryRunCommandExecutor(commands []entity.Command, dir string, logger entity.Logger) *DryRunCommandExecutor

+ func (p *DryRunCommandExecutor) Exec() error

+ type PipeCommandExecutor struct

+ func NewPipeCommandExecutor(commands []entity.Command, dir string, logger entity.Logger) *PipeCommandExecutor

+ func (p *PipeCommandExecutor) Exec() error

Feb 6, 2023

Changes in this version

type DryRunFileProc

+ func (p *DryRunFileProc) Process(file entity.DataFile) (entity.DataFile, error)

+ type DummyProducer struct

+ func NewDummyProducer(file entity.DataFile) *DummyProducer

+ func (p *DummyProducer) Get() (entity.DataFile, error)

+ type FilesExecutor struct

+ func NewFilesExecutor(producers []entity.FileProducer, processors []entity.FileProc) *FilesExecutor

+ func (e *FilesExecutor) Exec() error

+ type PreloadProducer struct

+ func NewPreloadProducer(producers []entity.FileProducer, logger entity.Logger) *PreloadProducer

+ func (p *PreloadProducer) Get() (entity.DataFile, error)

+ func (p *PreloadProducer) Process() error

+ type PreprocessingChain struct

+ func NewPreprocessingChain(loaders []entity.Preprocessor, processors []entity.Executor) *PreprocessingChain

+ func (c *PreprocessingChain) Exec() error

+ type SaveFileProc struct

+ func NewSaveFileProc(logger entity.Logger) *SaveFileProc

+ func (p *SaveFileProc) Process(file entity.DataFile) (entity.DataFile, error)

+ type TemplateFileProc struct

+ func NewTemplateFileProc(templateData, templateFns map[string]any, templateOptions []string) *TemplateFileProc

+ func (p *TemplateFileProc) Process(file entity.DataFile) (entity.DataFile, error)

Jan 22, 2023

Changes in this version

type Chain

+ func NewProcChain(processors []Proc) *Chain

Jan 19, 2023

Changes in this version

+ type CommandProc struct

+ func NewCommandProc(commands []entity.Command, logger entity.Logger) *CommandProc

+ func (p *CommandProc) Exec() error

+ type DryRunCommandProc struct

+ func NewDryRunCommandProc(commands []entity.Command, logger entity.Logger) *DryRunCommandProc

+ func (p *DryRunCommandProc) Exec() error

+ type DryRunFileProc struct

+ func NewDryRunFileProc(producers []entity.FileProducer, templateData map[string]any, ...) *DryRunFileProc

+ func (p *DryRunFileProc) Exec() error

+ type DryRunMkdirAllProc struct

+ func NewDryRunMkdirAllProc(dirs []string, logger entity.Logger) *DryRunMkdirAllProc

+ func (p *DryRunMkdirAllProc) Exec() error

+ type LocalProducer struct

+ func NewLocalProducer(file entity.LocalFile) *LocalProducer

+ func (p *LocalProducer) Get() (*entity.DataFile, error)

Jan 8, 2023

Changes in this version

+ type Chain struct

+ func NewProcChane(processors []Proc) *Chain

+ func (c *Chain) Exec() error

+ type FileProc struct

+ func NewFileProc(producers []entity.FileProducer, logger entity.Logger) *FileProc

+ func (p *FileProc) Exec() error

+ type MkdirAllProc struct

+ func NewMkdirAllProc(dirs []string, logger entity.Logger) *MkdirAllProc

+ func (p *MkdirAllProc) Exec() error

+ type Proc interface

+ Exec func() error

+ type RemoteProducer struct

+ func NewRemoteProducer(file entity.RemoteFile) *RemoteProducer

+ func (p *RemoteProducer) Get() (*entity.File, error)

+ type RunCommandProc struct

+ func NewRunCommandProc(commands []entity.Command, logger entity.Logger) *RunCommandProc

+ func (p *RunCommandProc) Exec() error

+ type StoredProducer struct

+ func NewStoredProducer(file entity.File) *StoredProducer

+ func (p *StoredProducer) Get() (*entity.File, error)