workerpool

type JobOutcome string

type JobSpec struct {
	Context     context.Context
	Kind        string
	Timeout     time.Duration
	MaxQueueAge time.Duration
	Run         func(context.Context)
	Finalize    func(context.Context, JobOutcome)
}

type ManagedConfig struct {
	Workers   int
	QueueSize int
	// FinalizeTimeout은 callback 실제 시작 시점부터 적용한다.
	FinalizeTimeout time.Duration
	// FinalizeConcurrency는 동시에 실행할 수 있는 callback 수다.
	FinalizeConcurrency int
	// FinalizeQueueSize는 accepted job의 pending reservation, queued callback,
	// in-flight callback을 합한 총 reservation capacity다. 0 이하면 Workers+QueueSize를 사용한다.
	FinalizeQueueSize int
	Logger            *slog.Logger
}

type ManagedFinalizerSnapshot struct {
	Concurrency  int
	QueueSize    int
	QueueDepth   int
	InFlight     int
	Reservations int
	// Accepting은 finalizer가 새 reservation을 받을 수 있는 lifecycle 상태다.
	Accepting bool
	// DispatchDrained는 Close 이후 pending reservation과 callback queue가 모두 dispatch됐음을 뜻한다.
	// 이미 시작된 callback의 실제 반환 완료는 뜻하지 않는다.
	DispatchDrained bool
	// Quiesced는 Close 이후 모든 callback이 실제로 반환하고 reservation이 해제됐음을 뜻한다.
	Quiesced            bool
	Claimed             uint64
	Started             uint64
	Completed           uint64
	CompletedLate       uint64
	TimedOut            uint64
	Overloaded          uint64
	ReservationRejected uint64
	Panicked            uint64
}

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

type ManagedSnapshot struct {
	QueueDepth     int
	InFlight       int
	OldestQueueAge time.Duration
	Outcomes       map[JobOutcome]uint64
	Finalizer      ManagedFinalizerSnapshot
}

type ManagedSubmitReason string

type ManagedSubmitResult struct {
	Accepted         bool
	FinalizerClaimed bool
	Reason           ManagedSubmitReason
}

type QueuedConfig struct {
	Workers   int
	QueueSize int
}

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