model

Documentation

Index

• func MarshalTimeseries(ts timeseries.Timeseries, rlo *timeseries.RequestOptions, status int) ([]byte, error)
• func MarshalTimeseriesWriter(ts timeseries.Timeseries, rlo *timeseries.RequestOptions, status int, ...) error
• func NewModeler() *timeseries.Modeler
• func UnmarshalTimeseries(data []byte, trq *timeseries.TimeRangeQuery) (timeseries.Timeseries, error)
• func UnmarshalTimeseriesReader(reader io.Reader, trq *timeseries.TimeRangeQuery) (timeseries.Timeseries, error)
• type WFDocument
• type WFResult

Functions

func MarshalTimeseries

func MarshalTimeseries(ts timeseries.Timeseries, rlo *timeseries.RequestOptions, status int) ([]byte, error)

MarshalTimeseries converts a Timeseries into a JSON blob

func MarshalTimeseriesWriter

func MarshalTimeseriesWriter(ts timeseries.Timeseries, rlo *timeseries.RequestOptions, status int, w io.Writer) error

MarshalTimeseriesWriter converts a Timeseries into a JSON blob via an io.Writer

func NewModeler

func NewModeler() *timeseries.Modeler

NewModeler returns a collection of modeling functions for influxdb interoperability

func UnmarshalTimeseries

func UnmarshalTimeseries(data []byte, trq *timeseries.TimeRangeQuery) (timeseries.Timeseries, error)

UnmarshalTimeseries converts a JSON blob into a Timeseries

func UnmarshalTimeseriesReader

func UnmarshalTimeseriesReader(reader io.Reader, trq *timeseries.TimeRangeQuery) (timeseries.Timeseries, error)

UnmarshalTimeseriesReader converts a JSON blob into a Timeseries via io.Reader

Types

type WFDocument

type WFDocument struct {
	Results []WFResult `json:"results"`
	Err     string     `json:"error,omitempty"`
}

WFDocument the Wire Format Document for the timeseries

type WFResult

type WFResult struct {
	StatementID int          `json:"statement_id"`
	SeriesList  []models.Row `json:"series,omitempty"`
	Err         string       `json:"error,omitempty"`
}

WFResult is the Result section of the WFD