definitions

package

Go to main page

Versions in this module

v0

v0.1.13

Dec 15, 2024

v0.1.12

Dec 12, 2024

Changes in this version

+ type LoggerFactory interface

+ GetLogger func(name string) *logrus.Logger

v0.1.11

Dec 8, 2024

Changes in this version

type Flow

+ FirstProcessors []*SimpleProcessor

type SimpleProcessor

+ NextProcessors []*SimpleProcessor

v0.1.10

Nov 29, 2024

Changes in this version

+ var ErrInputFileNotInitialized = fmt.Errorf("input file not initialized")

+ var ErrOutputFileNotInitialized = fmt.Errorf("output file not initialized")

v0.1.9

Nov 24, 2024

v0.1.8

Nov 21, 2024

v0.1.7

Nov 21, 2024

v0.1.6

Nov 13, 2024

Changes in this version

type EngineFlowObject

+ TPMark string

type SessionUpdate

+ TPMark string

v0.1.5

Nov 5, 2024

Changes in this version

+ type TriggerProcessorResponse struct

+ EngineFlowObject *EngineFlowObject

+ FileHandler ProcessorFileHandler

v0.1.4

Nov 3, 2024

Changes in this version

+ type BaseProcessorInterface interface

+ Close func() error

+ Name func() string

+ SetConfig func(config map[string]interface{}) error

type TriggerProcessor

+ Execute func(info *EngineFlowObject, fileHandler ProcessorFileHandler, log *logrus.Logger) ([]*EngineFlowObject, error)

v0.1.4-dev

Nov 3, 2024

v0.1.3

Oct 30, 2024

Changes in this version

+ type StateManager interface

+ Close func() error

+ GetState func(stateType StateType) (map[string]any, error)

+ Reset func() error

+ SetState func(stateType StateType, value map[string]any) error

+ WatchState func(state StateType, callback func()) error

+ type StateManagerFactory interface

+ CreateStateManager func(id uuid.UUID) StateManager

+ type StateType string

+ const StateTypeCluster

+ const StateTypeLocal

v0.1.2

Oct 26, 2024

Changes in this version

type SimpleProcessor

+ BackoffSeconds int

v0.1.1

Oct 24, 2024

Changes in this version

+ type Coordinator interface

+ Close func() error

+ IsLeader func(tpID uuid.UUID) (bool, error)

+ type LeaderSelector interface

+ Close func() error

+ IsLeader func() (bool, error)

+ ParticipantName func() string

+ Participants func() ([]string, error)

+ ParticipantsChangeChannel func() <-chan []string

+ Start func() error

type SimpleTriggerProcessor

+ SingleNode bool

v0.1.0

Sep 15, 2024

v0.0.28

Sep 15, 2024

v0.0.27

Sep 13, 2024

v0.0.26

Sep 13, 2024

v0.0.25

Sep 13, 2024

Changes in this version

type Processor

+ Close func() error

v0.0.24

Sep 12, 2024

Changes in this version

type LogEntry

+ IsComplete bool

v0.0.23

Sep 12, 2024

Changes in this version

type BranchTracker

+ AddProcessor func(sessionID uuid.UUID, processorID uuid.UUID, nextProcessorIDs []uuid.UUID)

+ GetCompletedProcessors func(sessionID uuid.UUID) []uuid.UUID

+ IsComplete func(sessionID uuid.UUID) bool

+ MarkComplete func(sessionID uuid.UUID, processorID uuid.UUID) (allComplete bool)

+ RestoreState func(sessionID uuid.UUID, completedProcessorIDs []uuid.UUID)

type FlowManager

+ GetFlowProcessors func(flowID uuid.UUID) ([]SimpleProcessor, error)

+ GetProcessors func(processorIDs []uuid.UUID) ([]SimpleProcessor, error)

type LogEntry

+ CompletedProcessorIDs []uuid.UUID

type WriteAheadLogger

+ ReadLastEntries func() ([]LogEntry, error)

v0.0.22

Sep 7, 2024

Changes in this version

type SimpleProcessor

+ NextProcessorIDs []uuid.UUID

v0.0.21

Sep 4, 2024

Changes in this version

type BranchTracker

+ AddBranch func(sessionID uuid.UUID, processorIDs []uuid.UUID)

+ IsBranchComplete func(sessionID uuid.UUID) bool

+ type BranchTrackerResult struct

+ IsLastInBranch bool

+ ShouldScheduleNext bool

v0.0.20

Sep 4, 2024

Changes in this version

+ type BranchTracker interface

+ AddProcessorsForSession func(sessionID uuid.UUID, processorIDs []uuid.UUID)

+ ClearSession func(sessionID uuid.UUID)

+ HasPendingProcessors func(sessionID uuid.UUID) bool

+ MarkProcessorComplete func(sessionID uuid.UUID, processorID uuid.UUID) (bool, error)

v0.0.19

Sep 4, 2024

Changes in this version

type SimpleProcessor

+ Enabled bool

type SimpleTriggerProcessor

+ Enabled bool

v0.0.18

Sep 3, 2024

v0.0.17

Sep 3, 2024

v0.0.16

Sep 3, 2024

Changes in this version

type ProcessorFactory

+ GetTriggerProcessor func(typeName string) (*TriggerProcessor, error)

v0.0.15

Sep 3, 2024

Changes in this version

type Flow

+ LastUpdated int64

+ TriggerProcessors []SimpleTriggerProcessor

type FlowManager

+ GetTriggerProcessorsForFlow func(flowID uuid.UUID) ([]*SimpleTriggerProcessor, error)

+ type SimpleTriggerProcessor struct

+ Config map[string]interface{}

+ CronExpr string

+ EventName string

+ FlowID uuid.UUID

+ ID uuid.UUID

+ LogLevel logrus.Level

+ Name string

+ ScheduleType ScheduleType

+ Type string

type TriggerProcessor

+ GetScheduleType func() ScheduleType

v0.0.14

Sep 3, 2024

Changes in this version

type TriggerProcessor

+ Close func() error

v0.0.13

Sep 3, 2024

Changes in this version

type Flow

+ Active bool

v0.0.12

Sep 3, 2024

Changes in this version

type FlowManager

+ GetLastUpdateTime func(flowIDs []uuid.UUID) (map[uuid.UUID]time.Time, error)

+ SetFlowActive func(flowID uuid.UUID, active bool) error

v0.0.11

Sep 2, 2024

Changes in this version

type TriggerProcessor

+ HandleSessionUpdate func(update SessionUpdate)

v0.0.10

Sep 2, 2024

Changes in this version

+ type EngineInterface interface

+ SessionUpdates func() <-chan SessionUpdate

+ Submit func(flowID uuid.UUID, metadata map[string]interface{}, reader io.Reader) uuid.UUID

type ProcessorFactory

+ RegisterProcessorWithTypeName func(typeName string, processor Processor)

+ type ScheduleConfig struct

+ CronExpr string

+ Type ScheduleType

+ type ScheduleType int

+ const CronDriven

+ const EventDriven

+ type TriggerProcessor interface

+ GetScheduleConfig func() ScheduleConfig

+ type WriteOnlyFileHandler interface

+ Write func() (io.Writer, error)

v0.0.9

Aug 30, 2024

v0.0.8

Aug 30, 2024

Changes in this version

+ type PaginatedData struct

+ Data []T

+ TotalCount int

+ type PaginationRequest struct

+ Page int

+ PerPage int

+ func (r *PaginationRequest) Limit() int

+ func (r *PaginationRequest) Offset() int

v0.0.7

Aug 30, 2024

v0.0.6

Aug 30, 2024

Changes in this version

+ type Flow struct

+ Description string

+ ID uuid.UUID

+ Name string

+ Processors []SimpleProcessor

type FlowManager

+ SaveFlow func(flow *Flow) error

type SimpleProcessor

+ FlowID uuid.UUID

+ FlowOrder int

v0.0.5

Aug 30, 2024

Changes in this version

type FlowManager

+ GetInitialProcessors func(flowID uuid.UUID) ([]*SimpleProcessor, error)

+ SaveFlowState func(flow *SimpleFlow) error

+ type SimpleFlow struct

+ ID uuid.UUID

+ Name string

+ Processors []*SimpleProcessor

+ type SimpleProcessor struct

+ Config map[string]interface{}

+ ID uuid.UUID

+ LogLevel logrus.Level

+ MaxRetries int

+ Name string

+ Next []*SimpleProcessor

+ Type string

v0.0.4

Aug 30, 2024

Changes in this version

type FlowManager

+ AddProcessorToFlowAfter func(flowID uuid.UUID, processor *models.Processor, referenceProcessorID uuid.UUID) error

+ AddProcessorToFlowBefore func(flowID uuid.UUID, processor *models.Processor, referenceProcessorID uuid.UUID) error

v0.0.3

Aug 30, 2024

v0.0.2

Aug 30, 2024

Changes in this version

+ type LogEntry struct

+ FlowID uuid.UUID

+ FlowObject definitions.EngineFlowObject

+ InputFile string

+ OutputFile string

+ ProcessorID string

+ ProcessorName string

+ RetryCount int

+ SessionID uuid.UUID

+ type WriteAheadLogger interface

+ ReadEntries func() ([]LogEntry, error)

+ WriteEntry func(entry LogEntry)

v0.0.1

Aug 30, 2024

Changes in this version

+ type BaseProcessor struct

+ ID string

+ func (b *BaseProcessor) DecodeMap(input interface{}, output interface{}) error

+ func (b *BaseProcessor) GetID() string

+ type EngineFileHandler interface

+ Close func()

+ GenerateNewFileHandler func() (EngineFileHandler, error)

+ GetInputFile func() string

+ GetOutputFile func() string

+ type EngineFlowObject struct

+ Metadata map[string]interface{}

+ func (e *EngineFlowObject) EvaluateExpression(input string) (string, error)

+ type EngineIncomingObject struct

+ FlowID uuid.UUID

+ Metadata map[string]interface{}

+ Reader io.Reader

+ SessionID uuid.UUID

+ type FlowManager interface

+ AddProcessorToFlow func(flowID uuid.UUID, processor *models.Processor, position string, ...) error

+ GetFirstProcessorsForFlow func(flowID uuid.UUID) ([]models.Processor, error)

+ GetFlowByID func(flowID uuid.UUID) (*models.Flow, error)

+ GetLastProcessorForFlow func(flowID uuid.UUID) (*models.Processor, error)

+ GetNextProcessors func(flowID uuid.UUID, processorID uuid.UUID) ([]models.Processor, error)

+ GetProcessorByID func(flowID uuid.UUID, processorID uuid.UUID) (*models.Processor, error)

+ ListFlows func() ([]models.Flow, error)

+ ListProcessorsForFlow func(flowID uuid.UUID) ([]models.Processor, error)

+ type Processor interface

+ Execute func(info *EngineFlowObject, fileHandler ProcessorFileHandler, log *logrus.Logger) (*EngineFlowObject, error)

+ GetID func() string

+ Name func() string

+ SetConfig func(config map[string]interface{}) error

+ type ProcessorFactory interface

+ GetProcessor func(typeName string) (Processor, error)

+ RegisterProcessor func(processor Processor)

+ type ProcessorFileHandler interface

+ Read func() (io.Reader, error)

+ Write func() (io.Writer, error)

+ type SessionUpdate struct

+ Error error

+ Finished bool

+ SessionID uuid.UUID

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL