api

Dec 16, 2022

Changes in this version

type DAGNode

+ Name string

+ NodeProcessor NodeProcessor

Dec 12, 2022

Changes in this version

type Thund

+ Start func() error

Dec 12, 2022

Changes in this version

type DAGNode

+ PipelineProcessor PipelineProcessor

Dec 11, 2022

Changes in this version

+ type DAG struct

+ Nodes []DAGNode

+ type DAGNode struct

+ type NodeProcessor interface

+ Process func() error

+ Setup func() error

+ type PipelineProcessor struct

+ IOEventImpl []IOEvent

+ ProcessorImpl NodeProcessor

+ func (fa PipelineProcessor) Process() error

+ func (fa PipelineProcessor) Setup() error

+ type Thund interface

+ Deploy func(DAG) error

Sep 28, 2022

Changes in this version

+ func SortOnAge(fileEntityMap map[string]FileEntity) []string

type FileEntity

+ UnixMilli int64

Jul 23, 2022

Changes in this version

type FileEntity

+ Footer string

+ HasFooter bool

+ HasHeader bool

+ HasLines bool

+ HasSize bool

+ HasSum bool

+ HashName bool

+ Header string

+ Lines int64

+ Sum []byte

Jul 14, 2022

Changes in this version

+ type FileEntity struct

+ Name string

+ Size int64

+ type IOEvent interface

+ Process func(reader io.Reader, customParams interface{}) bool

+ Setup func(customParams interface{}) bool

+ type Processor struct

+ IOEventImpl []IOEvent

+ WatcherImpl Watcher

+ func (fa Processor) Start()

+ type Watcher interface

+ Watch func(event []IOEvent) bool