Method Load

db/journal/queue.go:148–150

(ctx context.Context, id ID)

}

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

func (q *Queue) DeleteCommit(ctx context.Context, id ID) error {
	return q.engine.Delete(ctx, q.uri(id))