Documentation
¶
Index ¶
- Constants
- type LevelDbProcess
- func (b *LevelDbProcess) BatchQGet(size int) (r [][]byte, err error)
- func (b *LevelDbProcess) BatchQSet(value [][]byte) (err error)
- func (b *LevelDbProcess) BatchSet(keys [][]byte, values [][]byte) (err error)
- func (b *LevelDbProcess) Delete(key []byte) (err error)
- func (b *LevelDbProcess) Exists(key []byte) (r bool, err error)
- func (b *LevelDbProcess) Get(key []byte) ([]byte, error)
- func (b *LevelDbProcess) QGet() (r []byte, err error)
- func (b *LevelDbProcess) QSet(value []byte) (err error)
- func (b *LevelDbProcess) Scan(key_start []byte, key_end []byte, limit int) (key [][]byte, value [][]byte, err error)
- func (b *LevelDbProcess) Set(key []byte, value []byte) (err error)
- type ProcessorManager
Constants ¶
View Source
const ( Put = iota Delete )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type LevelDbProcess ¶
type LevelDbProcess struct {
// contains filtered or unexported fields
}
func NewLevelDbProcess ¶
func NewLevelDbProcess(name string, tb *tables.Table) *LevelDbProcess
func (*LevelDbProcess) BatchQGet ¶
func (b *LevelDbProcess) BatchQGet(size int) (r [][]byte, err error)
Parameters:
- Size
func (*LevelDbProcess) BatchQSet ¶
func (b *LevelDbProcess) BatchQSet(value [][]byte) (err error)
Parameters:
- Value
func (*LevelDbProcess) BatchSet ¶
func (b *LevelDbProcess) BatchSet(keys [][]byte, values [][]byte) (err error)
Parameters:
- Keys
- Values
func (*LevelDbProcess) Delete ¶
func (b *LevelDbProcess) Delete(key []byte) (err error)
Parameters:
- Key
func (*LevelDbProcess) Exists ¶
func (b *LevelDbProcess) Exists(key []byte) (r bool, err error)
Parameters:
- Key
func (*LevelDbProcess) Get ¶
func (b *LevelDbProcess) Get(key []byte) ([]byte, error)
Parameters:
- Key
func (*LevelDbProcess) QGet ¶
func (b *LevelDbProcess) QGet() (r []byte, err error)
func (*LevelDbProcess) QSet ¶
func (b *LevelDbProcess) QSet(value []byte) (err error)
Parameters:
- Value
type ProcessorManager ¶
type ProcessorManager struct {
// contains filtered or unexported fields
}
func NewProcessorManager ¶
func NewProcessorManager(tm *tables.TableManager) *ProcessorManager
func (*ProcessorManager) GetProcessor ¶
func (p *ProcessorManager) GetProcessor(name string) (common.Processor, error)
Source Files
Click to show internal directories.
Click to hide internal directories.