Documentation
¶
Index ¶
- type LevelDBQueue
- func (q *LevelDBQueue) Add(op *operation.QueuedOperation, protocolGenesisTime uint64) (uint, error)
- func (q *LevelDBQueue) Close()
- func (q *LevelDBQueue) Drop() error
- func (q *LevelDBQueue) Len() uint
- func (q *LevelDBQueue) Peek(num uint) ([]*operation.QueuedOperationAtTime, error)
- func (q *LevelDBQueue) Remove(num uint) (uint, uint, error)
- type Provider
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type LevelDBQueue ¶
type LevelDBQueue struct {
// contains filtered or unexported fields
}
LevelDBQueue implements an operation queue that's backed by a LevelDB persistent store
func (*LevelDBQueue) Add ¶
func (q *LevelDBQueue) Add(op *operation.QueuedOperation, protocolGenesisTime uint64) (uint, error)
Add adds the given operation to the tail of the queue
func (*LevelDBQueue) Drop ¶
func (q *LevelDBQueue) Drop() error
Drop deletes the database. Note that the queue must be closed before this operation may be performed.
func (*LevelDBQueue) Len ¶
func (q *LevelDBQueue) Len() uint
Len returns the number of operation in the queue
func (*LevelDBQueue) Peek ¶
func (q *LevelDBQueue) Peek(num uint) ([]*operation.QueuedOperationAtTime, error)
Peek returns the given number of operation at the head of the queue without removing them.
type Provider ¶
type Provider struct {
// contains filtered or unexported fields
}
Provider manages operation queues
func NewProvider ¶
func NewProvider(cfg peerConfig) *Provider
NewProvider returns a new Operation LevelDBQueue provider
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.