retrystore

type Datastore ¶

type Datastore struct {
	TempErrFunc func(error) bool
	Retries     int
	Delay       time.Duration

	ds.Batching
}

Datastore wraps a Batching datastore with a user-provided TempErrorFunc -which determines if an error is a temporal error and thus, worth retrying-, an amount of Retries -which specify how many times to retry an operation after a temporal error- and a base Delay, which is multiplied by the current retry and performs a pause before attempting the operation again.

func (d *Datastore) DiskUsage() (uint64, error)

func (d *Datastore) Get(k ds.Key) (interface{}, error)

func (d *Datastore) Has(k ds.Key) (bool, error)

func (d *Datastore) Put(k ds.Key, val interface{}) error