operationqueue

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
  • func NewProvider(cfg peerConfig) *Provider
  • func (p *Provider) Close()
  • func (p *Provider) Create(channelID, namespace string) (cutter.OperationQueue, error)

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) Close

func (q *LevelDBQueue) Close()

Close closes the database

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.

func (*LevelDBQueue) Remove

func (q *LevelDBQueue) Remove(num uint) (uint, uint, error)

Remove removes the given number of operation from the head of the queue. The operation are returned along with the new size of the queue and any error.

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

func (*Provider) Close

func (p *Provider) Close()

Close closes all databases

func (*Provider) Create

func (p *Provider) Create(channelID, namespace string) (cutter.OperationQueue, error)

Create returns the operation queue for the given channel