storage

Jul 27, 2021

Changes in this version

type GetOperation

+ func (t *GetOperation) FetchTtl(ttl *int) *GetOperation

+ func (t *GetOperation) FetchVersion(ptr *int64) *GetOperation

Jul 27, 2021

Changes in this version

+ type CompareAndSetOperation struct

+ func (t *CompareAndSetOperation) Binary(value []byte) (bool, error)

+ func (t *CompareAndSetOperation) Bucket(bucket []byte) *CompareAndSetOperation

+ func (t *CompareAndSetOperation) ByKey(formatKey string, args ...interface{}) *CompareAndSetOperation

+ func (t *CompareAndSetOperation) ByRawKey(key []byte) *CompareAndSetOperation

+ func (t *CompareAndSetOperation) Proto(msg proto.Message) (bool, error)

+ func (t *CompareAndSetOperation) String(value string) (bool, error)

+ func (t *CompareAndSetOperation) WithTtl(ttlSeconds int) *CompareAndSetOperation

+ func (t *CompareAndSetOperation) WithVersion(version int64) *CompareAndSetOperation

type GetOperation

+ func (t *GetOperation) WithVersion(ptr *int64) *GetOperation

+ type SetOperation struct

+ func (t *SetOperation) Binary(value []byte) error

+ func (t *SetOperation) Bucket(bucket []byte) *SetOperation

+ func (t *SetOperation) ByKey(formatKey string, args ...interface{}) *SetOperation

+ func (t *SetOperation) ByRawKey(key []byte) *SetOperation

+ func (t *SetOperation) Proto(msg proto.Message) error

+ func (t *SetOperation) String(value string) error

+ func (t *SetOperation) WithTtl(ttlSeconds int) *SetOperation

type Storage

+ CompareAndSet func() *CompareAndSetOperation

+ CompareAndSetRaw func(bucket, key, value []byte, ttlSeconds int, version int64) (bool, error)

+ Set func() *SetOperation

+ SetRaw func(bucket, key, value []byte, ttlSeconds int) error

Jul 10, 2021

Changes in this version

+ const NoTTL

+ var ErrNotFound = os.ErrNotExist

+ var ManagedStorageClass = reflect.TypeOf((*ManagedStorage)(nil)).Elem()

+ var StorageClass = reflect.TypeOf((*Storage)(nil)).Elem()

+ var StorageManagementClass = reflect.TypeOf((*StorageManagement)(nil)).Elem()

+ type EnumerateOperation struct

+ func (t *EnumerateOperation) Bucket(bucket []byte) *EnumerateOperation

+ func (t *EnumerateOperation) ByPrefix(formatPrefix string, args ...interface{}) *EnumerateOperation

+ func (t *EnumerateOperation) ByRawPrefix(prefix []byte) *EnumerateOperation

+ func (t *EnumerateOperation) Do(cb func(key, value []byte) bool) error

+ func (t *EnumerateOperation) DoProto(factory func() proto.Message, cb func(key []byte, value proto.Message) bool) error

+ func (t *EnumerateOperation) OnlyKeys() *EnumerateOperation

+ func (t *EnumerateOperation) Seek(formatSeek string, args ...interface{}) *EnumerateOperation

+ func (t *EnumerateOperation) WithBatchSize(batchSize int) *EnumerateOperation

+ type GetOperation struct

+ func (t *GetOperation) Bucket(bucket []byte) *GetOperation

+ func (t *GetOperation) ByKey(formatKey string, args ...interface{}) *GetOperation

+ func (t *GetOperation) ByRawKey(key []byte) *GetOperation

+ func (t *GetOperation) Required() *GetOperation

+ func (t *GetOperation) ToBinary() ([]byte, error)

+ func (t *GetOperation) ToProto(container proto.Message) error

+ func (t *GetOperation) ToString() (string, error)

+ type ManagedStorage interface

+ Instance func() interface{}

+ type PutOperation struct

+ func (t *PutOperation) Binary(value []byte) error

+ func (t *PutOperation) Bucket(bucket []byte) *PutOperation

+ func (t *PutOperation) ByKey(formatKey string, args ...interface{}) *PutOperation

+ func (t *PutOperation) ByRawKey(key []byte) *PutOperation

+ func (t *PutOperation) Proto(msg proto.Message) error

+ func (t *PutOperation) String(value string) error

+ func (t *PutOperation) WithTtl(ttlSeconds int) *PutOperation

+ type RemoveOperation struct

+ func (t *RemoveOperation) Bucket(bucket []byte) *RemoveOperation

+ func (t *RemoveOperation) ByKey(formatKey string, args ...interface{}) *RemoveOperation

+ func (t *RemoveOperation) ByRawKey(key []byte) *RemoveOperation

+ func (t *RemoveOperation) Do() error

+ type Storage interface

+ Enumerate func() *EnumerateOperation

+ EnumerateRaw func(bucket, seek []byte, batchSize int, onlyKeys bool, ...) error

+ FetchKeysRaw func(bucket []byte, batchSize int) ([][]byte, error)

+ Get func() *GetOperation

+ GetRaw func(bucket, key []byte, required bool) ([]byte, error)

+ Put func() *PutOperation

+ PutRaw func(bucket, key, value []byte, ttlSeconds int) error

+ Remove func() *RemoveOperation

+ RemoveRaw func(bucket, key []byte) error

+ type StorageManagement interface

+ Backup func(w io.Writer, since uint64) (uint64, error)

+ Compact func(discardRatio float64) error

+ DropAll func() error

+ DropWithPrefix func(prefix []byte) error

+ Restore func(r io.Reader) error