Get returns the value for a given key and a bool indicating if the key was present

Choose returns a bucket for a given key

Delete removes a key from the storage, and returns a bool indicating if the key was found

Set sets the value for key

SetBuckets sets the list of known buckets from which the chooser should select

ResetConnection reinitializes the connection for the shard responsible for a key

New returns a Storage that queries multiple replicas in parallel

Adds some keys to the hash.

Get implements the shardedkv.Storage interface

AddShard adds a shard from the list of known shards

Returns true if there are no items available.

BeginMigration begins a continuum migration. All the shards in the new continuum must already be known to the KVStore via AddShard().

DeleteShard removes a shard from the list of known shards

EndMigration ends a continuum migration and marks the migration continuum as the new primary

Gets the closest item in the hash to the provided key, and following unique servers for replicas.

New returns a KVStore that uses chooser to shard the keys across the provided shards

New returns a new sql key-value store. Connector should be a function which returns an sql.DB object for the database where the table lives.

New returns a new memory-backed Storage

New returns a rest-backed storage at the given base URL using the default HTTP client

New returns a new storage, backed by the redis server at 'addr'

New returns a new Storage, storing files in 'dir'

New returns a rest-backed storage at the given base URL using a custom HTTP client

64-bit xorshift multiply rng from http://vigna.di.unimi.it/ftp/papers/xorshift.pdf

BeginMigrationWithShards begins a continuum migration using the new set of shards.

Buckets returns the list of known buckets

Delete implements Storage.Delete()

Delete implements the shardedkv.Storage interface

Get implements Storage.Get()

Gets the closest item in the hash to the provided key.

HedgedTimeout returns the timeout for a single replica to respond before querying a backup. Defaults to 1 second.

ResetConnection implements Storage.ResetConnection()

ResetConnection implements the shardedkv.Storage interface

Set implements Storage.Set()