Method tryGet

tx_btree.go:487–509

(bucket string, key []byte, solveRecord func(record *core.Record, entry *core.Entry, found bool, bucketId core.BucketId) error)

}

func (tx *Tx) tryGet(bucket string, key []byte, solveRecord func(record *core.Record, entry *core.Entry, found bool, bucketId core.BucketId) error) error {
	if err := tx.checkTxIsClosed(); err != nil {
		return err
	}
	status, b := tx.getBucketAndItsStatus(DataStructureBTree, bucket)
	if isBucketNotFoundStatus(status) {
		return ErrNotFoundBucket
	}
	bucketId := b.Id
	var (
		record *core.Record = nil
		found  bool
	)
	entry, err := tx.pendingWrites.Get(DataStructureBTree, bucket, key)
	found = err == nil
	if idx, ok := tx.db.Index.BTree.exist(bucketId); ok {
		record, ok = idx.Find(key)
		if ok {
			found = true
		}
	}
	return solveRecord(record, entry, found, bucketId)
}

func (tx *Tx) update(bucket string, key []byte, getNewValue func([]byte) ([]byte, error), getNewTTL func(uint32) (uint32, error)) error {
	return tx.tryGet(bucket, key, func(record *core.Record, pendingEntry *core.Entry, found bool, bucketId core.BucketId) error {