common

Jul 23, 2026

Changes in this version

type OutboundEvent

+ Pc20WrapperAddress string

Jun 17, 2026

Changes in this version

type FundMigrationData

+ Balance *big.Int

May 13, 2026

Changes in this version

type FundMigrationData

+ L1GasFee *big.Int

type UnsignedSigningReq

+ TSSFundMigrationAmount *big.Int

Apr 1, 2026

Changes in this version

+ type FundMigrationData struct

+ From string

+ GasLimit uint64

+ GasPrice *big.Int

+ To string

+ type TxBuilder interface

+ BroadcastFundMigrationTx func(ctx context.Context, req *UnsignedSigningReq, data *FundMigrationData, ...) (string, error)

+ BroadcastOutboundSigningRequest func(ctx context.Context, req *UnsignedSigningReq, ...) (string, error)

+ GetFundMigrationSigningRequest func(ctx context.Context, data *FundMigrationData, nonce uint64) (*UnsignedSigningReq, error)

+ GetGasFeeUsed func(ctx context.Context, txHash string) (string, error)

+ GetNextNonce func(ctx context.Context, signerAddress string, useFinalized bool) (uint64, error)

+ GetOutboundSigningRequest func(ctx context.Context, data *uetypes.OutboundCreatedEvent, nonce uint64) (*UnsignedSigningReq, error)

+ IsAlreadyExecuted func(ctx context.Context, txID string) (bool, error)

+ VerifyBroadcastedTx func(ctx context.Context, txHash string) (found bool, blockHeight uint64, confirmations uint64, status uint8, err error)

+ type UnsignedSigningReq struct

+ Nonce uint64

+ SigningHash []byte

Mar 27, 2026

Changes in this version

type UniversalTx

+ RawPayload string

Mar 17, 2026

Changes in this version

type ChainStore

+ func (cs *ChainStore) UpdateStatusAndEventData(eventID, oldStatus, newStatus string, eventData []byte) (int64, error)

type OutboundEvent

+ GasFeeUsed string

type OutboundTxBuilder

+ GetGasFeeUsed func(ctx context.Context, txHash string) (string, error)

type UniversalTx

+ FromCEA bool

Feb 28, 2026

Changes in this version

type OutboundTxBuilder

+ IsAlreadyExecuted func(ctx context.Context, txID string) (bool, error)

Feb 25, 2026

Changes in this version

type ChainStore

+ func (cs *ChainStore) UpdateStatusAndVoteTxHash(eventID, oldStatus, newStatus, voteTxHash string) (int64, error)

type OutboundTxBuilder

+ GetNextNonce func(ctx context.Context, signerAddress string, useFinalized bool) (uint64, error)

+ VerifyBroadcastedTx func(ctx context.Context, txHash string) (found bool, blockHeight uint64, confirmations uint64, status uint8, err error)

Jan 28, 2026

Changes in this version

+ const EventTypeInbound

+ const EventTypeKeygen

+ const EventTypeKeyrefresh

+ const EventTypeOutbound

+ const EventTypeQuorumChange

+ const EventTypeSign

type ChainClient

+ GetTxBuilder func() (OutboundTxBuilder, error)

+ type ChainStore struct

+ func NewChainStore(database *db.DB) *ChainStore

+ func (cs *ChainStore) DeleteCompletedEvents(updatedBefore interface{}) (int64, error)

+ func (cs *ChainStore) DeleteTerminalEvents(updatedBefore interface{}) (int64, error)

+ func (cs *ChainStore) GetChainHeight() (uint64, error)

+ func (cs *ChainStore) GetConfirmedEvents(limit int) ([]store.Event, error)

+ func (cs *ChainStore) GetExpiredEvents(currentBlock uint64, limit int) ([]store.Event, error)

+ func (cs *ChainStore) GetPendingEvents(limit int) ([]store.Event, error)

+ func (cs *ChainStore) InsertEventIfNotExists(event *store.Event) (bool, error)

+ func (cs *ChainStore) UpdateChainHeight(blockHeight uint64) error

+ func (cs *ChainStore) UpdateEventStatus(eventID string, oldStatus, newStatus string) (int64, error)

+ func (cs *ChainStore) UpdateVoteTxHash(eventID string, voteTxHash string) error

+ type EventCleaner struct

+ func NewEventCleaner(database *db.DB, cleanupInterval time.Duration, retentionPeriod time.Duration, ...) *EventCleaner

+ func (ec *EventCleaner) Start(ctx context.Context) error

+ func (ec *EventCleaner) Stop()

+ type EventProcessor struct

+ func NewEventProcessor(signer *pushsigner.Signer, database *db.DB, chainID string, ...) *EventProcessor

+ func (ep *EventProcessor) IsRunning() bool

+ func (ep *EventProcessor) Start(ctx context.Context) error

+ func (ep *EventProcessor) Stop() error

+ type OutboundEvent struct

+ TxID string

+ UniversalTxID string

+ type OutboundTxBuilder interface

+ BroadcastOutboundSigningRequest func(ctx context.Context, req *UnSignedOutboundTxReq, ...) (string, error)

+ GetOutboundSigningRequest func(ctx context.Context, data *uetypes.OutboundCreatedEvent, gasPrice *big.Int, ...) (*UnSignedOutboundTxReq, error)

+ type UnSignedOutboundTxReq struct

+ GasPrice *big.Int

+ Nonce uint64

+ Signer string

+ SigningHash []byte

Jan 13, 2026

Changes in this version

+ type BaseChainClient struct

+ func NewBaseChainClient(chainConfig *uregistrytypes.ChainConfig, appConfig *config.Config) *BaseChainClient

+ func (b *BaseChainClient) Cancel()

+ func (b *BaseChainClient) ChainID() string

+ func (b *BaseChainClient) Context() context.Context

+ func (b *BaseChainClient) GetChainSpecificConfig() *config.ChainSpecificConfig

+ func (b *BaseChainClient) GetCleanupSettings() (cleanupInterval, retentionPeriod int)

+ func (b *BaseChainClient) GetConfig() *uregistrytypes.ChainConfig

+ func (b *BaseChainClient) GetGasOracleFetchInterval() time.Duration

+ func (b *BaseChainClient) GetRPCURLs() []string

+ func (b *BaseChainClient) SetContext(ctx context.Context)

+ type ChainClient interface

+ ChainID func() string

+ GetChainSpecificConfig func() *config.ChainSpecificConfig

+ GetCleanupSettings func() (cleanupInterval, retentionPeriod int)

+ GetConfig func() *uregistrytypes.ChainConfig

+ GetGasOracleFetchInterval func() time.Duration

+ GetGasPrice func(ctx context.Context) (*big.Int, error)

+ GetRPCURLs func() []string

+ IsHealthy func() bool

+ SetVoteHandler func(handler VoteHandler)

+ Start func(ctx context.Context) error

+ Stop func() error

+ type ConfirmationTracker struct

+ func NewConfirmationTracker(database *db.DB, config *uregistrytypes.BlockConfirmation, ...) *ConfirmationTracker

+ func (ct *ConfirmationTracker) GetConfirmedTransactions(chainID string) ([]store.ChainTransaction, error)

+ func (ct *ConfirmationTracker) GetGatewayTransaction(txHash string) (*store.ChainTransaction, error)

+ func (ct *ConfirmationTracker) GetRequiredConfirmations(mode string) uint64

+ func (ct *ConfirmationTracker) IsConfirmed(txHash string) (bool, error)

+ func (ct *ConfirmationTracker) MarkTransactionFailed(txHash string) error

+ func (ct *ConfirmationTracker) SetVoteHandler(handler VoteHandler)

+ func (ct *ConfirmationTracker) TrackTransaction(txHash string, blockNumber uint64, eventID string, confirmationType string, ...) (err error)

+ func (ct *ConfirmationTracker) UpdateConfirmations(currentBlock uint64) (err error)

+ type GasPrice struct

+ ChainID string

+ Price *big.Int

+ Timestamp int64

+ Unit string

+ type GasPriceFetcher interface

+ GetGasPrice func(ctx context.Context) (*big.Int, error)

+ type GatewayEvent struct

+ BlockNumber uint64

+ ChainID string

+ ConfirmationType string

+ Confirmations uint64

+ EventID string

+ Payload []byte

+ TxHash string

+ type GatewayOperations interface

+ GetLatestBlock func(ctx context.Context) (uint64, error)

+ GetTransactionConfirmations func(ctx context.Context, txHash string) (uint64, error)

+ IsConfirmed func(ctx context.Context, txHash string) (bool, error)

+ WatchGatewayEvents func(ctx context.Context, fromBlock uint64) (<-chan *GatewayEvent, error)

+ type RetryConfig struct

+ BackoffFactor float64

+ InitialDelay time.Duration

+ MaxDelay time.Duration

+ MaxRetries int

+ RetryableError func(error) bool

+ func DefaultRetryConfig() *RetryConfig

+ type RetryManager struct

+ func NewRetryManager(config *RetryConfig, logger zerolog.Logger) *RetryManager

+ func (r *RetryManager) CalculateBackoff(attempt int) time.Duration

+ func (r *RetryManager) ExecuteWithRetry(ctx context.Context, operation string, fn func() error) error

+ type UniversalTx struct

+ Amount string

+ LogIndex uint

+ Payload uetypes.UniversalPayload

+ Recipient string

+ RevertFundRecipient string

+ RevertMsg string

+ Sender string

+ SourceChain string

+ Token string

+ TxType uint

+ VerificationData string

+ type VoteHandler interface

+ VoteAndConfirm func(ctx context.Context, tx *store.ChainTransaction) error