core

Documentation

Index

• Constants
• Variables
• func AuthzMessagesParser(_ codec.Codec, incomingMsg sdk.Msg) []string
• func BankMessagesParser(_ codec.Codec, incomingMsg sdk.Msg) []string
• func CrisisMessagesParser(_ codec.Codec, incomingMsg sdk.Msg) []string
• func DefaultMessagesParser(_ codec.Codec, incomingMsg sdk.Msg) []string
• func DistributionMessagesParser(_ codec.Codec, incomingMsg sdk.Msg) []string
• func EvidenceMessagesParser(_ codec.Codec, incomingMsg sdk.Msg) []string
• func FeeGrantMessagesParser(_ codec.Codec, incomingMsg sdk.Msg) []string
• func GovMessagesParser(cdc codec.Codec, incomingMsg sdk.Msg) []string
• func GraphMessagesParser(_ codec.Codec, incomingMsg sdk.Msg) []string
• func IBCTransferMessagesParser(_ codec.Codec, incomingMsg sdk.Msg) []string
• func SlashingMessagesParser(_ codec.Codec, incomingMsg sdk.Msg) []string
• func StakingMessagesParser(_ codec.Codec, incomingMsg sdk.Msg) []string
• type Module
  • func New(b broker, tbM tb.ToBroker, cdc codec.Codec, parser MsgAddrParser) *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
• type MsgAddrParser
  • func JoinMessageParsers(parsers ...MsgAddrParser) MsgAddrParser

Constants

const (
	ModuleName = "core"
)

Variables

var (
	// CosmosMessageAddressesParser represents a MsgAddrParser that parses a
	// Cosmos message and returns all the involved addresses (both accounts and validators)
	CosmosMessageAddressesParser = JoinMessageParsers(
		BankMessagesParser,
		CrisisMessagesParser,
		DistributionMessagesParser,
		EvidenceMessagesParser,
		GovMessagesParser,
		IBCTransferMessagesParser,
		SlashingMessagesParser,
		StakingMessagesParser,
		FeeGrantMessagesParser,
		AuthzMessagesParser,
		GraphMessagesParser,

		DefaultMessagesParser,
	)
)

Functions

func AuthzMessagesParser

func AuthzMessagesParser(_ codec.Codec, incomingMsg 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, incomingMsg 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, incomingMsg 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, incomingMsg 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, incomingMsg 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, incomingMsg 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, incomingMsg 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, incomingMsg 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 GraphMessagesParser

func GraphMessagesParser(_ codec.Codec, incomingMsg sdk.Msg) []string

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

func IBCTransferMessagesParser

func IBCTransferMessagesParser(_ codec.Codec, incomingMsg 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, incomingMsg 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, incomingMsg 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 Module

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

func New

func New(b broker, tbM tb.ToBroker, cdc codec.Codec, parser MsgAddrParser) *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

type MsgAddrParser

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

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

func JoinMessageParsers

func JoinMessageParsers(parsers ...MsgAddrParser) MsgAddrParser

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