BaseProcessor represents a basic processor.

EngineFlowObject represents the flow of data through the engine, containing metadata for the processing context.

Flow represents a flow of processors that are executed in a specific order.

LogEntry is a struct that represents a log entry in the write ahead log.

PaginatedData represents a paginated response.

PaginationRequest represents a request for paginated data.

SessionUpdate represents the update status of a session being processed by the engine.

SimpleProcessor represents a processor within a flow.

SimpleTriggerProcessor represents a trigger processor within a flow.

Coordinator defines the interface for assigning leaders nodes for each trigger processor.

EngineFileHandler defines the interface for handling files in the engine's processing flow.

FlowManager defines the interface for managing and interacting with flows and processors within those flows.

LeaderSelector defines the interface for leader election mechanisms.

Processor defines the interface for a processor.

ProcessorFactory defines an interface for retrieving processors and trigger processors.

ProcessorFileHandler defines the interface for handling the current contents.

TriggerProcessor defines the interface for a trigger processor.

WriteAheadLogger is an interface for writing log entries to a file and reading them back.