index

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

type BPTreeOptions struct {
	// DirPath path to store index data.
	DirPath string
	// IndexType bptree(bolt).
	IndexType IndexerType
	// ColumnFamilyName db column family name, must be unique.
	ColumnFamilyName string
	// BucketName usually the the same as column family name, must be unique.
	BucketName []byte
	// BatchSize flush batch size.
	BatchSize int
	// DiscardChn if values in indexer are changed, the older value will be send to the DiscardChn.
	// Values will be handled in discard.go/listenUpdates().
	DiscardChn chan [][]byte
}

type Indexer interface {
	Put(key []byte, value []byte) (err error)

	PutBatch(kv []*IndexerNode, opts WriteOptions) (offset int, err error)

	Get(key []byte) (meta *IndexerMeta, err error)

	Delete(key []byte) error

	DeleteBatch(keys [][]byte, opts WriteOptions) error

	Sync() error

	Close() (err error)
}

type IndexerIter interface {
	// First moves the cursor to the first item in the bucket and returns its key and value.
	// If the bucket is empty then a nil key and value are returned.
	First() (key, value []byte)

	// Last moves the cursor to the last item in the bucket and returns its key and value.
	// If the bucket is empty then a nil key and value are returned.
	Last() (key, value []byte)

	// Seek moves the cursor to a given key and returns it.
	// If the key does not exist then the next key is used. If no keys follow, a nil key is returned.
	Seek(seek []byte) (key, value []byte)

	// Next moves the cursor to the next item in the bucket and returns its key and value.
	// If the cursor is at the end of the bucket then a nil key and value are returned.
	Next() (key, value []byte)

	// Prev moves the cursor to the previous item in the bucket and returns its key and value.
	// If the cursor is at the beginning of the bucket then a nil key and value are returned.
	Prev() (key, value []byte)

	// Close The close method must be called after the iterative behavior is over！
	Close() error
}

type IndexerMeta struct {
	Value     []byte
	Fid       uint32
	Offset    int64
	EntrySize int
}

type IndexerNode struct {
	Key  []byte
	Meta *IndexerMeta
}

type IndexerOptions interface {
	SetType(typ IndexerType)

	SetColumnFamilyName(cfName string)

	SetDirPath(dirPath string)

	GetType() IndexerType

	GetColumnFamilyName() string

	GetDirPath() string
}

type IndexerType int8

type WriteOptions struct {
	SendDiscard bool
}