Versions in this module Expand all Collapse all v0 v0.2.1 Nov 16, 2015 v0.2.0 Oct 27, 2015 Changes in this version + type RunRequest struct + CQs []string + Now time.Time v0.1.9 Sep 22, 2015 Changes in this version + const DefaultComputeNoMoreThan + const DefaultComputeRunsPerInterval + const DefaultRecomputeNoOlderThan + const DefaultRecomputePreviousN + const NoChunkingSize + type Config struct + ComputeNoMoreThan toml.Duration + ComputeRunsPerInterval int + Enabled bool + LogEnabled bool + RecomputeNoOlderThan toml.Duration + RecomputePreviousN int + func NewConfig() Config + type ContinuousQuerier interface + Run func(database, name string) error + type ContinuousQuery struct + Database string + Info *meta.ContinuousQueryInfo + LastRun time.Time + func NewContinuousQuery(database string, cqi *meta.ContinuousQueryInfo) (*ContinuousQuery, error) + type Service struct + Config *Config + Logger *log.Logger + MetaStore metaStore + PointsWriter pointsWriter + QueryExecutor queryExecutor + RunCh chan struct{} + RunInterval time.Duration + func NewService(c Config) *Service + func (s *Service) Close() error + func (s *Service) ExecuteContinuousQuery(dbi *meta.DatabaseInfo, cqi *meta.ContinuousQueryInfo) error + func (s *Service) Open() error + func (s *Service) Run(database, name string) error + func (s *Service) SetLogger(l *log.Logger)