storage

package

v0.1.3 Latest Latest Go to latest Published: Mar 3, 2024 License: Apache-2.0 Imports: 9 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/CocaineCong/tangseng

Links

Open Source Insights

Documentation ¶

Index ¶

func Get(db *bolt.DB, bucket string, key []byte) (r []byte, err error)
func Mmap(fd int, offset int64, length int) ([]byte, error)
func Put(db *bolt.DB, bucket string, key []byte, value []byte) error
type InvertedDB
- func NewInvertedDB(invertedName string) *InvertedDB
type KvInfo
type TrieDB
- func NewTrieDB(filePath string) *TrieDB

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func Get ¶

func Get(db *bolt.DB, bucket string, key []byte) (r []byte, err error)

Get 通过bolt获取数据

func Mmap ¶

func Mmap(fd int, offset int64, length int) ([]byte, error)

Mmap 将一个文件映射到内存中，以便可以直接通过内存访问文件的内容。映射后的内存可以像普通的字节切片一样进行读取和写入操作，而不需要额外的文件读写操作。这对于处理大文件或需要频繁访问文件内容的场景非常有用，因为避免了多次磁盘读写操作，提高了性能。

func Put ¶

func Put(db *bolt.DB, bucket string, key []byte, value []byte) error

Put 通过bolt写入数据

Types ¶

type InvertedDB ¶

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

func NewInvertedDB ¶

func NewInvertedDB(invertedName string) *InvertedDB

NewInvertedDB 新建一个inverted

func (*InvertedDB) Close ¶

func (t *InvertedDB) Close()

func (*InvertedDB) GetAllInverted ¶ added in v0.1.2

func (t *InvertedDB) GetAllInverted() (p []*types.InvertedInfo, err error)

func (*InvertedDB) GetInverted ¶

func (t *InvertedDB) GetInverted(key []byte) (value []byte, err error)

GetInverted 通过term获取value

func (*InvertedDB) GetInvertedDoc ¶

func (t *InvertedDB) GetInvertedDoc(offset int64, size int64) ([]byte, error)

GetInvertedDoc 根据地址获取读取文件

func (*InvertedDB) GetInvertedInfo ¶

func (t *InvertedDB) GetInvertedInfo(token string) (p *types.InvertedInfo, err error)

GetInvertedInfo 获取倒排地址

func (*InvertedDB) PutInverted ¶

func (t *InvertedDB) PutInverted(key, value []byte) (err error)

PutInverted 插入term

func (*InvertedDB) StoragePostings ¶

func (t *InvertedDB) StoragePostings(token string, values []byte) (err error)

StoragePostings 存储倒排索引表

type KvInfo ¶

type KvInfo struct {
	Key   []byte
	Value []byte
}

type TrieDB ¶

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

func NewTrieDB ¶

func NewTrieDB(filePath string) *TrieDB

NewTrieDB 初始化trie

func (*TrieDB) Close ¶

func (d *TrieDB) Close() error

Close 关闭db

func (*TrieDB) GetTrieTree ¶

func (d *TrieDB) GetTrieTree(key []byte) (value []byte, err error)

GetTrieTree 通过term获取value

func (*TrieDB) GetTrieTreeInfo ¶

func (d *TrieDB) GetTrieTreeInfo() (trieTree *trie.Trie, err error)

GetTrieTreeInfo 获取 trie tree

func (*TrieDB) PutTrieTree ¶

func (d *TrieDB) PutTrieTree(key, value []byte) (err error)

PutTrieTree 存储

func (*TrieDB) StorageDict ¶

func (d *TrieDB) StorageDict(trieTree *trie.Trie) (err error)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL