common

Documentation

Index

• Constants
• Variables
• func CondPanic(condition bool, err error)
• func Err(err error) error
• func Panic(err error)
• func Panic2(_ interface{}, err error)
• func WarpErr(format string, err error) error

Constants

const (
	MaxLevelNum                       = 7
	VlogFileDiscardStatsKey           = "VlogFileDiscard" // For storing lfDiscardStats
	ManifestFilename                  = "MANIFEST"
	ManifestRewriteFilename           = "REWRITEMANIFEST"
	ManifestDeletionsRewriteThreshold = 10000
	ManifestDeletionsRatio            = 10
	ManifestFileHeaderLen             = 8
	ManifestFileCrcLen                = 8
	DefaultFileFlag                   = os.O_RDWR | os.O_CREATE | os.O_APPEND
	DefaultFileMode                   = 0666
	MaxHeaderSize                     = 21 // 基于可变长编码,vlogFile其最可能的编码
	VlogHeaderSize                    = 0
	// KVWriteChRequestCapacity                 = 1000
	KVWriteChRequestCapacity = 0
)

const (
	BitDelete       byte = 1 << 0 //1 Set if the key has been deleted.
	BitValuePointer byte = 1 << 1 //2 Set if the value is NOT stored directly next to key.
)

meta

Variables

var (
	MagicText           = [4]byte{'M', 'A', 'G', 'C'} // Manifest 文件的头8B中的前4B魔数 Magic
	MagicVersion        = uint32(1)
	CastigationCryTable = crc32.MakeTable(crc32.Castagnoli)
)

var (
	ErrEmptyKey      = errors.New("key can not be empty")
	ErrOutOffset     = errors.New("out offset")
	ErrNotFoundTable = errors.New("not found table of key")
	ErrKeyNotFound   = errors.New("err not found key")

	ErrWalInvalidCrc = errors.New("walFile: invalid crc")
	ErrBadReadMagic  = errors.New("read magic failed")
	ErrBadMagic      = errors.New("bad magic")
	ErrBadCRC        = errors.New("bad crc")
	ErrBadReadCRC    = errors.New("read crc")
	ErrBadChecksum   = errors.New("bad Checksum from manifestFile")
	ErrBadRemoveSST  = errors.New("while removing table")

	ErrChecksumMismatch = errors.New("checksum mismatch")

	ErrTruncate      = errors.New("err do truncate")
	ErrEmptyVlogFile = errors.New("empty vlogFile when Entry()")

	ErrfillTables = errors.New("Unable to fill tables")

	ErrTxnTooBig     = errors.New("Txn is too big to fit into one request")
	ErrBatchTooLarge = errors.New("Batch is too big to fit into one request")

	// ErrNoRewrite is returned if a call for value log GC doesn't result in a log file rewrite.
	ErrNoRewrite = errors.New("Value log GC attempt didn't result in any cleanup")

	// ErrRejected is returned if a value log GC is called either while another GC is running, or
	// after DB::Close has been called.
	ErrRejected = errors.New("Value log GC request rejected")
)

Functions

func CondPanic

func CondPanic(condition bool, err error)

func Err

func Err(err error) error

func Panic

func Panic(err error)

func Panic2

func Panic2(_ interface{}, err error)

func WarpErr

func WarpErr(format string, err error) error