coordinator

type ArchiveHandler interface {
	// Start begins monitoring archived tasks
	Start(ctx context.Context) error
	// Stop gracefully shuts down the handler
	Stop() error
}

type Direction string

type ExternalScanCall struct {
	ModelID  string
	ScanType string
}

type MockService struct {

	// Control behavior
	StartFunc               func(ctx context.Context) error
	StopFunc                func() error
	ProcessFunc             func(transformation models.Transformation, direction Direction)
	ProcessExternalScanFunc func(modelID, scanType string)

	// Track calls for assertions
	StartCalls               []context.Context
	StopCalls                int
	ProcessCalls             []ProcessCall
	ProcessExternalScanCalls []ExternalScanCall
	// contains filtered or unexported fields
}

type ProcessCall struct {
	Transformation models.Transformation
	Direction      Direction
}

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)
}