Documentation ¶
Index ¶
- func Collect(ctx context.Context, api api.FullNode, influx client.Client, database string, ...)
- func GetFullNodeAPI(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 NewHeadBuffer(size int) *headBuffer
- 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 InfluxWriteQueue
- type PointList
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetLastRecordedHeight ¶
func InfluxNewBatch ¶
func InfluxNewBatch() (client.BatchPoints, error)
func NewHeadBuffer ¶ added in v0.2.10
func NewHeadBuffer(size int) *headBuffer
func RecordTipsetPoints ¶
func RecordTipsetStatePoints ¶
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()
Click to show internal directories.
Click to hide internal directories.