Versions in this module Expand all Collapse all v0 v0.7.0 Dec 17, 2018 Changes in this version + func ManageCQs(c *cli.Context, cqs []*ContinuousQuery, influxClient client.Client, ...) error + func NewCQFlags() []cli.Flag + type ContinuousQuery struct + Database string + Name string + OffsetIntervals []string + Query string + ResampleEveryInterval string + ResampleForInterval string + TimeInterval string + func NewContinuousQuery(name, database, resampleEveryInterval, resampleForInterval, query, ... string, ...) (*ContinuousQuery, error) + func (cq *ContinuousQuery) Deploy(c client.Client, sugar *zap.SugaredLogger) error + func (cq *ContinuousQuery) Drop(c client.Client, sugar *zap.SugaredLogger) error + func (cq *ContinuousQuery) Execute(c client.Client, sugar *zap.SugaredLogger) error + func (cq *ContinuousQuery) GetCurrentCQs(c client.Client, sugar *zap.SugaredLogger) (map[string]string, error)
Go to main page