Versions in this module Expand all Collapse all v1 v1.5.1 May 14, 2026 v1.5.0 May 13, 2026 Changes in this version + type Config struct + DefaultQueueTimeout time.Duration + ExecutorConfig executor.ExecutorConfig + InventoryStore inventorystore.Store + MaxWaitingTasksPerRack int + PromoterConfig conflict.PromoterConfig + TaskStore taskstore.Store + func (c *Config) Validate() error + type Manager interface + CancelTask func(ctx context.Context, taskID uuid.UUID) error + Start func(ctx context.Context) error + Stop func(ctx context.Context) + SubmitTask func(ctx context.Context, req *operation.Request) ([]uuid.UUID, error) + type ManagerImpl struct + func New(ctx context.Context, conf *Config) (*ManagerImpl, error) + func (m *ManagerImpl) CancelTask(ctx context.Context, taskID uuid.UUID) error + func (m *ManagerImpl) Start(ctx context.Context) error + func (m *ManagerImpl) Stop(ctx context.Context) + func (m *ManagerImpl) SubmitTask(ctx context.Context, req *operation.Request) ([]uuid.UUID, error) + type TargetFetcher interface + GetComponentByID func(ctx context.Context, id uuid.UUID) (*component.Component, error) + GetComponentsByExternalIDs func(ctx context.Context, externalIDs []string) ([]*component.Component, error) + GetRackByIdentifier func(ctx context.Context, identifier identifier.Identifier, withComponents bool) (*rack.Rack, error)
Go to main page