wsinternal

package

v0.2.0 Latest Latest Go to latest Published: Feb 2, 2025 License: MIT Imports: 6 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Subscriber interface {
	ID() string
	OnEventCallback(event any)
}

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

Worker is used to handle work of the WorkerPool.

func NewWorker(id int, channelBufferSize int, pool *WorkerPool) Worker

NewWorker creates a new Worker.

func (worker *Worker) Active() bool

func (worker *Worker) EnqueueEvent(event any)

func (worker *Worker) Start(_ context.Context, _ *slog.Logger) error

Start makes Worker start doing work.

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

WorkerPool is used to divide [Subscriber]s between [Worker]s. This prevents one Worker of being very busy.

func NewWorkerPool(
	logger *slog.Logger,
	maxWorkers int,
	channelBufferSize int,
) *WorkerPool

NewWorkerPool creates a new WorkerPool.

func (pool *WorkerPool) Active() bool

Active checks if the WorkerPool is active by checking if any Worker is active.

func (pool *WorkerPool) AddSubscriber(sub Subscriber)

AddSubscriber adds a Subscriber to the WorkerPool.

func (pool *WorkerPool) EnqueueEvent(event any)

EnqueueEvent puts an event on the Worker channels.

func (pool *WorkerPool) RemoveSubscriber(sub Subscriber)

RemoveSubscriber removes a Subscriber from the WorkerPool.

func (pool *WorkerPool) Start()

Start starts [Worker]s of a WorkerPool if they weren't active yet.

func (pool *WorkerPool) Stop()

Stop stops all workers.