delayed

package

v0.6.0 Latest Latest Go to latest Published: Aug 17, 2022 License: MIT Imports: 5 Imported by: 26

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

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(ctx context.Context) (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(ctx context.Context, key ds.Key) (err error)

Delete implements the ds.Datastore interface.

func (dds *Delayed) DiskUsage(ctx context.Context) (uint64, error)

DiskUsage implements the ds.PersistentDatastore interface.

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

Get implements the ds.Datastore interface.

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

GetSize implements the ds.Datastore interface.

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

Has implements the ds.Datastore interface.

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

Put implements the ds.Datastore interface.

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

Query implements the ds.Datastore interface.

func (dds *Delayed) Sync(ctx context.Context, prefix ds.Key) error

Sync implements Datastore.Sync