Documentation
¶
Index ¶
- Constants
- func BalanceInternalKey(organizationID, ledgerID uuid.UUID, key string) string
- func FullJitter(baseDelay time.Duration) time.Duration
- func GenericInternalKey(name, contextName, organizationID, ledgerID, key string) string
- func NextBackoff(current time.Duration) time.Duration
- func RedisConsumerLockKey(organizationID, ledgerID uuid.UUID, transactionID string) string
- func SanitizeAccountAliases(parserDSL *libTransaction.Transaction)
- func TransactionInternalKey(organizationID, ledgerID uuid.UUID, key string) string
- func WriteBehindTransactionKey(organizationID, ledgerID uuid.UUID, transactionID string) string
Constants ¶
const ( MaxRetries = 5 InitialBackoff = 500 * time.Millisecond MaxBackoff = 10 * time.Second BackoffFactor = 2.0 )
Variables ¶
This section is empty.
Functions ¶
func BalanceInternalKey ¶ added in v3.3.6
BalanceInternalKey returns a key with the following format to be used on redis cluster: "balance:{contextName}:organizationID:ledgerID:key"
func FullJitter ¶
FullJitter returns a random delay between [0, baseDelay], capped by MaxBackoff.
func GenericInternalKey ¶ added in v3.3.6
GenericInternalKey returns a key with the following format to be used on redis cluster: "name:{contextName}:organizationID:ledgerID:key"
func NextBackoff ¶
NextBackoff calculates the next exponential backoff, respecting the MaxBackoff capped.
func RedisConsumerLockKey ¶ added in v3.3.11
RedisConsumerLockKey returns a key with the following format to be used on redis cluster: "redis_consumer_lock:{organizationID:ledgerID}:transactionID" This key is used to prevent duplicate processing of the same transaction across multiple pods.
func SanitizeAccountAliases ¶ added in v3.3.13
func SanitizeAccountAliases(parserDSL *libTransaction.Transaction)
SanitizeAccountAliases cleans the AccountAlias fields in a Transaction's FromTo entries. This is necessary because HandleAccountFields mutates aliases in-place using ConcatAlias, producing formats like "0#@alias#key". SplitAlias extracts the original alias back.
func TransactionInternalKey ¶ added in v3.3.6
TransactionInternalKey returns a key with the following format to be used on redis cluster: "transaction:{contextName}:organizationID:ledgerID:key"
func WriteBehindTransactionKey ¶ added in v3.3.15
WriteBehindTransactionKey returns a key with the following format to be used on redis cluster: "wb_transaction:{organizationID:ledgerID:transactionID}" This key is used to store transaction data in the write-behind cache before persistence. The transactionID is included inside the hash tag so keys distribute evenly across Redis Cluster slots. Co-location via {orgID:ledgerID} is not needed here because write-behind keys are always accessed individually (SET/GET/DEL), never in multi-key operations.
Types ¶
This section is empty.
Source Files