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 MockService struct {

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

	// Track calls for assertions
	StartCalls                      []context.Context
	StopCalls                       int
	ProcessCalls                    []ProcessCall
	ProcessBoundsOrchestrationCalls []context.Context
	// 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)

	// ProcessBoundsOrchestration handles bounds orchestration for external models
	ProcessBoundsOrchestration(ctx context.Context)
}