consumers

Documentation

Index

• Constants
• Variables
• func Bootstrap(sc *servicesctrl.Control, networkID uint32, chains cfg.Chains, ...) error
• func IndexerFactories(sc *servicesctrl.Control, config *cfg.Config, ...) error
• type ConsumerDBFactory
• type ConsumerFactory
• type IndexerFactoryControl

Constants

const (
	IndexerAVMName = "avm"
	IndexerPVMName = "pvm"

	MaximumRecordsRead = 10000
	MaxTheads          = 10

	IteratorTimeout = 3 * time.Minute
)

Variables

var IndexerCChainDB = stream.NewConsumerCChainDB

var IndexerConsensusDB = stream.NewConsumerDBFactory(IndexerConsumer, stream.EventTypeConsensus)

var IndexerConsumer = func(networkID uint32, chainVM string, chainID string) (indexer services.Consumer, err error) {
	switch chainVM {
	case IndexerAVMName:
		indexer, err = avm.NewWriter(networkID, chainID)
	case IndexerPVMName:
		indexer, err = pvm.NewWriter(networkID, chainID)
	default:
		return nil, stream.ErrUnknownVM
	}
	return indexer, err
}

var IndexerConsumerCChain = func(networkID uint32, chainID string) (indexer services.ConsumerCChain, err error) {
	return cvm.NewWriter(networkID, chainID)
}

var IndexerDB = stream.NewConsumerDBFactory(IndexerConsumer, stream.EventTypeDecisions)

Functions

func Bootstrap

func Bootstrap(sc *servicesctrl.Control, networkID uint32, chains cfg.Chains, factories []ConsumerFactory) error

func IndexerFactories

func IndexerFactories(
	sc *servicesctrl.Control,
	config *cfg.Config,
	factoriesChainDB []stream.ProcessorFactoryChainDB,
	factoriesInstDB []stream.ProcessorFactoryInstDB,
	wg *sync.WaitGroup,
	runningControl utils.Running,
) error

Types

type ConsumerDBFactory

type ConsumerDBFactory func(uint32, string, string) (stream.ProcessorFactoryChainDB, error)

type ConsumerFactory

type ConsumerFactory func(uint32, string, string) (services.Consumer, error)

type IndexerFactoryControl

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