util

Documentation

Index

• Constants
• func SampleIndices(sliceLen int, count int) []int
• type Cache
  • func NewCache() *Cache
  • func (l *Cache) Del(key string)
  • func (l *Cache) Get(key string) interface{}
  • func (l *Cache) Has(key string) bool
  • func (l *Cache) Set(key string, val interface{}, expMS int64)
• type MultiLocker
  • func NewMultiLocker() MultiLocker
• type Observable
  • func NewObservable() *Observable
  • func (o *Observable) Emit(evt string, args ...interface{})
  • func (o *Observable) On(evt string, cb interface{}) func()
• type OnRemove
• type Unsubscriber

Constants

const (
	DefaultReapInterval = time.Second
)

Functions

func SampleIndices

func SampleIndices(sliceLen int, count int) []int

Types

type Cache

type Cache struct {
	ReaperFunc   OnRemove
	ReapInterval time.Duration
	// contains filtered or unexported fields
}

func NewCache

func NewCache() *Cache

func (*Cache) Del

func (l *Cache) Del(key string)

func (*Cache) Get

func (l *Cache) Get(key string) interface{}

func (*Cache) Has

func (l *Cache) Has(key string) bool

func (*Cache) Set

func (l *Cache) Set(key string, val interface{}, expMS int64)

type MultiLocker

type MultiLocker interface {
	TryLock(interface{}) bool
	TryRLock(interface{}) bool
	Unlock(interface{})
	RUnlock(interface{})
}

func NewMultiLocker

func NewMultiLocker() MultiLocker

type Observable

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

func NewObservable

func NewObservable() *Observable

func (*Observable) Emit

func (o *Observable) Emit(evt string, args ...interface{})

func (*Observable) On

func (o *Observable) On(evt string, cb interface{}) func()

type OnRemove

type OnRemove func(key string, val interface{})

type Unsubscriber

type Unsubscriber func()