roundrobbin

Documentation

Index

• func WithOnEvict[T comparable](fn func(T)) func(*Set[T])
• type Set
  • func NewSet[T comparable](opts ...func(*Set[T])) *Set[T]
  • func (s *Set[T]) Next(ctx context.Context) (t T, ok bool, err error)
  • func (s *Set[T]) Register(ctx context.Context, t T)
  • func (s *Set[T]) Remove(t T)

Functions

func WithOnEvict

func WithOnEvict[T comparable](fn func(T)) func(*Set[T])

Types

type Set

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

func NewSet

func NewSet[T comparable](opts ...func(*Set[T])) *Set[T]

func (*Set[T]) Next

func (s *Set[T]) Next(ctx context.Context) (t T, ok bool, err error)

func (*Set[T]) Register

func (s *Set[T]) Register(ctx context.Context, t T)

func (*Set[T]) Remove

func (s *Set[T]) Remove(t T)