Documentation
¶
Overview ¶
Package coordinator handles task coordination and dependency management
Index ¶
Constants ¶
View Source
const ( // DirectionForward processes tasks in forward direction DirectionForward Direction = "forward" // DirectionBack processes tasks in backward direction DirectionBack Direction = "back" // ExternalIncrementalTaskType is the task type for external incremental scan ExternalIncrementalTaskType = "external:incremental" // ExternalFullTaskType is the task type for external full scan ExternalFullTaskType = "external:full" )
Variables ¶
View Source
var ( // ErrShutdownErrors is returned when errors occur during shutdown ErrShutdownErrors = errors.New("errors during shutdown") )
Functions ¶
This section is empty.
Types ¶
type ArchiveHandler ¶ added in v0.0.2
type ArchiveHandler interface {
// Start begins monitoring archived tasks
Start(ctx context.Context) error
// Stop gracefully shuts down the handler
Stop() error
}
ArchiveHandler manages archive monitoring and cleanup
func NewArchiveHandler ¶ added in v0.0.2
func NewArchiveHandler(log logrus.FieldLogger, redisOpt *redis.Options) (ArchiveHandler, error)
NewArchiveHandler creates a new archive handler
type Service ¶
type Service interface {
// Start initializes and starts the coordinator service
Start(ctx context.Context) error
// Stop gracefully shuts down the coordinator service
Stop() error
// Process handles transformation processing in the specified direction
Process(transformation models.Transformation, direction Direction)
// ProcessExternalScan handles external model scan processing
ProcessExternalScan(modelID, scanType string)
}
Service defines the public interface for the coordinator
func NewService ¶
func NewService(log logrus.FieldLogger, redisOpt *redis.Options, dag models.DAGReader, adminService admin.Service, validator validation.Validator) (Service, error)
NewService creates a new coordinator service
Source Files
Click to show internal directories.
Click to hide internal directories.