generic

package

v0.2.0 Latest Latest Go to latest Published: Feb 6, 2023 License: AGPL-3.0 Imports: 5 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type SyncMap[K comparable, V any] struct {
	Mu deadlock.RWMutex
	//Mu   sync.RWMutex
	Data map[K]V
}

func NewSyncMap[K comparable, V any](size int) *SyncMap[K, V]

func (m *SyncMap[K, V]) Filter(predicateFn func(k K, v V) bool) map[K]V

func (m *SyncMap[K, V]) Len() int

func (m *SyncMap[K, V]) Load(k K) (V, bool)

func (m *SyncMap[K, V]) Map(mapFn func(v V) V)

func (m *SyncMap[K, V]) Purge()

func (m *SyncMap[K, V]) Remove(k K) bool

func (m *SyncMap[K, V]) Store(k K, v V)

type TimerFunc[T comparable] func(key T) error

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

func NewTimerSet[T comparable]() *TimerSet[T]

func (t *TimerSet[T]) Set(key T, delay time.Duration, fn TimerFunc[T])

func (t *TimerSet[T]) Stop(key T)

func (t *TimerSet[T]) StopAll()

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

func NewUnique[V any](val V) Unique[V]

func (u Unique[V]) Cmp() any

func (u Unique[V]) Compare(cmp any) bool

func (u Unique[V]) Equals(unique Unique[V]) bool

func (u Unique[V]) Value() V