scheduleringester

type Configuration struct {
	// Database configuration
	Postgres configuration.PostgresConfig
	// Metrics configuration
	Metrics configuration.MetricsConfig
	// General Pulsar configuration
	Pulsar configuration.PulsarConfig
	// Map of allowed priority classes by name
	PriorityClasses map[string]types.PriorityClass
	// Pulsar subscription name
	SubscriptionName string
	// Number of messages that will be batched together before being inserted into the database
	BatchSize int
	// Maximum time since the last batch before a batch will be inserted into the database
	BatchDuration time.Duration
	// Time for which the pulsar consumer will wait for a new message before retrying
	PulsarReceiveTimeout time.Duration
	// Time for which the pulsar consumer will back off after receiving an error on trying to receive a message
	PulsarBackoffTime time.Duration
}

type DbOperation interface {
	// a.Merge(b) attempts to merge b into a, creating a single combined op.
	// Returns true if merging was successful.
	// If successful, modifies a in-place.
	// If not successful, neither op is mutated.
	Merge(DbOperation) bool
	// a.CanBeAppliedBefore(b) returns true if a can be placed before b
	// without changing the end result of the overall set of operations.
	CanBeAppliedBefore(DbOperation) bool
}

type DbOperationsWithMessageIds struct {
	Ops        []DbOperation
	MessageIds []pulsar.MessageID
}

type InsertJobRunErrors map[uuid.UUID]*schedulerdb.JobRunError

type InsertJobs map[string]*schedulerdb.Job

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

type InsertRuns map[uuid.UUID]*JobRunDetails

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

type JobQueuedStateUpdate struct {
	Queued             bool
	QueuedStateVersion int32
}

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

type JobRunFailed struct {
	LeaseReturned bool
	RunAttempted  bool
}

type JobSchedulingInfoUpdate struct {
	JobSchedulingInfo        []byte
	JobSchedulingInfoVersion int32
}

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

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

type JobSetOperation interface {
	AffectsJobSet(queue string, jobSet string) bool
}

type MarkJobSetsCancelRequested map[JobSetKey]*JobSetCancelAction

type MarkJobsCancelRequested map[string]bool

type MarkJobsCancelled map[string]bool

type MarkJobsFailed map[string]bool

type MarkJobsSucceeded map[string]bool

type MarkRunsFailed map[uuid.UUID]*JobRunFailed

type MarkRunsRunning map[uuid.UUID]bool

type MarkRunsSucceeded map[uuid.UUID]bool

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

type UpdateJobPriorities map[string]int64

type UpdateJobQueuedState map[string]*JobQueuedStateUpdate

type UpdateJobSchedulingInfo map[string]*JobSchedulingInfoUpdate

type UpdateJobSetPriorities map[JobSetKey]int64