core

Documentation

Index

• Variables
• func AuthzMessagesParser(_ codec.Codec, cosmosMsg sdk.Msg) []string
• func BankMessagesParser(_ codec.Codec, cosmosMsg sdk.Msg) []string
• func CrisisMessagesParser(_ codec.Codec, cosmosMsg sdk.Msg) []string
• func DefaultMessagesParser(_ codec.Codec, cosmosMsg sdk.Msg) []string
• func DistributionMessagesParser(_ codec.Codec, cosmosMsg sdk.Msg) []string
• func EvidenceMessagesParser(_ codec.Codec, cosmosMsg sdk.Msg) []string
• func FeeGrantMessagesParser(_ codec.Codec, cosmosMsg sdk.Msg) []string
• func GovMessagesParser(cdc codec.Codec, cosmosMsg sdk.Msg) []string
• func IBCTransferMessagesParser(_ codec.Codec, cosmosMsg sdk.Msg) []string
• func SlashingMessagesParser(_ codec.Codec, cosmosMsg sdk.Msg) []string
• func StakingMessagesParser(_ codec.Codec, cosmosMsg sdk.Msg) []string
• type MessageAddressesParser
  • func JoinMessageParsers(parsers ...MessageAddressesParser) MessageAddressesParser
• type Module
  • func New(b broker, tbM tb.ToBroker, cdc codec.Codec, parser MessageAddressesParser) *Module
  • func (m *Module) HandleBlock(ctx context.Context, block *types.Block) error
  • func (m *Module) HandleMessage(ctx context.Context, index int, msg sdk.Msg, tx *types.Tx) error
  • func (m *Module) HandleTx(ctx context.Context, tx *types.Tx) error
  • func (m *Module) HandleValidators(ctx context.Context, vals *cometbftcoretypes.ResultValidators) error
  • func (m *Module) Name() string

Variables

var CosmosMessageAddressesParser = JoinMessageParsers(
	BankMessagesParser,
	CrisisMessagesParser,
	DistributionMessagesParser,
	EvidenceMessagesParser,
	GovMessagesParser,
	IBCTransferMessagesParser,
	SlashingMessagesParser,
	StakingMessagesParser,
	FeeGrantMessagesParser,
	AuthzMessagesParser,
	DefaultMessagesParser,
)

CosmosMessageAddressesParser represents a MessageAddressesParser that parses a Cosmos message and returns all the involved addresses (both accounts and validators)

Functions

func AuthzMessagesParser

func AuthzMessagesParser(_ codec.Codec, cosmosMsg sdk.Msg) []string

AuthzMessagesParser returns the list of all the accounts involved in the given message if it's related to the x/authz module

func BankMessagesParser

func BankMessagesParser(_ codec.Codec, cosmosMsg sdk.Msg) []string

BankMessagesParser returns the list of all the accounts involved in the given message if it's related to the x/bank module

func CrisisMessagesParser

func CrisisMessagesParser(_ codec.Codec, cosmosMsg sdk.Msg) []string

CrisisMessagesParser returns the list of all the accounts involved in the given message if it's related to the x/crisis module

func DefaultMessagesParser

func DefaultMessagesParser(_ codec.Codec, cosmosMsg sdk.Msg) []string

DefaultMessagesParser represents the default messages parser that simply returns the list of all the signers of a message

func DistributionMessagesParser

func DistributionMessagesParser(_ codec.Codec, cosmosMsg sdk.Msg) []string

DistributionMessagesParser returns the list of all the accounts involved in the given message if it's related to the x/distribution module

func EvidenceMessagesParser

func EvidenceMessagesParser(_ codec.Codec, cosmosMsg sdk.Msg) []string

EvidenceMessagesParser returns the list of all the accounts involved in the given message if it's related to the x/evidence module

func FeeGrantMessagesParser

func FeeGrantMessagesParser(_ codec.Codec, cosmosMsg sdk.Msg) []string

FeeGrantMessagesParser returns the list of all the accounts involved in the given message if it's related to the x/feegrant module

func GovMessagesParser

func GovMessagesParser(cdc codec.Codec, cosmosMsg sdk.Msg) []string

GovMessagesParser returns the list of all the accounts involved in the given message if it's related to the x/gov module

func IBCTransferMessagesParser

func IBCTransferMessagesParser(_ codec.Codec, cosmosMsg sdk.Msg) []string

IBCTransferMessagesParser returns the list of all the accounts involved in the given message if it's related to the x/IBCTransfer module

func SlashingMessagesParser

func SlashingMessagesParser(_ codec.Codec, cosmosMsg sdk.Msg) []string

SlashingMessagesParser returns the list of all the accounts involved in the given message if it's related to the x/slashing module

func StakingMessagesParser

func StakingMessagesParser(_ codec.Codec, cosmosMsg sdk.Msg) []string

StakingMessagesParser returns the list of all the accounts involved in the given message if it's related to the x/staking module

Types

type MessageAddressesParser

type MessageAddressesParser = func(cdc codec.Codec, msg sdk.Msg) []string

MessageAddressesParser represents a function that extracts all the involved addresses from a provided message (both accounts and validators)

func JoinMessageParsers

func JoinMessageParsers(parsers ...MessageAddressesParser) MessageAddressesParser

JoinMessageParsers joins together all the given parsers, calling them in order

type Module

type Module struct {
	// contains filtered or unexported fields
}

func New

func New(b broker, tbM tb.ToBroker, cdc codec.Codec, parser MessageAddressesParser) *Module

func (*Module) HandleBlock

func (m *Module) HandleBlock(ctx context.Context, block *types.Block) error

func (*Module) HandleMessage

func (m *Module) HandleMessage(ctx context.Context, index int, msg sdk.Msg, tx *types.Tx) error

func (*Module) HandleTx

func (m *Module) HandleTx(ctx context.Context, tx *types.Tx) error

func (*Module) HandleValidators

func (m *Module) HandleValidators(ctx context.Context, vals *cometbftcoretypes.ResultValidators) error

HandleValidators handles validators for each block height.

func (*Module) Name

func (m *Module) Name() string