transform

Documentation

Index

• Constants
• Variables
• 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
• type EventOriginFilter
  • 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
  • func NewEventOriginIndexer(indexStore dstore.Store, indexSize uint64, startBlock uint64) *EventOriginIndexer
  • func (i *EventOriginIndexer) ProcessBlock(block *pbcosmos.Block)
• type EventTypeFilter
  • 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
  • func NewEventTypeIndexer(indexStore dstore.Store, indexSize uint64, startBlock uint64) *EventTypeIndexer
  • func (i *EventTypeIndexer) ProcessBlock(block *pbcosmos.Block)
• type MessageTypeFilter
  • 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
  • func NewMessageTypeIndexer(indexStore dstore.Store, indexSize uint64, startBlock uint64) *MessageTypeIndexer
  • func (i *MessageTypeIndexer) ProcessBlock(block *pbcosmos.Block)

Constants

const EventOriginIndexShortName = "eventorigin"

const EventTypeIndexShortName = "eventtype"

const MessageTypeIndexShortName = "messagetype"

Variables

var EventOriginFilterMessageName = proto.MessageName(&pbtransform.EventOriginFilter{})

var EventTypeFilterMessageName = proto.MessageName(&pbtransform.EventTypeFilter{})

var MessageTypeFilterMessageName = proto.MessageName(&pbtransform.MessageTypeFilter{})

Functions

func EventOriginFilterFactory

func EventOriginFilterFactory(indexStore dstore.Store, possibleIndexSizes []uint64) *transform.Factory

func EventTypeFilterFactory

func EventTypeFilterFactory(indexStore dstore.Store, possibleIndexSizes []uint64) *transform.Factory

func MessageTypeFilterFactory

func MessageTypeFilterFactory(indexStore dstore.Store, possibleIndexSizes []uint64) *transform.Factory

func NewEventOriginIndexProvider

func NewEventOriginIndexProvider(
	store dstore.Store,
	possibleIndexSizes []uint64,
	eventOrigins map[EventOrigin]bool,
) *transform.GenericBlockIndexProvider

func NewEventTypeIndexProvider

func NewEventTypeIndexProvider(
	store dstore.Store,
	possibleIndexSizes []uint64,
	eventTypes map[string]bool,
) *transform.GenericBlockIndexProvider

func NewMessageTypeIndexProvider

func NewMessageTypeIndexProvider(
	store dstore.Store,
	possibleIndexSizes []uint64,
	messageTypes map[string]bool,
) *transform.GenericBlockIndexProvider

Types

type EventOrigin

type EventOrigin string

const (
	DeliverTx  EventOrigin = "DeliverTx"
	BeginBlock EventOrigin = "BeginBlock"
	EndBlock   EventOrigin = "EndBlock"
)

type EventOriginFilter

type EventOriginFilter struct {
	EventOrigins map[EventOrigin]bool
	// contains filtered or unexported fields
}

func (*EventOriginFilter) GetIndexProvider

func (p *EventOriginFilter) GetIndexProvider() bstream.BlockIndexProvider

func (*EventOriginFilter) String

func (p *EventOriginFilter) String() string

func (*EventOriginFilter) Transform

func (p *EventOriginFilter) Transform(readOnlyBlk *bstream.Block, in transform.Input) (transform.Output, error)

type EventOriginIndexer

type EventOriginIndexer struct {
	BlockIndexer blockIndexer
}

func NewEventOriginIndexer

func NewEventOriginIndexer(indexStore dstore.Store, indexSize uint64, startBlock uint64) *EventOriginIndexer

func (*EventOriginIndexer) ProcessBlock

func (i *EventOriginIndexer) ProcessBlock(block *pbcosmos.Block)

type EventTypeFilter

type EventTypeFilter struct {
	EventTypes map[string]bool
	// contains filtered or unexported fields
}

func (*EventTypeFilter) GetIndexProvider

func (p *EventTypeFilter) GetIndexProvider() bstream.BlockIndexProvider

func (*EventTypeFilter) String

func (p *EventTypeFilter) String() string

func (*EventTypeFilter) Transform

func (p *EventTypeFilter) Transform(readOnlyBlk *bstream.Block, in transform.Input) (transform.Output, error)

type EventTypeIndexer

type EventTypeIndexer struct {
	BlockIndexer blockIndexer
}

func NewEventTypeIndexer

func NewEventTypeIndexer(indexStore dstore.Store, indexSize uint64, startBlock uint64) *EventTypeIndexer

func (*EventTypeIndexer) ProcessBlock

func (i *EventTypeIndexer) ProcessBlock(block *pbcosmos.Block)

type MessageTypeFilter

type MessageTypeFilter struct {
	MessageTypes map[string]bool
	// contains filtered or unexported fields
}

func (*MessageTypeFilter) GetIndexProvider

func (p *MessageTypeFilter) GetIndexProvider() bstream.BlockIndexProvider

func (*MessageTypeFilter) String

func (p *MessageTypeFilter) String() string

func (*MessageTypeFilter) Transform

func (p *MessageTypeFilter) Transform(readOnlyBlk *bstream.Block, in transform.Input) (transform.Output, error)

type MessageTypeIndexer

type MessageTypeIndexer struct {
	BlockIndexer blockIndexer
}

func NewMessageTypeIndexer

func NewMessageTypeIndexer(indexStore dstore.Store, indexSize uint64, startBlock uint64) *MessageTypeIndexer

func (*MessageTypeIndexer) ProcessBlock

func (i *MessageTypeIndexer) ProcessBlock(block *pbcosmos.Block)