influx

Documentation

Index

• func GetLastRecordedHeight(influx client.Client, database string) (int64, error)
• func NewBatch() (client.BatchPoints, error)
• func NewClient(addr, user, pass string) (client.Client, error)
• func NewPoint(name string, value interface{}) models.Point
• func NewPointFrom(p models.Point) *client.Point
• func ResetDatabase(influx client.Client, database string) error
• type PointList
  • func NewPointList() *PointList
  • func (pl *PointList) AddPoint(p models.Point)
  • func (pl *PointList) Points() []models.Point
• type WriteQueue
  • func NewWriteQueue(ctx context.Context, influx client.Client) *WriteQueue
  • func (i *WriteQueue) AddBatch(bp client.BatchPoints)
  • func (i *WriteQueue) Close()

Functions

func GetLastRecordedHeight

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

func NewBatch

func NewBatch() (client.BatchPoints, error)

func NewClient

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

func NewPoint

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

func NewPointFrom

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

func ResetDatabase

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

Types

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

type WriteQueue

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

func NewWriteQueue

func NewWriteQueue(ctx context.Context, influx client.Client) *WriteQueue

func (*WriteQueue) AddBatch

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

func (*WriteQueue) Close

func (i *WriteQueue) Close()