Package throttle includes throttlers for composing in various contexts, such as inside Mounts for costly operations, and within the DAG store itself.

NewDAGStore constructs a new DAG store with the supplied configuration.

RecoverImmediately takes a failureCh where DAGStore failures are sent, and attempts to recover the shard immediately up until maxAttempts for each unique shard.

DoNotRecover will not recover any failed shards on start.

RecoverNow will eagerly trigger a recovery for all failed shards upon start.

RecoverOnAcquire will automatically queue a recovery for a failed shard on the first acquire attempt, and will park that acquire while recovery is in progress.

ShardStateAvailable indicates that the shard has been initialized and is active for serving queries.

ShardStateErrored indicates that an unexpected error was encountered during a shard operation, and therefore the shard needs to be recovered.

ShardStateInitializing indicates that the shard is being initialized by being fetched from the mount and being indexed.

ShardStateNew indicates that a shard has just been registered and is about to be processed for activation.

ShardStateRecovering indicates that the shard is recovering from an errored state.

ShardStateServing indicates the shard has active readers and thus is currently actively serving requests.

ShardStateUnknown indicates that it's not possible to determine the state of the shard.

ErrShardExists is the error returned upon registering a duplicate shard.

ErrShardInitializationFailed is returned when shard initialization fails.

ErrShardInUse is returned when the user attempts to destroy a shard that is in use.

ErrShardUnknown is the error returned when the requested shard is not known to the DAG store.

StoreNamespace is the namespace under which shard state will be persisted.

DAGStore is the central object of the DAG store.

GCResult is the result of performing a GC operation.

PersistedShard is the persistent representation of the Shard.

Shard encapsulates the state of a shard within the DAG store.

ShardAccessor provides various means to access the data contained in a shard.

ShardResult encapsulates a result from an asynchronous operation.

Interface is the publicly exposed interface of the DAGStore.

ReadBlockstore is a read-only view of Blockstores.

RecoverOnStartPolicy specifies the recovery policy for failed shards on DAGStore start.