stats

package
v0.6.2-rc1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 9, 2020 License: Apache-2.0, MIT Imports: 30 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Collect added in v0.5.0

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 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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL