routine

type CyclicDistributionEventChain[T any] struct {
	// contains filtered or unexported fields
}

type CyclicEventChainReportMetric struct {
	PoolSize          int    `json:"pool_size,omitempty"`
	Actives           []bool `json:"actives,omitempty"`
	NumClients        []int  `json:"num_clients,omitempty"`
	CurrentCyclicCode uint64 `json:"current_cyclic_code,omitempty"`
	Started           bool   `json:"started,omitempty"`
}

type EventChannel[T any] struct {
	// contains filtered or unexported fields
}

type EventHander[T any] func(job EventChannel[T], t *T) error

type Option func(opts *Options)

type Options struct {
	// MaxIdleWorkerDuration is a period for the scavenger goroutine to clean up those expired workers,
	// the scavenger scans all workers every `MaxIdleWorkerDuration` and clean up those workers that haven't been
	// used for more than `ExpiryDuration`.
	MaxIdleWorkerDuration time.Duration

	// Max number of goroutine blocking on pool.Submit.
	// 0 (default value) means no such limit.
	MaxWorkersCount uint32

	LogAllErrors bool
}

type WorkPoolMetrics struct {
	MaxWorkersCount       uint32        `json:"max_workers_count,omitempty"`
	LogAllErrors          bool          `json:"log_all_errors,omitempty"`
	MaxIdleWorkerDuration time.Duration `json:"max_idle_worker_duration,omitempty"`

	Ready      int    `json:"ready,omitempty"`
	GetTimes   uint64 `json:"get_times,omitempty"`
	PurgeTimes uint64 `json:"purge_times,omitempty"`
	// contains filtered or unexported fields
}

type WorkerFunc func() error