metrics

func EmitBlockchainPublish(payloadType string, duration time.Duration)

func EmitBlockchainWaitForTransaction(duration float64)

func EmitIndexerCurrentBlock(contractAddress string, block uint64)

func EmitIndexerCurrentBlockLag(contractAddress string, lag uint64)

func EmitIndexerGetLogsDuration(contractAddress string, duration time.Duration)

func EmitIndexerLogProcessingTime(duration time.Duration)

func EmitIndexerMaxBlock(contractAddress string, block uint64)

func EmitIndexerNumLogsFound(contractAddress string, numLogs int)

func EmitIndexerRetryableStorageError(contractAddress string)

func EmitMigratorDestLastSequenceIDBlockchain(table string, sequenceID int64)

func EmitMigratorDestLastSequenceIDDatabase(table string, sequenceID int64)

func EmitMigratorE2ELatency(table, destination string, duration float64)

func EmitMigratorReaderError(table, errorType string)

func EmitMigratorReaderFetchDuration(table string, duration float64)

func EmitMigratorReaderNumRowsFound(table string, numRows int64)

func EmitMigratorSourceLastSequenceID(table string, sequenceID int64)

func EmitMigratorTransformerError(table string)

func EmitMigratorWriterError(table, destination, errorType string)

func EmitMigratorWriterLatency(table, destination string, duration float64)

func EmitMigratorWriterRetryAttempts(table, destination string, attempts int)

func EmitMigratorWriterRowsMigrated(table string, numRows int64)

func EmitNewConnectionRequestVersion(version string)

func EmitNewFailedGRPCRequest(code codes.Code)

func EmitPayerBanlistRetries(originatorID uint32, retries int)

func EmitPayerBlockUntilDesiredCursorReached(originatorID uint32, duration float64)

func EmitPayerCurrentNonce(nonce float64)

func EmitPayerGetReaderNodeAvailableNodes(count int)

func EmitPayerMessageOriginated(originatorID uint32, count int)

func EmitPayerNodePublishDuration(originatorID uint32, duration float64)

func EmitSyncLastSeenOriginatorSequenceID(originatorID uint32, lastSequence uint64)

func EmitSyncOriginatorErrorMessages(originatorID uint32, count int)

func EmitSyncOriginatorReceivedMessagesCount(originatorID uint32, count int)

func MeasureGetLogs[Return any](contractAddress string, fn func() (Return, error)) (Return, error)

func MeasurePublishToBlockchainMethod[Return any](
	payloadType string,
	fn func() (Return, error),
) (Return, error)

func MeasureReaderLatency[Return any](table string, fn func() (Return, error)) (Return, error)

func MeasureWriterLatency(
	table, destination string,
	fn func() error,
) error