v1

type AssignedItemWithTask struct {
	AssignedItem *v1.AssignedItem
	Task         *v1.V1TaskWithPayload
}

type ConcurrencyManager struct {
	// contains filtered or unexported fields
}

type ConcurrencyResults struct {
	*v1.RunConcurrencyResult

	TenantId uuid.UUID
}

type Extensions struct {
	// contains filtered or unexported fields
}

type LeaseManager struct {
	// contains filtered or unexported fields
}

type PostAssignInput struct {
	HasUnassignedStepRuns bool
}

type PrometheusExtension struct {
	// contains filtered or unexported fields
}

type QueueResults struct {
	TenantId uuid.UUID
	Assigned []*v1.AssignedItem

	Unassigned         []*sqlcv1.V1QueueItem
	SchedulingTimedOut []*sqlcv1.V1QueueItem
	RateLimited        []*v1.RateLimitResult
}

type Queuer struct {
	// contains filtered or unexported fields
}

type Scheduler struct {
	// contains filtered or unexported fields
}

type SchedulerExtension interface {
	SetTenants(tenants []*sqlcv1.Tenant)
	ReportSnapshot(tenantId uuid.UUID, input *SnapshotInput)
	PostAssign(tenantId uuid.UUID, input *PostAssignInput)
	Cleanup() error
}

type SchedulingPool struct {
	Extensions *Extensions
	// contains filtered or unexported fields
}

type SlotCp struct {
	WorkerId uuid.UUID
	Used     bool
}

type SlotUtilization struct {
	UtilizedSlots    int
	NonUtilizedSlots int
}

type SnapshotInput struct {
	Workers               map[uuid.UUID]*WorkerCp
	WorkerSlotUtilization map[uuid.UUID]*SlotUtilization
}

type WorkerCp struct {
	WorkerId uuid.UUID
	MaxRuns  int
	Labels   []*sqlcv1.ListManyWorkerLabelsRow
	Name     string
}

type WorkerPromLabels struct {
	ID   uuid.UUID
	Name string
}