Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrNoOptimisticSlots = fmt.Errorf("no optimistic slots for scheduling")
View Source
var ErrTenantNotFound = fmt.Errorf("tenant not found in pool")
Sentinel errors returned from optimistic scheduling. Defined here (rather than per implementation) so errors.Is checks in the engine match whichever scheduler implementation a shard runs.
Functions ¶
This section is empty.
Types ¶
type AssignedItemWithTask ¶ added in v0.101.5
type AssignedItemWithTask struct {
AssignedItem *v1.AssignedItem
Task *v1.V1TaskWithPayload
}
AssignedItemWithTask pairs an optimistic scheduling assignment with its task.
type ConcurrencyResults ¶ added in v0.101.5
type ConcurrencyResults struct {
*v1.RunConcurrencyResult
TenantId uuid.UUID
}
ConcurrencyResults is the result set a concurrency strategy emits after a run.
type Pool ¶ added in v0.101.5
type Pool interface {
GetResultsCh() chan *QueueResults
GetConcurrencyResultsCh() chan *ConcurrencyResults
SetTenants(tenants []*sqlcv1.Tenant)
Replenish(ctx context.Context, tenantId uuid.UUID)
NotifyQueues(ctx context.Context, tenantId uuid.UUID, queueNames []string)
NotifyConcurrency(ctx context.Context, tenantId uuid.UUID, strategyIds []int64)
NotifyNewWorker(ctx context.Context, tenantId uuid.UUID, workerId uuid.UUID)
NotifyNewQueue(ctx context.Context, tenantId uuid.UUID, queueName string)
NotifyNewConcurrencyStrategy(ctx context.Context, tenantId uuid.UUID, strategyId int64)
RunOptimisticScheduling(ctx context.Context, tenantId uuid.UUID, opts []*v1.WorkflowNameTriggerOpts, localWorkerIds map[uuid.UUID]struct{}) (map[uuid.UUID][]*AssignedItemWithTask, []*v1.V1TaskWithPayload, []*v1.DAGWithData, []v1.IdempotencyCollision, error)
RunOptimisticSchedulingFromEvents(ctx context.Context, tenantId uuid.UUID, opts []v1.EventTriggerOpts, localWorkerIds map[uuid.UUID]struct{}) (map[uuid.UUID][]*AssignedItemWithTask, *v1.TriggerFromEventsResult, error)
}
Pool is the engine-facing surface of a tenant scheduling pool. It is implemented by both scheduling/v1 and scheduling/v1alpha, so a shard can select the scheduler implementation with a feature flag at startup.
type QueueResults ¶ added in v0.101.5
type QueueResults struct {
TenantId uuid.UUID
Assigned []*v1.AssignedItem
Buffered []*v1.AssignedItem
Unassigned []*sqlcv1.V1QueueItem
SchedulingTimedOut []*sqlcv1.V1QueueItem
RateLimited []*v1.RateLimitResult
}
QueueResults is the result set a queuer emits after flushing a batch of scheduling decisions to the database.
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.