eva.v2.system.transactor.core — com.workiva/eva 2.0.4

*max-concurrent-modification-retries* clj

*restart-delay-ms* clj

->txd-msg clj

(->txd-msg transactor-id database-id tx-report)

->txd-pub clj

(->txd-pub transactor-id database-id tx-report)

concurrent-modification-meter clj

long? clj

on-connection-error:try-restart-transactor clj

(on-connection-error:try-restart-transactor ex messenger messenger-id)

This is an error-listener function installed on the transactor's Messenger.

When a messaging connection encounters an exception, error-listener functions will be called. In the event of such an error, this function attempts to re-initiate the messenger once.

If re-initiation fails then the JVM will exit (ie. fast fail), and an external process-manager is expected to restart the process.

process-index-updates-impl clj

(process-index-updates-impl
  {:as txor :keys [database-id database-connection config transactor-id]}
  {:as updates :keys [index-updates]})

process-transaction-impl clj

(process-transaction-impl {:as txor
                           :keys [txor-timer messenger database-connection
                                  transaction-pub-addr database-id config
                                  transactor-id]}
                          {:as request :keys [tx-data]})

transactor clj

(transactor user-id {:as config})

Exists for the tracing & metrics on transactor creation. Acquires the transactor resource.

transactor* clj

(transactor* {:as config})

Constructs an uninitiated transactor from config.

transactor-manager clj

update-index-lag-gauge clj

(update-index-lag-gauge txor database-id tx-report)