util

Documentation

Index

• func MakeNewStorageDriver() StorageDriver
• func RandomString() string
• func UUID() (string, error)
• func UUID64() uint64
• type MultiLock
  • func NewMultiLock() *MultiLock
  • func (multiLock *MultiLock) Lock(partitioningKey []byte)
  • func (multiLock *MultiLock) Unlock(partitioningKey []byte)
• type RWTryLock
  • func (lock *RWTryLock) RUnlock()
  • func (lock *RWTryLock) TryRLock() bool
  • func (lock *RWTryLock) WLock()
  • func (lock *RWTryLock) WUnlock()
• type RequestMap
  • func NewRequestMap() *RequestMap
  • func (rm *RequestMap) MakeRequest(id uint64) <-chan interface{}
  • func (rm *RequestMap) Respond(id uint64, r interface{})

Functions

func MakeNewStorageDriver

func MakeNewStorageDriver() StorageDriver

func RandomString

func RandomString() string

func UUID

func UUID() (string, error)

func UUID64

func UUID64() uint64

Types

type MultiLock

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

func NewMultiLock

func NewMultiLock() *MultiLock

func (*MultiLock) Lock

func (multiLock *MultiLock) Lock(partitioningKey []byte)

func (*MultiLock) Unlock

func (multiLock *MultiLock) Unlock(partitioningKey []byte)

type RWTryLock

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

func (*RWTryLock) RUnlock

func (lock *RWTryLock) RUnlock()

func (*RWTryLock) TryRLock

func (lock *RWTryLock) TryRLock() bool

func (*RWTryLock) WLock

func (lock *RWTryLock) WLock()

func (*RWTryLock) WUnlock

func (lock *RWTryLock) WUnlock()

type RequestMap

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

func NewRequestMap

func NewRequestMap() *RequestMap

func (*RequestMap) MakeRequest

func (rm *RequestMap) MakeRequest(id uint64) <-chan interface{}

func (*RequestMap) Respond

func (rm *RequestMap) Respond(id uint64, r interface{})