package delayed

import "github.com/ipfs/go-datastore/delayed"

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

Index ¶

• type Delayed
• func New(ds ds.Datastore, delay delay.D) *Delayed
• func (dds *Delayed) Batch(ctx context.Context) (ds.Batch, error)
• func (dds *Delayed) Close() error
• func (dds *Delayed) Delete(ctx context.Context, key ds.Key) (err error)
• func (dds *Delayed) DiskUsage(ctx context.Context) (uint64, error)
• func (dds *Delayed) Get(ctx context.Context, key ds.Key) (value []byte, err error)
• func (dds *Delayed) GetSize(ctx context.Context, key ds.Key) (size int, err error)
• func (dds *Delayed) Has(ctx context.Context, key ds.Key) (exists bool, err error)
• func (dds *Delayed) Put(ctx context.Context, key ds.Key, value []byte) (err error)
• func (dds *Delayed) Query(ctx context.Context, q dsq.Query) (dsq.Results, error)
• func (dds *Delayed) Sync(ctx context.Context, prefix ds.Key) error

Types ¶

type Delayed ¶

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

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

func New ¶

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

New returns a new delayed datastore.

func (*Delayed) Batch ¶

func (dds *Delayed) Batch(ctx context.Context) (ds.Batch, error)

Batch implements the ds.Batching interface.

func (*Delayed) Close ¶

func (dds *Delayed) Close() error

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

func (*Delayed) Delete ¶

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

Delete implements the ds.Datastore interface.

func (*Delayed) DiskUsage ¶

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

DiskUsage implements the ds.PersistentDatastore interface.

func (*Delayed) Get ¶

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

Get implements the ds.Datastore interface.

func (*Delayed) GetSize ¶

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

GetSize implements the ds.Datastore interface.

func (*Delayed) Has ¶

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

Has implements the ds.Datastore interface.

func (*Delayed) Put ¶

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

Put implements the ds.Datastore interface.

func (*Delayed) Query ¶

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

Query implements the ds.Datastore interface.

func (*Delayed) Sync ¶

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

Sync implements Datastore.Sync

Source Files ¶

delayed.go