Versions in this module Expand all Collapse all v0 v0.7.1 Dec 8, 2023 v0.7.0 Nov 3, 2023 Changes in this version + const EventOriginIndexShortName + const EventTypeIndexShortName + const MessageTypeIndexShortName + var EventOriginFilterMessageName = proto.MessageName(&pbtransform.EventOriginFilter{}) + var EventTypeFilterMessageName = proto.MessageName(&pbtransform.EventTypeFilter{}) + var MessageTypeFilterMessageName = proto.MessageName(&pbtransform.MessageTypeFilter{}) + func EventOriginFilterFactory(indexStore dstore.Store, possibleIndexSizes []uint64) *transform.Factory + func EventTypeFilterFactory(indexStore dstore.Store, possibleIndexSizes []uint64) *transform.Factory + func MessageTypeFilterFactory(indexStore dstore.Store, possibleIndexSizes []uint64) *transform.Factory + func NewEventOriginIndexProvider(store dstore.Store, possibleIndexSizes []uint64, ...) *transform.GenericBlockIndexProvider + func NewEventTypeIndexProvider(store dstore.Store, possibleIndexSizes []uint64, eventTypes map[string]bool) *transform.GenericBlockIndexProvider + func NewMessageTypeIndexProvider(store dstore.Store, possibleIndexSizes []uint64, messageTypes map[string]bool) *transform.GenericBlockIndexProvider + type EventOrigin string + const BeginBlock + const DeliverTx + const EndBlock + type EventOriginFilter struct + EventOrigins map[EventOrigin]bool + func (p *EventOriginFilter) GetIndexProvider() bstream.BlockIndexProvider + func (p *EventOriginFilter) String() string + func (p *EventOriginFilter) Transform(readOnlyBlk *bstream.Block, in transform.Input) (transform.Output, error) + type EventOriginIndexer struct + BlockIndexer blockIndexer + func NewEventOriginIndexer(indexStore dstore.Store, indexSize uint64, startBlock uint64) *EventOriginIndexer + func (i *EventOriginIndexer) ProcessBlock(block *pbcosmos.Block) + type EventTypeFilter struct + EventTypes map[string]bool + func (p *EventTypeFilter) GetIndexProvider() bstream.BlockIndexProvider + func (p *EventTypeFilter) String() string + func (p *EventTypeFilter) Transform(readOnlyBlk *bstream.Block, in transform.Input) (transform.Output, error) + type EventTypeIndexer struct + BlockIndexer blockIndexer + func NewEventTypeIndexer(indexStore dstore.Store, indexSize uint64, startBlock uint64) *EventTypeIndexer + func (i *EventTypeIndexer) ProcessBlock(block *pbcosmos.Block) + type MessageTypeFilter struct + MessageTypes map[string]bool + func (p *MessageTypeFilter) GetIndexProvider() bstream.BlockIndexProvider + func (p *MessageTypeFilter) String() string + func (p *MessageTypeFilter) Transform(readOnlyBlk *bstream.Block, in transform.Input) (transform.Output, error) + type MessageTypeIndexer struct + BlockIndexer blockIndexer + func NewMessageTypeIndexer(indexStore dstore.Store, indexSize uint64, startBlock uint64) *MessageTypeIndexer + func (i *MessageTypeIndexer) ProcessBlock(block *pbcosmos.Block)
Go to main page