workers

type BackgroundParser struct {
	webFramework.FakeParser
	// contains filtered or unexported fields
}

type Config struct {
	// WorkerCount is the number of goroutines processing jobs.
	// Default: runtime.NumCPU().
	WorkerCount int

	// QueueSize is the buffered channel capacity.
	// Default: 100.
	QueueSize int

	// BlockOnFull determines whether Submit blocks when the queue is full
	// (true) or returns ErrQueueFull immediately (false).
	// Default: false.
	BlockOnFull bool

	// Clock is the clock source for deterministic testing.
	// If nil, time.Now is used.
	Clock func() time.Time

	// JitterSource is the jitter source for deterministic testing.
	// If nil, a package-level locked random source is used.
	JitterSource func(max int64) int64
}

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

type Job struct {
	// Name identifies the job for logging and tracing.
	Name string

	// Handler is the function to execute.
	Handler JobHandler

	// Options configures retry, backoff, and tracing.
	Options JobOptions
}

type JobContext struct {
	// Context carries cancellation and tracing.
	Context context.Context

	// WebFramework is a job-owned root webFramework.WebFramework with a
	// BackgroundParser that supports webFramework.AddLog calls. This
	// ensures that external API calls and critical business events
	// within jobs are logged to the Splunk transaction pipeline.
	WebFramework webFramework.WebFramework

	// JobName is the name of the job.
	JobName string

	// Attempt is the current attempt number (1-based).
	Attempt int

	// Attributes are tracing attributes for the job.
	Attributes map[string]string
	// contains filtered or unexported fields
}

type JobHandler func(*JobContext) error

type JobOptions struct {
	// MaxAttempts is the maximum number of execution attempts (including the first).
	// Default: 1 (no retry).
	MaxAttempts int

	// InitialBackoff is the delay before the first retry.
	// Default: 100ms.
	InitialBackoff time.Duration

	// MaxBackoff is the maximum delay between retries.
	// Default: 5s.
	MaxBackoff time.Duration

	// Jitter adds randomness to backoff to prevent thundering herd.
	// Default: true.
	Jitter bool

	// Attributes are tracing attributes for the job span.
	Attributes map[string]string

	// OnFailure is called when all attempts are exhausted.
	// It receives the final error and the total number of attempts.
	OnFailure func(err error, attempts int)

	// PropagateCancel, when true, makes the job context derive from
	// the submit context so cancellation propagates. When false
	// (default), the job context uses context.WithoutCancel so
	// the job outlives the request.
	PropagateCancel bool
}

type ScheduledJob struct {
	// Name identifies the job for logging and tracing.
	Name string

	// Handler is the function executed on each tick.
	Handler JobHandler

	// Interval is the time between successive ticks.
	// Must be > 0.
	Interval time.Duration

	// Options configures retry, backoff, and tracing for each tick.
	// Retry applies within a single tick: if the handler returns an
	// error, it is retried up to MaxAttempts with backoff before
	// the next tick interval begins.
	Options JobOptions
}

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

type SchedulerStats struct {
	Ticks     int64
	Succeeded int64
	Failed    int64
	LastRun   time.Time
	LastErr   string
	InFlight  bool
	NextRun   time.Time
}

type Stats struct {
	Submitted  int64
	Succeeded  int64
	Failed     int64
	InFlight   int64
	QueueDepth int
	Workers    int
}

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

type Worker interface {
	// Submit enqueues a job for asynchronous execution.
	// Returns an error if the queue is full or the worker is shutting down.
	Submit(ctx context.Context, job Job) error

	// Shutdown stops accepting new jobs, drains the queue, and waits
	// for in-flight jobs to complete or the context to expire.
	Shutdown(ctx context.Context) error

	// Stats returns current worker pool statistics.
	Stats() Stats
}