bulk

Documentation

Index

• type Bulk
  • func New(batchSize int, client influxmod.Client, config influxmod.BatchPointsConfig) (Bulk, error)
  • func NewSafe(unsafe Bulk) Bulk
• type PointOp

Types

type Bulk

type Bulk interface {
	AddPoints(po ...PointOp) error
	Perform() error
}

Bulk interface for InfluxDB

func New

func New(batchSize int, client influxmod.Client, config influxmod.BatchPointsConfig) (Bulk, error)

New creates a Bulk instance which is not thread safe.

func NewSafe

func NewSafe(unsafe Bulk) Bulk

NewSafe wraps un unsafe Bulk with a sync.RWMutex

type PointOp

type PointOp struct {
	Name   string
	Tags   map[string]string
	Fields map[string]interface{}
	Time   time.Time
}

PointOp regroups all parameters for influx.NewPoint. All members are mendatory.