tx

Apr 6, 2026

Changes in this version

+ var ErrTransactionCommitted = errors.New("transaction already committed")

+ var ErrTransactionRolledBack = errors.New("transaction already rolled back")

+ var ErrTxClosed = errors.New("transaction is closed")

+ type MemoryManager struct

+ func NewMemoryManager(store *storage.MemoryDB) *MemoryManager

+ func (m *MemoryManager) Begin(readOnly bool) (*MemoryTransaction, error)

+ type MemoryTransaction struct

+ func (t *MemoryTransaction) Commit() error

+ func (t *MemoryTransaction) Delete(key []byte) error

+ func (t *MemoryTransaction) Get(key []byte) ([]byte, error)

+ func (t *MemoryTransaction) IsClosed() bool

+ func (t *MemoryTransaction) IsReadOnly() bool

+ func (t *MemoryTransaction) Put(key, value []byte) error

+ func (t *MemoryTransaction) Rollback() error

+ type Tx interface

+ Commit func() error

+ Delete func(key []byte) error

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

+ IsClosed func() bool

+ IsReadOnly func() bool

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

+ Rollback func() error

Mar 28, 2026

Changes in this version

+ var ErrReadOnlyTransaction = errors.New("read only transaction")

+ var ErrTransactionClosed = errors.New("transaction closed")

+ type Manager struct

+ func NewManager(store *storage.DB) *Manager

+ func (m *Manager) Begin(readOnly bool) (*Transaction, error)

+ type Transaction struct

+ func (t *Transaction) Commit() error

+ func (t *Transaction) Delete(key []byte) error

+ func (t *Transaction) Get(key []byte) ([]byte, error)

+ func (t *Transaction) IsClosed() bool

+ func (t *Transaction) IsReadOnly() bool

+ func (t *Transaction) Put(key, value []byte) error

+ func (t *Transaction) Rollback() error