Documentation
¶
Index ¶
- Variables
- func NewDefaultFlowManager(db *gorm.DB, workDir string) (definitions.FlowManager, error)
- type DefaultFlowManager
- func (fm *DefaultFlowManager) AddProcessorToFlow(flowID uuid.UUID, processor *models.Processor, position string, ...) error
- func (fm *DefaultFlowManager) GetFirstProcessorsForFlow(flowID uuid.UUID) ([]models.Processor, error)
- func (fm *DefaultFlowManager) GetFlowByID(flowID uuid.UUID) (*models.Flow, error)
- func (fm *DefaultFlowManager) GetLastProcessorForFlow(flowID uuid.UUID) (*models.Processor, error)
- func (fm *DefaultFlowManager) GetNextProcessors(flowID uuid.UUID, processorID uuid.UUID) ([]models.Processor, error)
- func (fm *DefaultFlowManager) GetProcessorByID(flowID uuid.UUID, processorID uuid.UUID) (*models.Processor, error)
- func (fm *DefaultFlowManager) ListFlows() ([]models.Flow, error)
- func (fm *DefaultFlowManager) ListProcessorsForFlow(flowID uuid.UUID) ([]models.Processor, error)
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrCouldNotGetDBConnection = fmt.Errorf("could not get db connection")
View Source
var ErrCouldNotRunMigrations = fmt.Errorf("could not run migrations")
Functions ¶
func NewDefaultFlowManager ¶
func NewDefaultFlowManager(db *gorm.DB, workDir string) (definitions.FlowManager, error)
Types ¶
type DefaultFlowManager ¶
type DefaultFlowManager struct {
// contains filtered or unexported fields
}
func (*DefaultFlowManager) AddProcessorToFlow ¶
func (fm *DefaultFlowManager) AddProcessorToFlow(flowID uuid.UUID, processor *models.Processor, position string, referenceProcessorID uuid.UUID) error
AddProcessorToFlow adds a processor to a flow. It can insert before or after a specified processor.
func (*DefaultFlowManager) GetFirstProcessorsForFlow ¶
func (*DefaultFlowManager) GetFlowByID ¶
func (*DefaultFlowManager) GetLastProcessorForFlow ¶
GetLastProcessorForFlow returns the last processor executed in a given flow.
func (*DefaultFlowManager) GetNextProcessors ¶
func (*DefaultFlowManager) GetProcessorByID ¶
func (*DefaultFlowManager) ListFlows ¶
func (fm *DefaultFlowManager) ListFlows() ([]models.Flow, error)
func (*DefaultFlowManager) ListProcessorsForFlow ¶
Source Files
Click to show internal directories.
Click to hide internal directories.