pool

package

v1.3.1 Latest Latest Go to latest Published: Jun 8, 2026 License: AGPL-3.0 Imports: 7 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func NewResult[T any](key uuid.UUID, value T) *Result[T]

func (r *Result[T]) ID() string

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

func NewWorkerPool(workers int, tracer tracing.TracingInterface, monitor monitoring.MonitorInterface, logger logging.LoggerInterface) *WorkerPool

func (p *WorkerPool) Stop()

func (p *WorkerPool) Submit(command any, results chan *Result[any], wg *sync.WaitGroup) (string, error)

type WorkerPoolInterface interface {
	Submit(any, chan *Result[any], *sync.WaitGroup) (string, error)
}