Versions in this module Expand all Collapse all v1 v1.0.0 Aug 15, 2021 Changes in this version + func Collect(ctx context.Context, api api.FullNode, influx client.Client, database string, ...) + func GetFullNodeAPI(ctx context.Context, repo string) (api.FullNode, jsonrpc.ClientCloser, error) + func GetLastRecordedHeight(influx client.Client, database string) (int64, error) + func GetTips(ctx context.Context, api api.FullNode, lastHeight abi.ChainEpoch, headlag int) (<-chan *types.TipSet, error) + func InfluxClient(addr, user, pass string) (client.Client, error) + func InfluxNewBatch() (client.BatchPoints, error) + func NewPoint(name string, value interface{}) models.Point + func NewPointFrom(p models.Point) *client.Point + func RecordTipsetMessagesPoints(ctx context.Context, api api.FullNode, pl *PointList, tipset *types.TipSet) error + func RecordTipsetPoints(ctx context.Context, api api.FullNode, pl *PointList, tipset *types.TipSet) error + func RecordTipsetStatePoints(ctx context.Context, api api.FullNode, pl *PointList, tipset *types.TipSet) error + func ResetDatabase(influx client.Client, database string) error + func WaitForSyncComplete(ctx context.Context, napi api.FullNode) error + type ApiIpldStore struct + func NewApiIpldStore(ctx context.Context, api apiIpldStoreApi) *ApiIpldStore + func (ht *ApiIpldStore) Context() context.Context + func (ht *ApiIpldStore) Get(ctx context.Context, c cid.Cid, out interface{}) error + func (ht *ApiIpldStore) Put(ctx context.Context, v interface{}) (cid.Cid, error) + type InfluxWriteQueue struct + func NewInfluxWriteQueue(ctx context.Context, influx client.Client) *InfluxWriteQueue + func (i *InfluxWriteQueue) AddBatch(bp client.BatchPoints) + func (i *InfluxWriteQueue) Close() + type PointList struct + func NewPointList() *PointList + func (pl *PointList) AddPoint(p models.Point) + func (pl *PointList) Points() []models.Point