in qldbdriver/transaction.go [91:104]
func (txn *transaction) commit(ctx context.Context) error {
commitResult, err := txn.communicator.commitTransaction(ctx, txn.id, txn.commitHash.hash)
if err != nil {
return err
}
if !reflect.DeepEqual(commitResult.CommitDigest, txn.commitHash.hash) {
return &qldbDriverError{
errorMessage: "Transaction's commit digest did not match returned value from QLDB. Please retry with a new transaction.",
}
}
return nil
}