syncing

README

go-syncing

Documentation

Index

• type Funnel
  • func NewFunnel[T comparable]() Funnel[T]
• type Group
  • func NewGroup(ctx context.Context) Group
• type Limiter
  • func NewLimiter(ctx context.Context, count int, interval time.Duration) Limiter
• type Lock
  • func NewLock() Lock
• type Map
  • 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)
  • func (v *Map[K, V]) Size() int
  • func (v *Map[K, V]) Yield() iter.Seq2[K, V]
• type Slice
  • func NewSlice[V any](size uint) *Slice[V]
  • func (v *Slice[V]) Append(val ...V)
  • func (v *Slice[V]) Extract() []V
  • func (v *Slice[V]) Index(i int) (V, bool)
  • func (v *Slice[V]) Reset()
  • func (v *Slice[V]) Size() int
  • func (v *Slice[V]) Yield() iter.Seq[V]
• type Switch
  • func NewSwitch() Switch
• type XLock
  • func NewXLock[V any]() XLock[V]

Types

type Funnel

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

func NewFunnel

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

type Group

type Group interface {
	Cancel()
	Wait()
	Background(name string, call func(ctx context.Context))
	Run(name string, call func(ctx context.Context))
	OnPanic(call func(err error))
}

func NewGroup

func NewGroup(ctx context.Context) Group

type Limiter

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

func NewLimiter

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

type Lock

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

func NewLock

func NewLock() Lock

type Map

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

func NewMap

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

func (*Map[K, V]) Del

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

func (*Map[K, V]) Extract

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

func (*Map[K, V]) Get

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

func (*Map[K, V]) Keys

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

func (*Map[K, V]) Reset

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

func (*Map[K, V]) Set

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

func (*Map[K, V]) Size

func (v *Map[K, V]) Size() int

func (*Map[K, V]) Yield

func (v *Map[K, V]) Yield() iter.Seq2[K, V]

type Slice

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

func NewSlice

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

func (*Slice[V]) Append

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

func (*Slice[V]) Extract

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

func (*Slice[V]) Index

func (v *Slice[V]) Index(i int) (V, bool)

func (*Slice[V]) Reset

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

func (*Slice[V]) Size

func (v *Slice[V]) Size() int

func (*Slice[V]) Yield

func (v *Slice[V]) Yield() iter.Seq[V]

type Switch

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

func NewSwitch

func NewSwitch() Switch

type XLock

type XLock[V any] interface {
	RLock(call func() (V, error)) (V, error)
	Lock(call func() (V, error)) (V, error)
}

func NewXLock

func NewXLock[V any]() XLock[V]