database

Documentation

Index

• type CmdLine
• type DB
• type DBEngine
• type DataEntity
• type KeyEventCallback

Types

type CmdLine

type CmdLine = [][]byte

CmdLine is alias for [][]byte, represents a command line

type DB

type DB interface {
	Exec(client redis.Connection, cmdLine [][]byte) redis.Reply
	AfterClientClose(c redis.Connection)
	Close()
	LoadRDB(dec *core.Decoder) error
}

DB is the interface for redis style storage engine

type DBEngine

type DBEngine interface {
	DB
	ExecWithLock(conn redis.Connection, cmdLine [][]byte) redis.Reply
	ExecMulti(conn redis.Connection, watching map[string]uint32, cmdLines []CmdLine) redis.Reply
	GetUndoLogs(dbIndex int, cmdLine [][]byte) []CmdLine
	ForEach(dbIndex int, cb func(key string, data *DataEntity, expiration *time.Time) bool)
	RWLocks(dbIndex int, writeKeys []string, readKeys []string)
	RWUnLocks(dbIndex int, writeKeys []string, readKeys []string)
	GetDBSize(dbIndex int) (int, int)
	GetEntity(dbIndex int, key string) (*DataEntity, bool)
	GetExpiration(dbIndex int, key string) *time.Time
	SetKeyInsertedCallback(cb KeyEventCallback)
	SetKeyDeletedCallback(cb KeyEventCallback)
}

DBEngine is the embedding storage engine exposing more methods for complex application

type DataEntity

type DataEntity struct {
	Data interface{}
}

DataEntity stores data bound to a key, including a string, list, hash, set and so on

type KeyEventCallback

type KeyEventCallback func(dbIndex int, key string, entity *DataEntity)

KeyEventCallback will be called back on key event, such as key inserted or deleted may be called concurrently