Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ChainSpecificMessageTypeHandlerBootstrap ¶
func ChainSpecificMessageTypeHandlerBootstrap(chainID string)
Merge the chain specific message type handlers into the core message type handler map. Chain specific handlers will be registered BEFORE any generic handlers. TODO: Remove this function and replace with a more generic solution
Types ¶
type Parser ¶
type Parser interface {
ProcessRPCBlockByHeightTXs(messageTypeFilters []filter.MessageTypeFilter,
blockResults *coretypes.ResultBlock, resultBlockRes *coretypes.ResultBlockResults) ([]dbTypes.TxDBWrapper, *time.Time, error)
ProcessRPCTXs(messageTypeFilters []filter.MessageTypeFilter,
txEventResp *cosmosTx.GetTxsEventResponse) ([]dbTypes.TxDBWrapper, *time.Time, error)
}
type Processor ¶
type Processor interface {
ProcessTx(tx txtypes.MergedTx, messagesRaw [][]byte) (txDBWapper dbTypes.TxDBWrapper,
txTime time.Time, err error)
ProcessSigners(authInfo *cosmosTx.AuthInfo,
messageSigners []types.AccAddress) ([]models.Address, []*models.SignerInfo, error)
ProcessFees(authInfo cosmosTx.AuthInfo, signers []models.Address) ([]models.Fee, error)
ProcessMessage(messageIndex int, message types.Msg,
txMessageEventLogs []txtypes.LogMessage,
uniqueEventTypes map[string]models.MessageEventType,
uniqueEventAttributeKeys map[string]models.MessageEventAttributeKey) (string, dbTypes.MessageDBWrapper)
}
func NewProcessor ¶
func NewProcessor(cl *client.ChainClient) Processor
Click to show internal directories.
Click to hide internal directories.