(tx *Tx[T], keyBytes []byte)
| 482 | } |
| 483 | |
| 484 | func (this *Table[T]) getWithKeyBytes(tx *Tx[T], keyBytes []byte) (value T, err error) { |
| 485 | valueBytes, closer, err := tx.batch.Get(keyBytes) |
| 486 | if err != nil { |
| 487 | return value, err |
| 488 | } |
| 489 | defer func() { |
| 490 | _ = closer.Close() |
| 491 | }() |
| 492 | |
| 493 | resultValue, decodeErr := this.encoder.Decode(valueBytes) |
| 494 | if decodeErr != nil { |
| 495 | return value, fmt.Errorf("decode value failed: %w", decodeErr) |
| 496 | } |
| 497 | value = resultValue |
| 498 | return |
| 499 | } |