Documentation
¶
Index ¶
- Variables
- func NewDBFlowManager(db *gorm.DB, logFactory definitions.LoggerFactory) (definitions.FlowManager, error)
- type DBFlowManager
- func (fm *DBFlowManager) AddProcessorToFlowAfter(flowID uuid.UUID, processor *definitions.SimpleProcessor, ...) error
- func (fm *DBFlowManager) AddProcessorToFlowBefore(flowID uuid.UUID, processor *definitions.SimpleProcessor, ...) error
- func (fm *DBFlowManager) GetFirstProcessorsForFlow(flowID uuid.UUID) ([]*definitions.SimpleProcessor, error)
- func (fm *DBFlowManager) GetFlowByID(flowID uuid.UUID) (*definitions.Flow, error)
- func (fm *DBFlowManager) GetFlowProcessors(flowID uuid.UUID) ([]*definitions.SimpleProcessor, error)
- func (fm *DBFlowManager) GetLastProcessorForFlow(flowID uuid.UUID) ([]*definitions.SimpleProcessor, error)
- func (fm *DBFlowManager) GetLastUpdateTime(flowIDs []uuid.UUID) (map[uuid.UUID]time.Time, error)
- func (fm *DBFlowManager) GetProcessorByID(flowID uuid.UUID, processorID uuid.UUID) (*definitions.SimpleProcessor, error)
- func (fm *DBFlowManager) GetProcessors(ids []uuid.UUID) ([]*definitions.SimpleProcessor, error)
- func (fm *DBFlowManager) GetTriggerProcessorsForFlow(flowID uuid.UUID) ([]*definitions.SimpleTriggerProcessor, error)
- func (fm *DBFlowManager) ListFlows(pagination *definitions.PaginationRequest, since time.Time) (*definitions.PaginatedData[*definitions.Flow], error)
- func (fm *DBFlowManager) SaveFlow(flow *definitions.Flow) error
- func (fm *DBFlowManager) SetFlowActive(flowID uuid.UUID, active bool) error
- type UUIDArray
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrFailedToInitializeCache = fmt.Errorf("failed to initialize cache") ErrReferenceProcessorNotFound = fmt.Errorf("reference processor not found") ErrCouldNotRunMigrations = fmt.Errorf("could not run migrations") ErrFailedToGetTotalCount = fmt.Errorf("failed to get total count") ErrFailedToCreateProcessor = fmt.Errorf("failed to create processor") ErrFailedToUpdateReferenceProcessor = fmt.Errorf("failed to update reference processor") ErrProcessorNotFound = fmt.Errorf("processor not found") ErrFailedToConvertProcessors = fmt.Errorf("failed to convert processors") ErrFailedToConvertTriggerProcessors = fmt.Errorf("failed to convert trigger processors") )
Functions ¶
func NewDBFlowManager ¶
func NewDBFlowManager(db *gorm.DB, logFactory definitions.LoggerFactory) (definitions.FlowManager, error)
NewDBFlowManager creates a new instance of DBFlowManager with an in-memory cache for flows.
Types ¶
type DBFlowManager ¶
type DBFlowManager struct {
// contains filtered or unexported fields
}
func (*DBFlowManager) AddProcessorToFlowAfter ¶
func (fm *DBFlowManager) AddProcessorToFlowAfter(flowID uuid.UUID, processor *definitions.SimpleProcessor, referenceProcessorID uuid.UUID) error
AddProcessorToFlowAfter adds a processor to the flow after a reference processor.
func (*DBFlowManager) AddProcessorToFlowBefore ¶
func (fm *DBFlowManager) AddProcessorToFlowBefore(flowID uuid.UUID, processor *definitions.SimpleProcessor, referenceProcessorID uuid.UUID) error
AddProcessorToFlowBefore adds a processor to the flow before a reference processor.
func (*DBFlowManager) GetFirstProcessorsForFlow ¶
func (fm *DBFlowManager) GetFirstProcessorsForFlow(flowID uuid.UUID) ([]*definitions.SimpleProcessor, error)
GetFirstProcessorsForFlow retrieves the first processors in a flow.
func (*DBFlowManager) GetFlowByID ¶
func (fm *DBFlowManager) GetFlowByID(flowID uuid.UUID) (*definitions.Flow, error)
GetFlowByID retrieves a flow by its ID, using cache if available.
func (*DBFlowManager) GetFlowProcessors ¶
func (fm *DBFlowManager) GetFlowProcessors(flowID uuid.UUID) ([]*definitions.SimpleProcessor, error)
func (*DBFlowManager) GetLastProcessorForFlow ¶
func (fm *DBFlowManager) GetLastProcessorForFlow(flowID uuid.UUID) ([]*definitions.SimpleProcessor, error)
GetLastProcessorForFlow retrieves the last processor(s) for a flow (no next processors).
func (*DBFlowManager) GetLastUpdateTime ¶
GetLastUpdateTime retrieves the last update time for the specified flow IDs.
func (*DBFlowManager) GetProcessorByID ¶
func (fm *DBFlowManager) GetProcessorByID(flowID uuid.UUID, processorID uuid.UUID) (*definitions.SimpleProcessor, error)
GetProcessorByID retrieves a processor by its ID within a flow.
func (*DBFlowManager) GetProcessors ¶
func (fm *DBFlowManager) GetProcessors(ids []uuid.UUID) ([]*definitions.SimpleProcessor, error)
func (*DBFlowManager) GetTriggerProcessorsForFlow ¶
func (fm *DBFlowManager) GetTriggerProcessorsForFlow(flowID uuid.UUID) ([]*definitions.SimpleTriggerProcessor, error)
GetTriggerProcessorsForFlow retrieves the trigger processors for a given flow.
func (*DBFlowManager) ListFlows ¶
func (fm *DBFlowManager) ListFlows(pagination *definitions.PaginationRequest, since time.Time) (*definitions.PaginatedData[*definitions.Flow], error)
ListFlows lists all flows with pagination and filters based on the last update time.
func (*DBFlowManager) SaveFlow ¶
func (fm *DBFlowManager) SaveFlow(flow *definitions.Flow) error
SaveFlow saves the flow and its processors to the database.
func (*DBFlowManager) SetFlowActive ¶
func (fm *DBFlowManager) SetFlowActive(flowID uuid.UUID, active bool) error
SetFlowActive sets the active state of a flow.
Source Files
Click to show internal directories.
Click to hide internal directories.