bitalosdb

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

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

type BatchBitowerReader []byte

type BitableOptions = options.BitableOptions

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

type CheckpointOption func(*checkpointOptions)

type CompactEnv struct {
	StartHour     int
	EndHour       int
	DeletePercent float64
	BitreeMaxSize int64
	Interval      int
}

type Compare = base.Compare

type Comparer = base.Comparer

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

type DeferredBatchOp struct {
	Key, Value []byte
	// contains filtered or unexported fields
}

type Equal = base.Equal

type EventListener struct {
	BackgroundError func(error)
	FlushBegin      func(FlushInfo)
	FlushEnd        func(FlushInfo)
	WALCreated      func(WALCreateInfo)
	WALDeleted      func(WALDeleteInfo)
	WriteStallBegin func(WriteStallBeginInfo)
	WriteStallEnd   func()
}

type FileNum = base.FileNum

type FlushInfo struct {
	Index    int
	Reason   string
	Input    int
	Iterated uint64
	Written  int64

	Duration time.Duration
	Done     bool
	Err      error
	// contains filtered or unexported fields
}

type InternalKey = base.InternalKey

type InternalKeyKind = base.InternalKeyKind

type IterOptions = options.IterOptions

type IterValidityState int8

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

type IteratorMetrics struct {
	ReadAmp int
}

type IteratorStats struct {
	ForwardSeekCount [NumStatsKind]int
	ReverseSeekCount [NumStatsKind]int
	ForwardStepCount [NumStatsKind]int
	ReverseStepCount [NumStatsKind]int
}

type IteratorStatsKind int8

type Logger = base.Logger

type MetricsInfo struct {
	FlushMemTime       int64 `json:"-"`
	BithashFileTotal   int   `json:"bithash_file_total"`
	BithashKeyTotal    int   `json:"bithash_key_total"`
	BithashDelKeyTotal int   `json:"bithash_del_key_total"`
}

type Options struct {
	BytesPerSync                   int
	Comparer                       *Comparer
	DisableWAL                     bool
	EventListener                  EventListener
	MemTableSize                   int
	MemTableStopWritesThreshold    int
	WALBytesPerSync                int
	WALDir                         string
	WALMinSyncInterval             func() time.Duration
	FS                             vfs.FS
	Logger                         Logger
	Id                             int
	Verbose                        bool
	LogTag                         string
	DataType                       string
	CompressionType                int
	DeleteFileInternal             int
	UseBithash                     bool
	UseBitable                     bool
	BitableOpts                    *options.BitableOptions
	AutoCompact                    bool
	CompactInfo                    CompactEnv
	CacheSize                      int64
	CacheType                      int
	CacheShards                    int
	CacheHashSize                  int
	UseMapIndex                    bool
	UsePrefixCompress              bool
	UseBlockCompress               bool
	BlockCacheSize                 int64
	FlushReporter                  func(int)
	KeyHashFunc                    func([]byte) int
	KvCheckExpireFunc              func(int, []byte, []byte) bool
	KvTimestampFunc                func([]byte, uint8) (bool, uint64)
	IOWriteLoadThresholdFunc       func() bool
	KeyPrefixDeleteFunc            func([]byte) uint64
	FlushPrefixDeleteKeyMultiplier int
	FlushFileLifetime              int
	BitpageFlushSize               uint64
	BitpageSplitSize               uint64
	// contains filtered or unexported fields
}

type Reader interface {
	Get(key []byte) (value []byte, closer func(), err error)
	NewIter(o *IterOptions) *Iterator
	Close() error
}

type Split = base.Split

type WALCreateInfo struct {
	Index           int
	Path            string
	FileNum         FileNum
	RecycledFileNum FileNum
	Err             error
}

type WALDeleteInfo struct {
	Index   int
	Path    string
	FileNum FileNum
	Err     error
}

type WriteOptions struct {
	Sync bool
}

type WriteStallBeginInfo struct {
	Index  int
	Reason string
}

type Writer interface {
	Apply(batch *Batch, o *WriteOptions) error
	ApplyBitower(batch *BatchBitower, o *WriteOptions) error
	Delete(key []byte, o *WriteOptions) error
	LogData(data []byte, index int, opts *WriteOptions) error
	Set(key, value []byte, o *WriteOptions) error
	PrefixDeleteKeySet(key []byte, o *WriteOptions) error
}