func()

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
}