consumers

Documentation

Index

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

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 avm.VMName:
		indexer, err = avm.NewWriter(conns, networkID, chainID)
	case pvm.VMName:
		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