rec

Documentation

Overview

Package rec includes everything related to datapoint record.

Index

• type RecBytes
  • func ParseRec(s []byte, normalize bool, shouldLog bool, nowF func() time.Time, ...) (*RecBytes, error)
  • func (r RecBytes) Copy() (*RecBytes, error)
  • func (r *RecBytes) Serialize() []byte

Types

type RecBytes

type RecBytes struct {
	Path []byte
	Val  []byte
	Time []byte

	Received time.Time
}

RecBytes represents a single piece of data (a datapoint) that can be sent.

func ParseRec

func ParseRec(s []byte, normalize bool, shouldLog bool, nowF func() time.Time, lg *zap.Logger) (*RecBytes, error)

ParseRec parses a single datapoint record from a string. Makes sure it's valid. Performs normalizations.

func (RecBytes) Copy

func (r RecBytes) Copy() (*RecBytes, error)

Copy returns a deep copy of the record

func (*RecBytes) Serialize

func (r *RecBytes) Serialize() []byte

Serialize makes record into a string ready to be sent via TCP w/ line protocol.