Documentation ¶
Index ¶
- Constants
- type BigHash
- type BlockCache
- type BlockEntry
- type BlockInfo
- type BlockInfoP
- type Bucket
- type BucketEntry
- type BucketHeader
- type BucketP
- type NvmStore
- func (n *NvmStore[K, V]) Delete(key K) error
- func (n *NvmStore[K, V]) Get(key K) (value V, cost int64, expire int64, ok bool, err error)
- func (n *NvmStore[K, V]) HandleAsyncError(err error)
- func (n *NvmStore[K, V]) Set(key K, value V, cost int64, expire int64) error
- func (n *NvmStore[K, V]) SetClock(clock *clock.Clock)
- type Region
- type RegionManager
Constants ¶
View Source
const ( BigHashMetaBlock uint8 = iota BigHashMetaBucketBlock BlockCacheMetaBlock BlockCacheMetaIndexBlock DataBlock )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BigHash ¶
type BigHash struct { CacheSize uint64 BucketSize uint64 GenerationTime uint64 Clock *clock.Clock // contains filtered or unexported fields }
func NewBigHash ¶
type BlockCache ¶
type BlockCache struct { Offset uint64 Clock *clock.Clock CacheSize uint64 RegionSize uint32 // contains filtered or unexported fields }
func NewBlockCache ¶
func (*BlockCache) Delete ¶
func (c *BlockCache) Delete(key []byte)
type BlockEntry ¶
type BlockEntry struct {
// contains filtered or unexported fields
}
type BlockInfoP ¶
type Bucket ¶
type Bucket struct { Bloomfilter *bf.Bloomfilter // contains filtered or unexported fields }
type BucketEntry ¶
type BucketEntry struct {
// contains filtered or unexported fields
}
type BucketHeader ¶
type BucketHeader struct {
// contains filtered or unexported fields
}
type BucketP ¶
type BucketP struct { Index uint64 Bloomfilter *bf.Bloomfilter }
used in persisit data
type NvmStore ¶
type NvmStore[K comparable, V any] struct { // contains filtered or unexported fields }
func NewNvmStore ¶
func NewNvmStore[K comparable, V any]( file string, blockSize int, cacheSize int, bucketSize int, regionSize int, cleanRegionSize int, sizePct uint8, bigHashMaxEntrySize int, bfSize int, errorHandler func(err error), keySerializer internal.Serializer[K], valueSerializer internal.Serializer[V], ) (*NvmStore[K, V], error)
func (*NvmStore[K, V]) HandleAsyncError ¶
type RegionManager ¶
type RegionManager struct {
// contains filtered or unexported fields
}
func NewRegionManager ¶
Directories ¶
Path | Synopsis |
---|---|
This is library for the Go language to enable use of Direct IO under all supported OSes of Go.
|
This is library for the Go language to enable use of Direct IO under all supported OSes of Go. |
Click to show internal directories.
Click to hide internal directories.