Documentation
¶
Index ¶
- Constants
- type Table
- func (t *Table) BatchDelete(keys [][]byte) error
- func (t *Table) BatchSet(keys [][]byte, values [][]byte) error
- func (t *Table) Close() error
- func (t *Table) Delete(key []byte) error
- func (t *Table) Exists(key []byte) (bool, error)
- func (t *Table) Get(key []byte) ([]byte, error)
- func (t *Table) Info() map[string]string
- func (t *Table) Scan(start, end []byte, limit int) (key [][]byte, value [][]byte, err error)
- func (t *Table) Set(key, value []byte) error
- type TableInfo
- type TableManager
- type TableServer
Constants ¶
View Source
const ( TimeFormat = "2006-01-02 15:04:05" SetTable = 0 DeleteTable = 1 )
View Source
const BadCommand = "Incorrect command format"
View Source
const (
MinTimeFormat = "20060102150405"
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Table ¶
type Table struct {
TableInfo
// contains filtered or unexported fields
}
func (*Table) Info ¶
get table info leveldb.num-files-at-level{n} Returns the number of files at level 'n'. leveldb.stats Returns statistics of the underlying DB. leveldb.iostats Returns statistics of effective disk read and write. leveldb.writedelay Returns cumulative write delay caused by compaction. leveldb.sstables Returns sstables list for each level. leveldb.blockpool Returns block pool stats. leveldb.cachedblock Returns size of cached block. leveldb.openedtables Returns number of opened tables. leveldb.alivesnaps Returns number of alive snapshots. leveldb.aliveiters Returns number of alive iterators.
type TableInfo ¶
type TableInfo struct {
Name string
CreateTime time.Time
Host string
// contains filtered or unexported fields
}
func (*TableInfo) GetQueueId ¶
type TableManager ¶
type TableManager struct {
TableEvent func(info *TableInfo, eventType byte)
// contains filtered or unexported fields
}
func NewTableManager ¶
func NewTableManager(cfg *common.Config, tables []*TableInfo) (t *TableManager)
create new table manager
func (*TableManager) DeleteTable ¶
func (t *TableManager) DeleteTable(name string) (err error)
delete a table
type TableServer ¶
type TableServer struct {
// contains filtered or unexported fields
}
Source Files
Click to show internal directories.
Click to hide internal directories.