common

package

Go to main page

Versions in this module

v0

v0.0.48

Sep 11, 2026

Changes in this version

+ const DefaultFastConfirmations

+ const DefaultStandardConfirmations

+ func ConfirmationDepth(latestHeight, txHeight uint64) (depth uint64, ok bool)

type FundMigrationData

+ TransferAmount *big.Int

v0.0.47

Sep 7, 2026

v0.0.46

Aug 27, 2026

v0.0.45

Aug 19, 2026

Changes in this version

+ func EncodeUint256Result(v *big.Int) ([]byte, error)

+ func NewReadErrorResult(code ucallbacktypes.ReadErrorCode) *ucallbacktypes.ReadResult

type ChainClient

+ GetReadRequestHandler func() (ReadRequestHandler, error)

+ type EventHandler interface

+ HandleEvent func(ctx context.Context, event *store.Event) error

type EventProcessor

+ func (ep *EventProcessor) RegisterHandler(eventType string, handler EventHandler)

+ type InboundObservation struct

+ Amount string

+ FromCEA bool

+ LogIndex uint

+ RawPayload string

+ Recipient string

+ RevertFundRecipient string

+ Sender string

+ SourceChain string

+ Token string

+ TxType uint

+ VerificationData string

+ type InboundObservationEventProcessor struct

+ func NewInboundObservationEventProcessor(signer VoteSigner, database *db.DB, logger zerolog.Logger) *InboundObservationEventProcessor

+ func (p *InboundObservationEventProcessor) HandleEvent(ctx context.Context, event *store.Event) error

+ type OutboundObservation struct

+ GasFeeUsed string

+ Pc20WrapperAddress string

+ TxID string

+ UniversalTxID string

+ type OutboundObservationEventProcessor struct

+ func NewOutboundObservationEventProcessor(signer VoteSigner, database *db.DB, logger zerolog.Logger) *OutboundObservationEventProcessor

+ func (p *OutboundObservationEventProcessor) HandleEvent(ctx context.Context, event *store.Event) error

+ type ReadRequestHandler interface

+ ExecuteRead func(ctx context.Context, req *ucallbacktypes.ReadRequest) (*ucallbacktypes.ReadResult, error)

+ type VoteSigner interface

+ VoteInbound func(ctx context.Context, inbound *uexecutortypes.Inbound) (string, error)

+ VoteOutbound func(ctx context.Context, txID string, utxID string, ...) (string, error)

v0.0.44

Aug 3, 2026

Changes in this version

+ type ChainClient interface

+ GetTxBuilder func() (TxBuilder, error)

+ IsHealthy func() bool

+ Start func(ctx context.Context) error

+ Stop func() error

+ type ChainStore struct

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

+ func (cs *ChainStore) DeleteTerminalEvents(updatedBefore any) (int64, error)

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

+ func (cs *ChainStore) GetConfirmedEvents(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) UpdateStatusAndEventData(eventID, oldStatus, newStatus string, eventData []byte) (int64, error)

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

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

+ type EventCleaner struct

+ func NewEventCleaner(database *db.DB, cleanupIntervalSeconds *int, retentionPeriodSeconds *int, ...) *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 FundMigrationData struct

+ Balance *big.Int

+ From string

+ GasLimit uint64

+ GasPrice *big.Int

+ L1GasFee *big.Int

+ To string

+ type OutboundEvent struct

+ GasFeeUsed string

+ Pc20WrapperAddress string

+ TxID string

+ UniversalTxID 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) (executed bool, queryBlockTime int64, err error)

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

+ type UniversalTx struct

+ Amount string

+ FromCEA bool

+ LogIndex uint

+ RawPayload string

+ Recipient string

+ RevertFundRecipient string

+ Sender string

+ SourceChain string

+ Token string

+ TxType uint

+ VerificationData string

+ type UnsignedSigningReq struct

+ Nonce uint64

+ SigningHash []byte

+ TSSFundMigrationAmount *big.Int

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL