stoabs

package module

Go to main page

Versions in this module

v1

v1.10.0

Oct 8, 2024

v1.9.0

Jul 5, 2023

v1.8.1

Apr 5, 2023

v1.8.0

Apr 5, 2023

v1.7.1

Mar 24, 2023

Changes in this version

type MockReader

+ func (m *MockReader) Empty() (bool, error)

type MockReaderMockRecorder

+ func (mr *MockReaderMockRecorder) Empty() *gomock.Call

type MockWriter

+ func (m *MockWriter) Empty() (bool, error)

type MockWriterMockRecorder

+ func (mr *MockWriterMockRecorder) Empty() *gomock.Call

v1.7.0

Mar 23, 2023

Changes in this version

type NilReader

+ func (n NilReader) Empty() (bool, error)

type Reader

+ Empty func() (bool, error)

v1.6.0

Jan 3, 2023

Changes in this version

+ var ErrKeyNotFound = errors.New("key not found")

v1.5.1

Dec 8, 2022

v1.5.0

Dec 8, 2022

Changes in this version

type Writer

+ func NewErrorWriter(err error) Writer

v1.4.0

Nov 29, 2022

v1.3.0

Oct 7, 2022

v1.2.1

Oct 5, 2022

v1.2.0

Sep 30, 2022

Changes in this version

+ func DatabaseError(err error) error

+ type ErrDatabase struct

+ func (e ErrDatabase) Error() string

+ func (e ErrDatabase) Is(other error) bool

+ func (e ErrDatabase) Unwrap() error

v1.1.0

Sep 16, 2022

v1.0.0

Aug 30, 2022

Changes in this version

+ const DefaultTransactionTimeout

+ var ErrCommitFailed = errors.New("unable to commit transaction")

+ var ErrStoreIsClosed = errors.New("database not open")

+ type AfterCommitOption struct

+ func (o AfterCommitOption) Invoke(opts []TxOption)

+ type BytesKey []byte

+ func (b BytesKey) Bytes() []byte

+ func (b BytesKey) Equals(other Key) bool

+ func (b BytesKey) FromBytes(i []byte) (Key, error)

+ func (b BytesKey) FromString(i string) (Key, error)

+ func (b BytesKey) Next() Key

+ func (b BytesKey) String() string

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

+ type Config struct

+ LockAcquireTimeout time.Duration

+ Log *logrus.Logger

+ NoSync bool

+ func DefaultConfig() Config

+ type HashKey [32]byte

+ func (s HashKey) Bytes() []byte

+ func (s HashKey) Equals(other Key) bool

+ func (s HashKey) FromBytes(i []byte) (Key, error)

+ func (s HashKey) FromString(i string) (Key, error)

+ func (s HashKey) Next() Key

+ func (s HashKey) String() string

+ type KVStore interface

+ Read func(ctx context.Context, fn func(ReadTx) error) error

+ ReadShelf func(ctx context.Context, shelfName string, fn func(Reader) error) error

+ Write func(ctx context.Context, fn func(WriteTx) error, opts ...TxOption) error

+ WriteShelf func(ctx context.Context, shelfName string, fn func(Writer) error) error

+ type Key interface

+ Bytes func() []byte

+ Equals func(other Key) bool

+ FromBytes func([]byte) (Key, error)

+ FromString func(string) (Key, error)

+ Next func() Key

+ func NewHashKey(bytes [32]byte) Key

+ type MockKVStore struct

+ func NewMockKVStore(ctrl *gomock.Controller) *MockKVStore

+ func (m *MockKVStore) Close(ctx context.Context) error

+ func (m *MockKVStore) EXPECT() *MockKVStoreMockRecorder

+ func (m *MockKVStore) Read(ctx context.Context, fn func(ReadTx) error) error

+ func (m *MockKVStore) ReadShelf(ctx context.Context, shelfName string, fn func(Reader) error) error

+ func (m *MockKVStore) Write(ctx context.Context, fn func(WriteTx) error, opts ...TxOption) error

+ func (m *MockKVStore) WriteShelf(ctx context.Context, shelfName string, fn func(Writer) error) error

+ type MockKVStoreMockRecorder struct

+ func (mr *MockKVStoreMockRecorder) Close(ctx interface{}) *gomock.Call

+ func (mr *MockKVStoreMockRecorder) Read(ctx, fn interface{}) *gomock.Call

+ func (mr *MockKVStoreMockRecorder) ReadShelf(ctx, shelfName, fn interface{}) *gomock.Call

+ func (mr *MockKVStoreMockRecorder) Write(ctx, fn interface{}, opts ...interface{}) *gomock.Call

+ func (mr *MockKVStoreMockRecorder) WriteShelf(ctx, shelfName, fn interface{}) *gomock.Call

+ type MockReadTx struct

+ func NewMockReadTx(ctrl *gomock.Controller) *MockReadTx

+ func (m *MockReadTx) EXPECT() *MockReadTxMockRecorder

+ func (m *MockReadTx) GetShelfReader(shelfName string) Reader

+ func (m *MockReadTx) Store() KVStore

+ func (m *MockReadTx) Unwrap() interface{}

+ type MockReadTxMockRecorder struct

+ func (mr *MockReadTxMockRecorder) GetShelfReader(shelfName interface{}) *gomock.Call

+ func (mr *MockReadTxMockRecorder) Store() *gomock.Call

+ func (mr *MockReadTxMockRecorder) Unwrap() *gomock.Call

+ type MockReader struct

+ func NewMockReader(ctrl *gomock.Controller) *MockReader

+ func (m *MockReader) EXPECT() *MockReaderMockRecorder

+ func (m *MockReader) Get(key Key) ([]byte, error)

+ func (m *MockReader) Iterate(callback CallerFn, keyType Key) error

+ func (m *MockReader) Range(from, to Key, callback CallerFn, stopAtNil bool) error

+ func (m *MockReader) Stats() ShelfStats

+ type MockReaderMockRecorder struct

+ func (mr *MockReaderMockRecorder) Get(key interface{}) *gomock.Call

+ func (mr *MockReaderMockRecorder) Iterate(callback, keyType interface{}) *gomock.Call

+ func (mr *MockReaderMockRecorder) Range(from, to, callback, stopAtNil interface{}) *gomock.Call

+ func (mr *MockReaderMockRecorder) Stats() *gomock.Call

+ type MockStore struct

+ func NewMockStore(ctrl *gomock.Controller) *MockStore

+ func (m *MockStore) Close(ctx context.Context) error

+ func (m *MockStore) EXPECT() *MockStoreMockRecorder

+ type MockStoreMockRecorder struct

+ func (mr *MockStoreMockRecorder) Close(ctx interface{}) *gomock.Call

+ type MockTxOption struct

+ func NewMockTxOption(ctrl *gomock.Controller) *MockTxOption

+ func (m *MockTxOption) EXPECT() *MockTxOptionMockRecorder

+ type MockTxOptionMockRecorder struct

+ type MockWriteTx struct

+ func NewMockWriteTx(ctrl *gomock.Controller) *MockWriteTx

+ func (m *MockWriteTx) EXPECT() *MockWriteTxMockRecorder

+ func (m *MockWriteTx) GetShelfReader(shelfName string) Reader

+ func (m *MockWriteTx) GetShelfWriter(shelfName string) (Writer, error)

+ func (m *MockWriteTx) Store() KVStore

+ func (m *MockWriteTx) Unwrap() interface{}

+ type MockWriteTxMockRecorder struct

+ func (mr *MockWriteTxMockRecorder) GetShelfReader(shelfName interface{}) *gomock.Call

+ func (mr *MockWriteTxMockRecorder) GetShelfWriter(shelfName interface{}) *gomock.Call

+ func (mr *MockWriteTxMockRecorder) Store() *gomock.Call

+ func (mr *MockWriteTxMockRecorder) Unwrap() *gomock.Call

+ type MockWriter struct

+ func NewMockWriter(ctrl *gomock.Controller) *MockWriter

+ func (m *MockWriter) Delete(key Key) error

+ func (m *MockWriter) EXPECT() *MockWriterMockRecorder

+ func (m *MockWriter) Get(key Key) ([]byte, error)

+ func (m *MockWriter) Iterate(callback CallerFn, keyType Key) error

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

+ func (m *MockWriter) Range(from, to Key, callback CallerFn, stopAtNil bool) error

+ func (m *MockWriter) Stats() ShelfStats

+ type MockWriterMockRecorder struct

+ func (mr *MockWriterMockRecorder) Delete(key interface{}) *gomock.Call

+ func (mr *MockWriterMockRecorder) Get(key interface{}) *gomock.Call

+ func (mr *MockWriterMockRecorder) Iterate(callback, keyType interface{}) *gomock.Call

+ func (mr *MockWriterMockRecorder) Put(key, value interface{}) *gomock.Call

+ func (mr *MockWriterMockRecorder) Range(from, to, callback, stopAtNil interface{}) *gomock.Call

+ func (mr *MockWriterMockRecorder) Stats() *gomock.Call

+ type NilReader struct

+ func (n NilReader) Get(_ Key) ([]byte, error)

+ func (n NilReader) Iterate(_ CallerFn, _ Key) error

+ func (n NilReader) Range(_ Key, to Key, _ CallerFn, _ bool) error

+ func (n NilReader) Stats() ShelfStats

+ type OnRollbackOption struct

+ func (o OnRollbackOption) Invoke(opts []TxOption)

+ type Option func(config *Config)

+ func WithLockAcquireTimeout(value time.Duration) Option

+ func WithLogger(log *logrus.Logger) Option

+ func WithNoSync() Option

+ type ReadTx interface

+ GetShelfReader func(shelfName string) Reader

+ Store func() KVStore

+ Unwrap func() interface{}

+ type Reader interface

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

+ Iterate func(callback CallerFn, keyType Key) error

+ Range func(from Key, to Key, callback CallerFn, stopAtNil bool) error

+ Stats func() ShelfStats

+ type ShelfStats struct

+ NumEntries uint

+ ShelfSize uint

+ type Store interface

+ Close func(ctx context.Context) error

+ type TxOption interface

+ func AfterCommit(fn func()) TxOption

+ func OnRollback(fn func()) TxOption

+ func WithWriteLock() TxOption

+ type Uint32Key uint32

+ func (u Uint32Key) Bytes() []byte

+ func (u Uint32Key) Equals(other Key) bool

+ func (u Uint32Key) FromBytes(i []byte) (Key, error)

+ func (u Uint32Key) FromString(i string) (Key, error)

+ func (u Uint32Key) Next() Key

+ func (u Uint32Key) String() string

+ type WriteLockOption struct

+ func (w WriteLockOption) Enabled(opts []TxOption) bool

+ type WriteTx interface

+ GetShelfWriter func(shelfName string) (Writer, error)

+ type Writer interface

+ Delete func(key Key) error

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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL