internal

Documentation

Index

• func Flat[T any](values [][]T) []T
• func Map[T any, U any](values []T, mapFn func(value T) U) []U
• type KeyValue
• type RLockValue
  • func NewRLockValue[T any](initialValue T) *RLockValue[T]
  • func (v *RLockValue[T]) Load() (T, func())
  • func (v *RLockValue[T]) Store(value T) T
• type SyncMap
  • func NewSyncMap[K comparable, V any](initialKeyValues ...KeyValue[K, V]) *SyncMap[K, V]
  • func (s *SyncMap[K, V]) Clear()
  • func (m *SyncMap[K, V]) Load(key K) (V, bool)
  • func (m *SyncMap[K, V]) LoadOrStore(key K, value V) (V, bool)
  • func (s *SyncMap[K, V]) Remove(key K)
  • func (s *SyncMap[K, V]) Snapshot() map[K]V
  • func (m *SyncMap[K, V]) Store(key K, value V)
• type SyncSlice
  • func NewSyncSlice[T any]() *SyncSlice[T]
  • func (s *SyncSlice[T]) Append(value T)
  • func (s *SyncSlice[T]) Snapshot() []T

Functions

func Flat

func Flat[T any](values [][]T) []T

func Map

func Map[T any, U any](values []T, mapFn func(value T) U) []U

Types

type KeyValue

type KeyValue[K comparable, V any] struct {
	Key   K
	Value V
}

type RLockValue

type RLockValue[T any] struct {
	Value T
	// contains filtered or unexported fields
}

func NewRLockValue

func NewRLockValue[T any](initialValue T) *RLockValue[T]

func (*RLockValue[T]) Load

func (v *RLockValue[T]) Load() (T, func())

func (*RLockValue[T]) Store

func (v *RLockValue[T]) Store(value T) T

Returns old value

type SyncMap

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

func NewSyncMap

func NewSyncMap[K comparable, V any](initialKeyValues ...KeyValue[K, V]) *SyncMap[K, V]

func (*SyncMap[K, V]) Clear

func (s *SyncMap[K, V]) Clear()

func (*SyncMap[K, V]) Load

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

Load search on Parent as well

func (*SyncMap[K, V]) LoadOrStore

func (m *SyncMap[K, V]) LoadOrStore(key K, value V) (V, bool)

LoadOrStores shallow

func (*SyncMap[K, V]) Remove

func (s *SyncMap[K, V]) Remove(key K)

func (*SyncMap[K, V]) Snapshot

func (s *SyncMap[K, V]) Snapshot() map[K]V

func (*SyncMap[K, V]) Store

func (m *SyncMap[K, V]) Store(key K, value V)

Stores shallow

type SyncSlice

type SyncSlice[T any] struct {
	// contains filtered or unexported fields
}

func NewSyncSlice

func NewSyncSlice[T any]() *SyncSlice[T]

func (*SyncSlice[T]) Append

func (s *SyncSlice[T]) Append(value T)

func (*SyncSlice[T]) Snapshot

func (s *SyncSlice[T]) Snapshot() []T