syncing

package module

v0.3.1 Latest Latest Go to latest Published: Jan 12, 2025 License: BSD-3-Clause Imports: 5 Imported by: 12

Details

This section is empty.

This section is empty.

This section is empty.

type Funnel[T comparable] interface {
	Valve(name T, call func())
}

func NewFunnel[T comparable]() Funnel[T]

type Group interface {
	Wait()
	Background(call func())
	Run(call func())
}

func NewGroup() Group

type Limiter interface {
	Tap(ctx context.Context) error
}

func NewLimiter(ctx context.Context, count int, interval time.Duration) Limiter

type Lock interface {
	RLock(call func())
	Lock(call func())
}

func NewLock() Lock

type Map[K comparable, V any] struct {
	// contains filtered or unexported fields
}

func NewMap[K comparable, V any](size uint) *Map[K, V]

func (v *Map[K, V]) Del(key K)

func (v *Map[K, V]) Extract(key K) (val V, ok bool)

func (v *Map[K, V]) Get(key K) (val V, ok bool)

func (v *Map[K, V]) Keys() []K

func (v *Map[K, V]) Reset()

func (v *Map[K, V]) Set(key K, val V)

type Slice[V any] struct {
	// contains filtered or unexported fields
}

func NewSlice[V any](size uint) *Slice[V]

func (v *Slice[V]) Append(val ...V)

func (v *Slice[V]) Extract() []V

type Switch interface {
	On() bool
	Off() bool
	IsOn() bool
	IsOff() bool
}

func NewSwitch() Switch