store

type BatchInput struct {
	ID     string
	Offset uint64
	Data   [][]byte
}

type BatchOutput struct {
	ID     string
	Offset uint64
	Count  int
	Err    error
}

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

type Options struct {
	// Path is the file path to the BoltDB to use
	Path string

	// BoltOptions contains any specific BoltDB options you might
	// want to specify [e.g. open timeout]
	BoltOptions *bolt.Options

	// NoSync causes the database to skip fsync calls after each
	// write to the log. This is unsafe, so it should be used
	// with caution.
	NoSync bool
}

type Store interface {
	DeleteQueue(id string) error
	CreateQueue(id string) error
	Put(id string, index uint64, payload []byte) error
	GetRange(id string, from uint64, buff [][]byte) (uint64, int, error)
	All() []string
}