Versions in this module Expand all Collapse all v1 v1.1.1 Jul 10, 2025 v1.1.0 Jul 10, 2025 Changes in this version + const ConsensusRound + const ModuleName + var ErrDecodingTxBytes = errorsmod.Register(ModuleName, 1, "Decoding tx bytes failed") + var ErrMsgValidateBasic = errorsmod.Register(ModuleName, 2, "ValidateBasic failed on msg") + var ErrProposedPriceValidation = errorsmod.Register(ModuleName, 5, "Validation of proposed MsgUpdateMarketPrices failed") + var ErrUnexpectedMsgType = errorsmod.Register(ModuleName, 4, "Unexpected msg type") + var ErrUnexpectedNumMsgs = errorsmod.Register(ModuleName, 3, "Unexpected num of msgs") + func FullNodeProcessProposalHandler(txConfig client.TxConfig, bridgeKeeepr ProcessBridgeKeeper, ...) sdk.ProcessProposalHandler + func IncorrectNumberUpdatesError(expected, actual int) error + func IncorrectPriceUpdateForMarket(marketID uint32, expected, actual uint64) error + func InvalidMarketPriceUpdateError(err error) error + func IsDisallowClobOrderMsgInOtherTxs(targetMsg sdk.Msg) bool + func MissingPriceUpdateForMarket(marketID uint32) error + func ProcessProposalHandler(txConfig client.TxConfig, bridgeKeeper ProcessBridgeKeeper, ...) sdk.ProcessProposalHandler + type AcknowledgeBridgesTx struct + func DecodeAcknowledgeBridgesTx(ctx sdk.Context, bridgeKeeper ProcessBridgeKeeper, decoder sdk.TxDecoder, ...) (*AcknowledgeBridgesTx, error) + func (abt *AcknowledgeBridgesTx) GetMsg() sdk.Msg + func (abt *AcknowledgeBridgesTx) Validate() error + type AddPremiumVotesTx struct + func DecodeAddPremiumVotesTx(decoder sdk.TxDecoder, txBytes []byte) (*AddPremiumVotesTx, error) + func (afst *AddPremiumVotesTx) GetMsg() sdk.Msg + func (afst *AddPremiumVotesTx) Validate() error + type DefaultUpdateMarketPriceTxDecoder struct + func NewDefaultUpdateMarketPriceTxDecoder(pk ProcessPricesKeeper, txDecoder sdk.TxDecoder) *DefaultUpdateMarketPriceTxDecoder + func (mpd *DefaultUpdateMarketPriceTxDecoder) DecodeUpdateMarketPricesTx(ctx sdk.Context, txs [][]byte) (*UpdateMarketPricesTx, error) + func (mpd DefaultUpdateMarketPriceTxDecoder) GetTxOffset(sdk.Context) int + type MultiMsgsTx interface + GetMsgs func() []sdk.Msg + Validate func() error + type OtherMsgsTx struct + func DecodeOtherMsgsTx(decoder sdk.TxDecoder, txBytes []byte) (*OtherMsgsTx, error) + func (omt *OtherMsgsTx) GetMsgs() []sdk.Msg + func (omt *OtherMsgsTx) Validate() error + type ProcessBridgeKeeper interface + GetAcknowledgedEventInfo func(ctx sdk.Context) (acknowledgedEventInfo bridgetypes.BridgeEventInfo) + GetBridgeEventFromServer func(ctx sdk.Context, id uint32) (event bridgetypes.BridgeEvent, found bool) + GetRecognizedEventInfo func(ctx sdk.Context) (recognizedEventInfo bridgetypes.BridgeEventInfo) + GetSafetyParams func(ctx sdk.Context) (safetyParams bridgetypes.SafetyParams) + type ProcessClobKeeper interface + RecordMevMetrics func(ctx sdk.Context, stakingKeeper ProcessStakingKeeper, ...) + RecordMevMetricsIsEnabled func() bool + type ProcessPerpetualKeeper interface + GetPerpetual func(ctx sdk.Context, id uint32) (val perptypes.Perpetual, err error) + MaybeProcessNewFundingTickEpoch func(ctx sdk.Context) + type ProcessPricesKeeper interface + PerformStatefulPriceUpdateValidation func(ctx sdk.Context, marketPriceUpdates *pricestypes.MsgUpdateMarketPrices, ...) error + type ProcessProposalTxs struct + AcknowledgeBridgesTx *AcknowledgeBridgesTx + AddPremiumVotesTx *AddPremiumVotesTx + OtherTxs []*OtherMsgsTx + ProposedOperationsTx *ProposedOperationsTx + UpdateMarketPricesTx *UpdateMarketPricesTx + func DecodeProcessProposalTxs(ctx sdk.Context, decoder sdk.TxDecoder, req *abci.RequestProcessProposal, ...) (*ProcessProposalTxs, error) + func (ppt *ProcessProposalTxs) Validate() error + type ProcessStakingKeeper interface + GetValidatorByConsAddr func(ctx context.Context, consAddr sdk.ConsAddress) (validator stakingtypes.Validator, err error) + type ProposedOperationsTx struct + func DecodeProposedOperationsTx(decoder sdk.TxDecoder, txBytes []byte) (*ProposedOperationsTx, error) + func (pmot *ProposedOperationsTx) GetMsg() sdk.Msg + func (pmot *ProposedOperationsTx) Validate() error + type SingleMsgTx interface + GetMsg func() sdk.Msg + Validate func() error + type SlinkyMarketPriceDecoder struct + func NewSlinkyMarketPriceDecoder(decoder UpdateMarketPriceTxDecoder, agg prices.PriceUpdateGenerator) *SlinkyMarketPriceDecoder + func (mpd *SlinkyMarketPriceDecoder) DecodeUpdateMarketPricesTx(ctx sdk.Context, txs [][]byte) (*UpdateMarketPricesTx, error) + func (mpd *SlinkyMarketPriceDecoder) GetTxOffset(ctx sdk.Context) int + type UpdateMarketPriceTxDecoder interface + DecodeUpdateMarketPricesTx func(ctx sdk.Context, txs [][]byte) (*UpdateMarketPricesTx, error) + GetTxOffset func(ctx sdk.Context) int + type UpdateMarketPricesTx struct + func DecodeUpdateMarketPricesTx(ctx sdk.Context, pricesKeeper ProcessPricesKeeper, decoder sdk.TxDecoder, ...) (*UpdateMarketPricesTx, error) + func NewUpdateMarketPricesTx(ctx sdk.Context, pk ProcessPricesKeeper, ...) *UpdateMarketPricesTx + func (umpt *UpdateMarketPricesTx) GetMsg() sdk.Msg + func (umpt *UpdateMarketPricesTx) Validate() error