Repository files navigation

Buffered FIFO interface to the datastore

The dsqueue package provides a buffered FIFO queue backed by aBatching Datastore. Queued items are persisted in the datastore when the input buffer is full, after some amount of idle time, and when the queue is shuddown.

https://pkg.go.dev/github.com/ipfs/go-dsqueue

ds=getBatchingDatastore()dsq:=dsqueue.New(ds,"ExampleQueue")deferdsq.Close()c,err:=cid.Decode("QmPNHBy5h7f19yJDt7ip9TvmMRbqmYsa6aetkrsc1ghjLB")iferr!=nil {panic(err)}dsq.Put(c.Bytes())out:=<-dsq.Out()c2,err:=cid.Parse(out)iferr!=nil {panic(err)}ifc2!=c {fmt.Fprintln(os.Stderr,"cids are not quual")}

@gammazero

Contributions are welcome! This repository is part of the IPFS project and therefore governed by ourcontributing guidelines.

SPDX-License-Identifier: Apache-2.0 OR MIT