transform

Documentation

Index

• Constants
• Variables
• func BasicReceiptFilterFactory(indexStore dstore.Store, possibleIndexSizes []uint64) (*transform.Factory, error)
• func NewHeaderOnlyTransformFactory(_ dstore.Store, _ []uint64) (*transform.Factory, error)
• func NewNearBlockIndexProvider(store dstore.Store, possibleIndexSizes []uint64, addresses map[string]bool, ...) *transform.GenericBlockIndexProvider
• func NewNearBlockIndexer(indexStore dstore.Store, indexSize uint64) (firecore.BlockIndexer[*pbnear.Block], error)
• type BasicReceiptFilter
  • func (p *BasicReceiptFilter) GetIndexProvider() bstream.BlockIndexProvider
  • func (p *BasicReceiptFilter) String() string
  • func (p *BasicReceiptFilter) Transform(readOnlyBlk *bstream.Block, in transform.Input) (transform.Output, error)
• type HeaderOnlyFilter
  • func (p *HeaderOnlyFilter) String() string
  • func (p *HeaderOnlyFilter) Transform(readOnlyBlk *bstream.Block, in transform.Input) (transform.Output, error)
• type NearBlockIndexer
  • func (i *NearBlockIndexer) ProcessBlock(blk *pbnear.Block) error

Constants

const ReceiptAddressIndexShortName = "rcptaddr"

Variables

var HeaderOnlyMessageName = proto.MessageName(&pbtransform.HeaderOnly{})

var ReceiptFilterMessageName = proto.MessageName(&pbtransform.BasicReceiptFilter{})

Functions

func BasicReceiptFilterFactory

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

func NewHeaderOnlyTransformFactory

func NewHeaderOnlyTransformFactory(_ dstore.Store, _ []uint64) (*transform.Factory, error)

func NewNearBlockIndexProvider

func NewNearBlockIndexProvider(
	store dstore.Store,
	possibleIndexSizes []uint64,
	addresses map[string]bool,
	prefixSuffixPairs []*pbtransform.PrefixSuffixPair,
) *transform.GenericBlockIndexProvider

func NewNearBlockIndexer

func NewNearBlockIndexer(indexStore dstore.Store, indexSize uint64) (firecore.BlockIndexer[*pbnear.Block], error)

Types

type BasicReceiptFilter

type BasicReceiptFilter struct {
	Accounts          map[string]bool
	PrefixSuffixPairs []*pbtransform.PrefixSuffixPair
	// contains filtered or unexported fields
}

func (*BasicReceiptFilter) GetIndexProvider

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

func (*BasicReceiptFilter) String

func (p *BasicReceiptFilter) String() string

func (*BasicReceiptFilter) Transform

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

type HeaderOnlyFilter

type HeaderOnlyFilter struct{}

func (*HeaderOnlyFilter) String

func (p *HeaderOnlyFilter) String() string

func (*HeaderOnlyFilter) Transform

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

type NearBlockIndexer

type NearBlockIndexer struct {
	BlockIndexer blockIndexer
}

func (*NearBlockIndexer) ProcessBlock

func (i *NearBlockIndexer) ProcessBlock(blk *pbnear.Block) error