store

type Bucket struct {
	BucketInfo

	GCHistory []GCState
	// contains filtered or unexported fields
}

type BucketInfo struct {
	BucketStat

	// tmp
	Pos             Position
	LastGC          *GCState
	HintState       int
	MaxDumpedHintID HintID
	DU              int64
	NumSameVhash    int64
	SizeSameVhash   int64
	SizeVhashKey    string
	NumSet          int64
	NumGet          int64
}

type BucketStat struct {
	// pre open init
	State int

	// init in open
	ID   int
	Home string

	TreeID      HintID
	NextGCChunk int
}

type CollisionTable struct {
	sync.Mutex `yaml:"-"`
	HintID
	Items map[uint64]map[string]HintItem
}

type DBLocalConfig struct {
	Home string `yaml:",omitempty"`
}

type DU struct {
	Disks      map[string]utils.DiskStatus
	BucketsHex map[string]int64
	Buckets    map[int]int64 `json:"-"`
	Errs       []string
}

type DataConfig struct {
	FlushWake     int64 `yaml:"-"`                        // after set to flush buffer, wake up flush go routine if buffer size > this
	DataFileMax   int64 `yaml:"-"`                        // data rotate when reach the size
	CheckVHash    bool  `yaml:"check_vhash,omitempty"`    // not really set if vhash is the same
	FlushInterval int   `yaml:"flush_interval,omitempty"` // the flush go routine run at this interval
	NoGCDays      int   `yaml:"no_gc_days,omitempty"`     // not data files whose mtime in recent NoGCDays days

	FlushWakeStr   string          `yaml:"flush_wake_str"` //
	DataFileMaxStr string          `yaml:"datafile_max_str,omitempty"`
	BufIOCap       int             `yaml:"-"` // for bufio reader/writer, if value is big, then enlarge this cap, defalult: 1MB
	BufIOCapStr    string          `yaml:"bufio_cap_str,omitempty"`
	NotCompress    map[string]bool `yaml:"not_compress,omitempty"` // kind do not compress
}

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

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

type GCFileState struct {
	NumBefore          int64
	NumReleased        int64
	NumReleasedDeleted int64
	SizeBefore         int64
	SizeReleased       int64
	SizeDeleted        int64
	SizeBroken         int64
	NumNotInHtree      int64
}

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

type GCState struct {
	BeginTS time.Time
	EndTS   time.Time

	// Begin and End are chunckIDs, they determine the range of GC.
	Begin int
	End   int

	// Src and Dst are chunkIDs, they are tmp variables used in gc process.
	Src int
	Dst int

	// For beansdbadmin check status.
	Running bool

	Err        error
	CancelFlag bool
	// sum
	GCFileState
}

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

type HStoreConfig struct {
	config.DBRouteConfig `yaml:"-"` // from route table
	DBLocalConfig        `yaml:"local,omitempty"`

	DataConfig  `yaml:"data,omitempty"`
	HintConfig  `yaml:"hint,omitempty"`
	HTreeConfig `yaml:"htree,omitempty"`
}

type HTree struct {
	sync.Mutex
	// contains filtered or unexported fields
}

type HTreeConfig struct {
	TreeHeight int `yaml:"tree_height,omitempty"`
	TreeDump   int `yaml:"tree_dump,omitempty"`

	HtreeDerivedConfig `yaml:"-"`
}

type HTreeItem HintItemMeta

type HTreeReq struct {
	Meta
	Position
	// contains filtered or unexported fields
}

type HashFuncType func(key []byte) uint64

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

type HintConfig struct {
	NoMerged          bool  `yaml:"hint_no_merged,omitempty"`      // merge only used to find collision, but not dump idx.m to save disk space
	MergeInterval     int   `yaml:"hint_merge_interval,omitempty"` // merge after rotating each MergeInterval chunk
	IndexIntervalSize int64 `yaml:"-"`                             // max diff of offsets of two adjacent hint index items
	SplitCap          int64 `yaml:"-"`                             // pre alloc SplitCap slot for each split, when slots are all filled, slot is dumped

	SplitCapStr          string `yaml:"hint_split_cap_str,omitempty"`
	IndexIntervalSizeStr string `yaml:"hint_index_interval_str,omitempty"`
}

type HintID struct {
	Chunk int
	Split int
}

type HintItem struct {
	HintItemMeta
	Key string
}

type HintItemMeta struct {
	Keyhash uint64
	Pos     Position
	Ver     int32
	Vhash   uint16
}

type HintStatus struct {
	NumRead int
	MaxRead int
	MaxTime time.Duration
}

type HtreeDerivedConfig struct {
	TreeDepth       int // from NumBucket
	TreeKeyHashMask uint64
	TreeKeyHashLen  int
}

type ItemFunc func(uint64, *HTreeItem)

type KeyInfo struct {
	KeyHash   uint64
	KeyIsPath bool
	Key       []byte
	StringKey string
	KeyPos
}

type KeyPos struct {
	KeyPathBuf [16]int
	KeyPath    []int

	// need depth
	BucketID        int
	KeyPathInBucket []int
}

type Meta struct {
	TS   uint32
	Flag uint32
	Ver  int32
	// computed once
	ValueHash uint16
	RecSize   uint32
}

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

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

type Payload struct {
	Meta
	cmem.CArray
}

type Position struct {
	ChunkID int
	Offset  uint32
}

type Record struct {
	Key     []byte
	Payload *Payload
}

type SliceHeader struct {
	Data uintptr
	Len  int
}

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