influx

Documentation

Index

• func EncodePoint(p *Point, buf *bytes.Buffer) error
• func EncodePoints(ps Points, buf *bytes.Buffer) error
• type Client
  • func NewClient(cfg ClientCfg) (*Client, error)
  • func (c *Client) EnqueuePoint(p *Point)
  • func (c *Client) EnqueuePoints(points Points)
  • func (c *Client) SendPoints(points Points) error
  • func (c *Client) Start()
  • func (c *Client) Stop()
  • func (c *Client) Terminate()
• type ClientCfg
  • func (cfg *ClientCfg) ValidateJSON(v *ejson.Validator)
• type Fields
• type Point
  • func NewPoint(measurement string, tags Tags, fields Fields) *Point
  • func NewPointWithTimestamp(measurement string, tags Tags, fields Fields, t time.Time) *Point
• type Points
• type Tags

Functions

func EncodePoint

func EncodePoint(p *Point, buf *bytes.Buffer) error

func EncodePoints

func EncodePoints(ps Points, buf *bytes.Buffer) error

Types

type Client

type Client struct {
	Cfg        ClientCfg
	Log        *log.Logger
	HTTPClient *http.Client
	// contains filtered or unexported fields
}

func NewClient

func NewClient(cfg ClientCfg) (*Client, error)

func (*Client) EnqueuePoint

func (c *Client) EnqueuePoint(p *Point)

func (*Client) EnqueuePoints

func (c *Client) EnqueuePoints(points Points)

func (*Client) SendPoints

func (c *Client) SendPoints(points Points) error

func (*Client) Start

func (c *Client) Start()

func (*Client) Stop

func (c *Client) Stop()

func (*Client) Terminate

func (c *Client) Terminate()

type ClientCfg

type ClientCfg struct {
	Log        *log.Logger  `json:"-"`
	HTTPClient *http.Client `json:"-"`
	Hostname   string       `json:"-"`

	URI         string            `json:"uri"`
	Bucket      string            `json:"bucket"`
	Org         string            `json:"org,omitempty"`
	Token       string            `json:"token,omitempty"`
	BatchSize   int               `json:"batch_size,omitempty"`
	Tags        map[string]string `json:"tags,omitempty"`
	LogRequests bool              `json:"log_requests,omitempty"`
}

func (*ClientCfg) ValidateJSON

func (cfg *ClientCfg) ValidateJSON(v *ejson.Validator)

type Fields

type Fields map[string]interface{}

type Point

type Point struct {
	Measurement string
	Tags        Tags
	Fields      Fields
	Timestamp   *time.Time
}

func NewPoint

func NewPoint(measurement string, tags Tags, fields Fields) *Point

func NewPointWithTimestamp

func NewPointWithTimestamp(measurement string, tags Tags, fields Fields, t time.Time) *Point

type Points

type Points []*Point

type Tags

type Tags map[string]string