v2

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

type ConcurrencyResults struct {
	*v1.RunConcurrencyResult

	TenantId pgtype.UUID
}

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

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

type PostAssignInput struct {
	HasUnassignedStepRuns bool
}

type QueueResults struct {
	TenantId pgtype.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 []*dbsqlc.Tenant)
	ReportSnapshot(tenantId string, input *SnapshotInput)
	PostAssign(tenantId string, input *PostAssignInput)
	Cleanup() error
}

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

type SlotCp struct {
	WorkerId string
	Used     bool
}

type SlotUtilization struct {
	UtilizedSlots    int
	NonUtilizedSlots int
}

type SnapshotInput struct {
	Workers               map[string]*WorkerCp
	WorkerSlotUtilization map[string]*SlotUtilization
}

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