consumers

Documentation

Index

• Constants
• Variables
• func ExportToDisk(conf *cfg.Config, exportPath string, chainID string) (int64, error)

Constants

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

Variables

var (
	ErrExportFileExists = errors.New("export file exists")
)

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

var IndexerCChain = stream.NewConsumerCChain

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

Functions

func ExportToDisk

func ExportToDisk(conf *cfg.Config, exportPath string, chainID string) (int64, error)

ExportToDisk writes the stream data for a given chain out to disk