utils

Documentation

Index

• Variables
• func BinId(x uuid.UUID) []byte
• func ChanMonitor(name string, ch interface{}, intvl time.Duration)
• func ChanMonitorEmpty(name string, ch interface{}, intvl time.Duration)
• func DbToUuid(f interface{}) (uuid.UUID, error)
• func GetFromAny[V any](val any, defaultValue V) V
• func GetFromAnyMap[K comparable, V any](amap map[K]any, key K, defaultValue V) V
• func LoadRow(rows *sql.Rows) (map[string]interface{}, error)
• func SpaceTypeFromMap(parametersMap map[string]interface{}) (uuid.UUID, error)
• type SyncMap
  • func NewSyncMap[K comparable, V any]() *SyncMap[K, V]
  • func (m *SyncMap[K, V]) Load(k K) (V, bool)
  • func (m *SyncMap[K, V]) Purge()
  • func (m *SyncMap[K, V]) Remove(k K)
  • func (m *SyncMap[K, V]) Store(k K, v V)
• type TAtomBool
  • func (b *TAtomBool) Get() bool
  • func (b *TAtomBool) Set(value bool)
  • func (b *TAtomBool) Swap(value bool) bool
• type TimerFunc
• type TimerSet
  • 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)
• type Unique
  • func NewUnique[V any](val V) Unique[V]
  • func (u Unique[V]) Equals(unique Unique[V]) bool
  • func (u Unique[V]) Value() V

Variables

var ErrNotFound = errors.New("not found")

Functions

func BinId

func BinId(x uuid.UUID) []byte

func ChanMonitor

func ChanMonitor(name string, ch interface{}, intvl time.Duration)

func ChanMonitorEmpty

func ChanMonitorEmpty(name string, ch interface{}, intvl time.Duration)

func DbToUuid

func DbToUuid(f interface{}) (uuid.UUID, error)

func GetFromAny

func GetFromAny[V any](val any, defaultValue V) V

func GetFromAnyMap

func GetFromAnyMap[K comparable, V any](amap map[K]any, key K, defaultValue V) V

func LoadRow

func LoadRow(rows *sql.Rows) (map[string]interface{}, error)

func SpaceTypeFromMap

func SpaceTypeFromMap(parametersMap map[string]interface{}) (uuid.UUID, error)

Types

type SyncMap

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

func NewSyncMap

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

func (*SyncMap[K, V]) Load

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

func (*SyncMap[K, V]) Purge

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

func (*SyncMap[K, V]) Remove

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

func (*SyncMap[K, V]) Store

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

type TAtomBool

type TAtomBool struct {
	// contains filtered or unexported fields
}

func (*TAtomBool) Get

func (b *TAtomBool) Get() bool

func (*TAtomBool) Set

func (b *TAtomBool) Set(value bool)

func (*TAtomBool) Swap

func (b *TAtomBool) Swap(value bool) bool

type TimerFunc

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

type TimerSet

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

func NewTimerSet

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

func (*TimerSet[T]) Set

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

func (*TimerSet[T]) Stop

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

type Unique

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

func NewUnique

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

func (Unique[V]) Equals

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

func (Unique[V]) Value

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