Method uri

db/journal/queue.go:144–146

(id ID)

}

func (q *Queue) uri(id ID) *storage.URI {
	return q.path.JoinPath(fmt.Sprintf("%d.%s", id, ext))
}

func (q *Queue) Load(ctx context.Context, id ID) ([]byte, error) {
	return storage.Get(ctx, q.engine, q.uri(id))