Specs

abort_transaction(session()) :: :ok | {:error, term()}

Abort current transaction and rollback changes introduced by it. It will error if the session is invalid.

Specs

commit_transaction(session()) :: :ok | {:error, term()}

Commit current transaction. It will error if the session is in invalid state.

Specs

end_session(session()) :: :ok

Finish current session and rollback uncommited transactions if any.

WARNING: Session is ended in asynchronous manner, which mean, that the process itself can be still available and Mongo.Session.ended?(session) can still return false for some time after calling this function.

Specs

ended?(session()) :: boolean()

Check whether given session has already ended.

Specs

start_transaction(session(), keyword()) :: :ok | {:error, term()}

Start new transaction within current session.

Specs

with_transaction(session(), keyword(), (() -> return)) ::
  {:ok, return} | {:error, term()}
when return: term()

Run provided func within transaction and automatically commit it if there was no exceptions.