stats

Documentation

Index

• 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
  • 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
  • func NewInfluxWriteQueue(ctx context.Context, influx client.Client) *InfluxWriteQueue
  • func (i *InfluxWriteQueue) AddBatch(bp client.BatchPoints)
  • func (i *InfluxWriteQueue) Close()
• type PointList
  • func NewPointList() *PointList
  • func (pl *PointList) AddPoint(p models.Point)
  • func (pl *PointList) Points() []models.Point

Functions

func Collect

func Collect(ctx context.Context, api api.FullNode, influx client.Client, database string, height int64, headlag int)

func GetFullNodeAPI

func GetFullNodeAPI(ctx context.Context, repo string) (api.FullNode, jsonrpc.ClientCloser, error)

func GetLastRecordedHeight

func GetLastRecordedHeight(influx client.Client, database string) (int64, error)

func GetTips

func GetTips(ctx context.Context, api api.FullNode, lastHeight abi.ChainEpoch, headlag int) (<-chan *types.TipSet, error)

func InfluxClient

func InfluxClient(addr, user, pass string) (client.Client, error)

func InfluxNewBatch

func InfluxNewBatch() (client.BatchPoints, error)

func NewPoint

func NewPoint(name string, value interface{}) models.Point

func NewPointFrom

func NewPointFrom(p models.Point) *client.Point

func RecordTipsetMessagesPoints

func RecordTipsetMessagesPoints(ctx context.Context, api api.FullNode, pl *PointList, tipset *types.TipSet) error

func RecordTipsetPoints

func RecordTipsetPoints(ctx context.Context, api api.FullNode, pl *PointList, tipset *types.TipSet) error

func RecordTipsetStatePoints

func RecordTipsetStatePoints(ctx context.Context, api api.FullNode, pl *PointList, tipset *types.TipSet) error

func ResetDatabase

func ResetDatabase(influx client.Client, database string) error

func WaitForSyncComplete

func WaitForSyncComplete(ctx context.Context, napi api.FullNode) error

Types

type ApiIpldStore

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

func NewApiIpldStore

func NewApiIpldStore(ctx context.Context, api apiIpldStoreApi) *ApiIpldStore

func (*ApiIpldStore) Context

func (ht *ApiIpldStore) Context() context.Context

func (*ApiIpldStore) Get

func (ht *ApiIpldStore) Get(ctx context.Context, c cid.Cid, out interface{}) error

func (*ApiIpldStore) Put

func (ht *ApiIpldStore) Put(ctx context.Context, v interface{}) (cid.Cid, error)

type InfluxWriteQueue

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

func NewInfluxWriteQueue

func NewInfluxWriteQueue(ctx context.Context, influx client.Client) *InfluxWriteQueue

func (*InfluxWriteQueue) AddBatch

func (i *InfluxWriteQueue) AddBatch(bp client.BatchPoints)

func (*InfluxWriteQueue) Close

func (i *InfluxWriteQueue) Close()

type PointList

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

func NewPointList

func NewPointList() *PointList

func (*PointList) AddPoint

func (pl *PointList) AddPoint(p models.Point)

func (*PointList) Points

func (pl *PointList) Points() []models.Point