delayed

package

v0.3.1 Latest Latest Go to latest Published: Dec 5, 2019 License: MIT Imports: 4 Imported by: 30

Details

Package delayed wraps a datastore allowing to artificially delay all operations.

This section is empty.

This section is empty.

This section is empty.

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

Delayed is an adapter that delays operations on the inner datastore.

func New(ds ds.Datastore, delay delay.D) *Delayed

New returns a new delayed datastore.

func (dds *Delayed) Batch() (ds.Batch, error)

Batch implements the ds.Batching interface.

func (dds *Delayed) Close() error

Close closes the inner datastore (if it implements the io.Closer interface).

func (dds *Delayed) Delete(key ds.Key) (err error)

Delete implements the ds.Datastore interface.

func (dds *Delayed) DiskUsage() (uint64, error)

DiskUsage implements the ds.PersistentDatastore interface.

func (dds *Delayed) Get(key ds.Key) (value []byte, err error)

Get implements the ds.Datastore interface.

func (dds *Delayed) GetSize(key ds.Key) (size int, err error)

GetSize implements the ds.Datastore interface.

func (dds *Delayed) Has(key ds.Key) (exists bool, err error)

Has implements the ds.Datastore interface.

func (dds *Delayed) Put(key ds.Key, value []byte) (err error)

Put implements the ds.Datastore interface.

func (dds *Delayed) Query(q dsq.Query) (dsq.Results, error)

Query implements the ds.Datastore interface.

func (dds *Delayed) Sync(prefix ds.Key) error

Sync implements Datastore.Sync