func (store *rocksStore) EnqueueAll(set SortedSet) error {
	return set.Each(func(idx int, key []byte, data []byte) error {
		return store.EnqueueFrom(set, key)
	})
}
Transactional operations
Enqueue all moves all jobs within the given set into the
queues associated with those jobs.
package storage
import (
	"encoding/json"
	"sync/atomic"
	"github.com/contribsys/faktory/client"
	"github.com/contribsys/gorocksdb"
)
type Transaction struct {
	batch     *gorocksdb.WriteBatch
	onSuccess func()
}
func (store *rocksStore) newTransaction() *Transaction {
	return &Transaction{
		batch: gorocksdb.NewWriteBatch(),
	}
}