cutter

type BatchCutter struct {
	// contains filtered or unexported fields
}

type Committer = func() (pending uint, err error)

type OperationQueue interface {
	// Add adds the given operation to the tail of the queue and returns the new length of the queue.
	Add(data *operation.QueuedOperation, protocolVersion uint64) (uint, error)
	// Remove removes (up to) the given number of items from the head of the queue and returns:
	// - The operations that are to be removed.
	// - The 'Ack' function that must be called to commit the remove.
	// - The 'Nack' function that must be called to roll back the remove.
	Remove(num uint) (ops operation.QueuedOperationsAtTime, ack func() uint, nack func(error), err error)
	// Peek returns (up to) the given number of operations from the head of the queue but does not remove them.
	Peek(num uint) (operation.QueuedOperationsAtTime, error)
	// Len returns the number of operation in the queue.
	Len() uint
}

type Result struct {
	// Operations holds the operations that were cut from the queue
	Operations []*operation.QueuedOperation
	// ProtocolVersion is the genesis time of the protocol version that was used to add the operations to the queue
	ProtocolVersion uint64
	// Pending is the number of operations remaining in the queue
	Pending uint
	// Ack commits the remove from the queue and returns the number of pending operations.
	Ack func() uint
	// Nack rolls back the remove so that a retry may occur.
	Nack func(error)
}