z

Feb 3, 2022

Changes in this version

+ const MaxArrayLen — darwin/amd64, linux/amd64, windows/amd64

+ const MaxBufferSize — darwin/amd64, linux/amd64, windows/amd64

+ var ErrNewFileCreateFailed = errors.New("create a new file")

+ func Allocators() string

+ func BytesToUint64Slice(b []byte) []uint64

+ func CPUTicks() int64

+ func Calloc(n int, tag string) []byte

+ func CallocNoRef(n int, tag string) []byte

+ func FastRand() uint32

+ func Fibonacci(num int) []float64

+ func Free(b []byte)

+ func HistogramBounds(minExponent, maxExponent uint32) []float64

+ func KeyToHash(key interface{}) (uint64, uint64)

+ func Leaks() string

+ func Madvise(b []byte, readahead bool) error

+ func MemHash(data []byte) uint64

+ func MemHashString(str string) uint64

+ func Memclr(b []byte)

+ func Mmap(fd *os.File, writable bool, size int64) ([]byte, error)

+ func Msync(b []byte) error

+ func Munmap(b []byte) error

+ func NanoTime() int64

+ func NumAllocBytes() int64

+ func ReadMemStats(_ *MemStats)

+ func SetTmpDir(dir string)

+ func StatsPrint()

+ func SyncDir(dir string) error

+ func ZeroOut(dst []byte, start, end int)

+ type Allocator struct

+ Ref uint64

+ Tag string

+ func AllocatorFrom(ref uint64) *Allocator

+ func NewAllocator(sz int, tag string) *Allocator

+ func (a *Allocator) Allocate(sz int) []byte

+ func (a *Allocator) AllocateAligned(sz int) []byte

+ func (a *Allocator) Allocated() uint64

+ func (a *Allocator) Copy(buf []byte) []byte

+ func (a *Allocator) MaxAlloc() int

+ func (a *Allocator) Release()

+ func (a *Allocator) Reset()

+ func (a *Allocator) Size() int

+ func (a *Allocator) String() string

+ func (a *Allocator) TrimTo(max int)

+ type AllocatorPool struct

+ func NewAllocatorPool(sz int) *AllocatorPool

+ func (p *AllocatorPool) Get(sz int, tag string) *Allocator

+ func (p *AllocatorPool) Release()

+ func (p *AllocatorPool) Return(a *Allocator)

+ type Bloom struct

+ ElemNum uint64

+ func JSONUnmarshal(dbData []byte) (*Bloom, error)

+ func NewBloomFilter(params ...float64) (bloomfilter *Bloom)

+ func (bl *Bloom) Add(hash uint64)

+ func (bl *Bloom) AddIfNotHas(hash uint64) bool

+ func (bl *Bloom) Clear()

+ func (bl *Bloom) IsSet(idx uint64) bool

+ func (bl *Bloom) Set(idx uint64)

+ func (bl *Bloom) Size(sz uint64)

+ func (bl *Bloom) TotalSize() int

+ func (bl Bloom) Has(hash uint64) bool

+ func (bl Bloom) JSONMarshal() []byte

+ type Buffer struct

+ func NewBuffer(capacity int, tag string) *Buffer

+ func NewBufferPersistent(path string, capacity int) (*Buffer, error)

+ func NewBufferSlice(slice []byte) *Buffer

+ func NewBufferTmp(dir string, capacity int) (*Buffer, error)

+ func (b *Buffer) Allocate(n int) []byte

+ func (b *Buffer) AllocateOffset(n int) int

+ func (b *Buffer) Bytes() []byte

+ func (b *Buffer) Data(offset int) []byte

+ func (b *Buffer) Grow(n int)

+ func (b *Buffer) IsEmpty() bool

+ func (b *Buffer) LenNoPadding() int

+ func (b *Buffer) LenWithPadding() int

+ func (b *Buffer) Release() error

+ func (b *Buffer) Reset()

+ func (b *Buffer) Slice(offset int) ([]byte, int)

+ func (b *Buffer) SliceAllocate(sz int) []byte

+ func (b *Buffer) SliceIterate(f func(slice []byte) error) error

+ func (b *Buffer) SliceOffsets() []int

+ func (b *Buffer) SortSlice(less func(left, right []byte) bool)

+ func (b *Buffer) SortSliceBetween(start, end int, less LessFunc)

+ func (b *Buffer) StartOffset() int

+ func (b *Buffer) WithAutoMmap(threshold int, path string) *Buffer

+ func (b *Buffer) WithMaxSize(size int) *Buffer

+ func (b *Buffer) Write(p []byte) (n int, err error)

+ func (b *Buffer) WriteSlice(slice []byte)

+ type BufferType int

+ const UseCalloc

+ const UseInvalid

+ const UseMmap

+ func (t BufferType) String() string

+ type Closer struct

+ func NewCloser(initial int) *Closer

+ func (lc *Closer) AddRunning(delta int)

+ func (lc *Closer) Ctx() context.Context

+ func (lc *Closer) Done()

+ func (lc *Closer) HasBeenClosed() <-chan struct{}

+ func (lc *Closer) Signal()

+ func (lc *Closer) SignalAndWait()

+ func (lc *Closer) Wait()

+ type HistogramData struct

+ Bounds []float64

+ Count int64

+ CountPerBucket []int64

+ Max int64

+ Min int64

+ Sum int64

+ func NewHistogramData(bounds []float64) *HistogramData

+ func (histogram *HistogramData) Clear()

+ func (histogram *HistogramData) Copy() *HistogramData

+ func (histogram *HistogramData) Mean() float64

+ func (histogram *HistogramData) Percentile(p float64) float64

+ func (histogram *HistogramData) String() string

+ func (histogram *HistogramData) Update(value int64)

+ type LessFunc func(a, b []byte) bool

+ type MemStats struct

+ Active uint64

+ Allocated uint64

+ Resident uint64

+ Retained uint64

+ type MmapFile struct

+ Data []byte

+ Fd *os.File

+ func OpenMmapFile(filename string, flag int, maxSz int) (*MmapFile, error)

+ func OpenMmapFileUsing(fd *os.File, sz int, writable bool) (*MmapFile, error)

+ func (m *MmapFile) AllocateSlice(sz, offset int) ([]byte, int, error)

+ func (m *MmapFile) Bytes(off, sz int) ([]byte, error)

+ func (m *MmapFile) Close(maxSz int64) error

+ func (m *MmapFile) Delete() error

+ func (m *MmapFile) NewReader(offset int) io.Reader

+ func (m *MmapFile) Slice(offset int) []byte

+ func (m *MmapFile) Sync() error

+ func (m *MmapFile) Truncate(maxSz int64) error

+ type SuperFlag struct

+ func NewSuperFlag(flag string) *SuperFlag

+ func (sf *SuperFlag) GetBool(opt string) bool

+ func (sf *SuperFlag) GetDuration(opt string) time.Duration

+ func (sf *SuperFlag) GetFloat64(opt string) float64

+ func (sf *SuperFlag) GetInt64(opt string) int64

+ func (sf *SuperFlag) GetPath(opt string) string

+ func (sf *SuperFlag) GetString(opt string) string

+ func (sf *SuperFlag) GetUint32(opt string) uint32

+ func (sf *SuperFlag) GetUint64(opt string) uint64

+ func (sf *SuperFlag) Has(opt string) bool

+ func (sf *SuperFlag) MergeAndCheckDefault(flag string) *SuperFlag

+ func (sf *SuperFlag) MergeWithDefault(flag string) (*SuperFlag, error)

+ func (sf *SuperFlag) String() string

+ type SuperFlagHelp struct

+ func NewSuperFlagHelp(defaults string) *SuperFlagHelp

+ func (h *SuperFlagHelp) Flag(name, description string) *SuperFlagHelp

+ func (h *SuperFlagHelp) Head(head string) *SuperFlagHelp

+ func (h *SuperFlagHelp) String() string

+ type Tree struct

+ func NewTree(tag string) *Tree

+ func NewTreePersistent(path string) (*Tree, error)

+ func (t *Tree) Close() error

+ func (t *Tree) DeleteBelow(ts uint64)

+ func (t *Tree) Get(k uint64) uint64

+ func (t *Tree) Iterate(fn func(node))

+ func (t *Tree) IterateKV(f func(key, val uint64) (newVal uint64))

+ func (t *Tree) Print()

+ func (t *Tree) Reset()

+ func (t *Tree) Set(k, v uint64)

+ func (t *Tree) Stats() TreeStats

+ type TreeStats struct

+ Allocated int

+ Bytes int

+ NumLeafKeys int

+ NumPages int

+ NumPagesFree int

+ Occupancy float64

+ PageSize int