datastore

Feb 19, 2025

Changes in this version

type Key

+ func (k Key) RootNamespace() string

Aug 17, 2022

Changes in this version

+ const FeatureNameBatching

+ const FeatureNameChecked

+ const FeatureNameGC

+ const FeatureNamePersistent

+ const FeatureNameScrubbed

+ const FeatureNameTTL

+ const FeatureNameTransaction

+ type BatchingFeature interface

+ Batch func(ctx context.Context) (Batch, error)

+ type CheckedFeature interface

+ Check func(ctx context.Context) error

+ type Feature struct

+ DatastoreInterface interface{}

+ Interface interface{}

+ Name string

+ func FeatureByName(name string) (Feature, bool)

+ func Features() []Feature

+ func FeaturesForDatastore(dstore Datastore) (features []Feature)

+ type GCFeature interface

+ CollectGarbage func(ctx context.Context) error

type NullDatastore

+ func (d *NullDatastore) Check(ctx context.Context) error

+ func (d *NullDatastore) CollectGarbage(ctx context.Context) error

+ func (d *NullDatastore) DiskUsage(ctx context.Context) (uint64, error)

+ func (d *NullDatastore) NewTransaction(ctx context.Context, readOnly bool) (Txn, error)

+ func (d *NullDatastore) Scrub(ctx context.Context) error

+ type PersistentFeature interface

+ DiskUsage func(ctx context.Context) (uint64, error)

+ type ScrubbedFeature interface

+ Scrub func(ctx context.Context) error

+ type TxnFeature interface

+ NewTransaction func(ctx context.Context, readOnly bool) (Txn, error)

Dec 5, 2019

Changes in this version

type LogDatastore

+ func (d *LogDatastore) Sync(prefix Key) error

Dec 3, 2019

Changes in this version

type Datastore

+ Sync func(prefix Key) error

type MapDatastore

+ func (d *MapDatastore) Sync(prefix Key) error

type NullDatastore

+ func (d *NullDatastore) Sync(prefix Key) error

Feb 28, 2019

Changes in this version

+ var ErrBatchUnsupported = errors.New("this datastore does not support batching")

+ var ErrInvalidType = errors.New("datastore: invalid type error")

+ var ErrNotFound = errors.New("datastore: key not found")

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

+ func GetBackedHas(ds Read, key Key) (bool, error)

+ func GetBackedSize(ds Read, key Key) (int, error)

+ func NamespaceType(namespace string) string

+ func NamespaceValue(namespace string) string

+ type Batch interface

+ Commit func() error

+ func NewBasicBatch(ds Datastore) Batch

+ type Batching interface

+ Batch func() (Batch, error)

+ type CheckedDatastore interface

+ Check func() error

+ type Datastore interface

+ type GCDatastore interface

+ CollectGarbage func() error

+ type Key struct

+ func EntryKeys(e []dsq.Entry) []Key

+ func KeyWithNamespaces(ns []string) Key

+ func NewKey(s string) Key

+ func RandomKey() Key

+ func RawKey(s string) Key

+ func (k *Key) Clean()

+ func (k *Key) UnmarshalJSON(data []byte) error

+ func (k Key) BaseNamespace() string

+ func (k Key) Bytes() []byte

+ func (k Key) Child(k2 Key) Key

+ func (k Key) ChildString(s string) Key

+ func (k Key) Equal(k2 Key) bool

+ func (k Key) Instance(s string) Key

+ func (k Key) IsAncestorOf(other Key) bool

+ func (k Key) IsDescendantOf(other Key) bool

+ func (k Key) IsTopLevel() bool

+ func (k Key) Less(k2 Key) bool

+ func (k Key) List() []string

+ func (k Key) MarshalJSON() ([]byte, error)

+ func (k Key) Name() string

+ func (k Key) Namespaces() []string

+ func (k Key) Parent() Key

+ func (k Key) Path() Key

+ func (k Key) Reverse() Key

+ func (k Key) String() string

+ func (k Key) Type() string

+ type KeySlice []Key

+ func (p KeySlice) Len() int

+ func (p KeySlice) Less(i, j int) bool

+ func (p KeySlice) Swap(i, j int)

+ type LogBatch struct

+ Name string

+ func (d *LogBatch) Commit() (err error)

+ func (d *LogBatch) Delete(key Key) (err error)

+ func (d *LogBatch) Put(key Key, value []byte) (err error)

+ type LogDatastore struct

+ Name string

+ func NewLogDatastore(ds Datastore, name string) *LogDatastore

+ func (d *LogDatastore) Batch() (Batch, error)

+ func (d *LogDatastore) Check() error

+ func (d *LogDatastore) Children() []Datastore

+ func (d *LogDatastore) Close() error

+ func (d *LogDatastore) CollectGarbage() error

+ func (d *LogDatastore) Delete(key Key) (err error)

+ func (d *LogDatastore) DiskUsage() (uint64, error)

+ func (d *LogDatastore) Get(key Key) (value []byte, err error)

+ func (d *LogDatastore) GetSize(key Key) (size int, err error)

+ func (d *LogDatastore) Has(key Key) (exists bool, err error)

+ func (d *LogDatastore) Put(key Key, value []byte) (err error)

+ func (d *LogDatastore) Query(q dsq.Query) (dsq.Results, error)

+ func (d *LogDatastore) Scrub() error

+ type MapDatastore struct

+ func NewMapDatastore() (d *MapDatastore)

+ func (d *MapDatastore) Batch() (Batch, error)

+ func (d *MapDatastore) Close() error

+ func (d *MapDatastore) Delete(key Key) (err error)

+ func (d *MapDatastore) Get(key Key) (value []byte, err error)

+ func (d *MapDatastore) GetSize(key Key) (size int, err error)

+ func (d *MapDatastore) Has(key Key) (exists bool, err error)

+ func (d *MapDatastore) Put(key Key, value []byte) (err error)

+ func (d *MapDatastore) Query(q dsq.Query) (dsq.Results, error)

+ type NullDatastore struct

+ func NewNullDatastore() *NullDatastore

+ func (d *NullDatastore) Batch() (Batch, error)

+ func (d *NullDatastore) Close() error

+ func (d *NullDatastore) Delete(key Key) (err error)

+ func (d *NullDatastore) Get(key Key) (value []byte, err error)

+ func (d *NullDatastore) GetSize(key Key) (size int, err error)

+ func (d *NullDatastore) Has(key Key) (exists bool, err error)

+ func (d *NullDatastore) Put(key Key, value []byte) (err error)

+ func (d *NullDatastore) Query(q dsq.Query) (dsq.Results, error)

+ type PersistentDatastore interface

+ DiskUsage func() (uint64, error)

+ type Read interface

+ Get func(key Key) (value []byte, err error)

+ GetSize func(key Key) (size int, err error)

+ Has func(key Key) (exists bool, err error)

+ Query func(q query.Query) (query.Results, error)

+ type ScrubbedDatastore interface

+ Scrub func() error

+ type Shim interface

+ Children func() []Datastore

+ type TTL interface

+ GetExpiration func(key Key) (time.Time, error)

+ PutWithTTL func(key Key, value []byte, ttl time.Duration) error

+ SetTTL func(key Key, ttl time.Duration) error

+ type TTLDatastore interface

+ type ThreadSafeDatastore interface

+ IsThreadSafe func()

+ type Txn interface

+ Commit func() error

+ Discard func()

+ type TxnDatastore interface

+ NewTransaction func(readOnly bool) (Txn, error)

+ type Write interface

+ Delete func(key Key) error

+ Put func(key Key, value []byte) error