workset

package

v0.7.2 Latest Latest Go to latest Published: Oct 18, 2026 License: Apache-2.0 Imports: 4 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Option[T comparable] func(*WorkSet[T])

func WithLogger[T comparable](logger *zap.SugaredLogger) Option[T]

WithLogger sets the logger

func WithTaskInterval[T comparable](d time.Duration) Option[T]

WithTaskInterval sets the task interval

func WithWorkers[T comparable](i int) Option[T]

WithWorkers sets the workers

type ProcessFunc[T comparable] func(ctx context.Context, key T) error

ProcessFunc handles one AgentDeploy per invocation.

type WorkSet[T comparable] struct {
	// contains filtered or unexported fields
}

func NewWorkSet[T comparable](name string, processFunc ProcessFunc[T], opts ...Option[T]) *WorkSet[T]

func (w *WorkSet[T]) Contains(key T) bool

Contains reports whether the key is in the set.

func (w *WorkSet[T]) Forget(key T)

Forget removes a key from the set.

func (w *WorkSet[T]) Len() int

Len is the size of the set.

func (w *WorkSet[T]) Snapshot() []T

Snapshot returns a copy of the current keys for a component to iterate without holding the lock or racing concurrent Track/Forget.

func (w *WorkSet[T]) Start(ctx context.Context) error

Start runs the worker pool and the assigner loop until ctx is cancelled.

func (w *WorkSet[T]) Track(key T)

Track adds a key to the set (idempotent)..