Versions in this module Expand all Collapse all v1 v1.8.3 May 26, 2023 v1.8.2 May 26, 2023 v1.8.1 May 24, 2023 Changes in this version + type Queue struct + func NewQueue(ctx context.Context, name string, ds datastore.Datastore) (*Queue, error) + func (q *Queue) Close() error + func (q *Queue) Dequeue() <-chan cid.Cid + func (q *Queue) Enqueue(cid cid.Cid) error
Go to main page