continuous_querier

Documentation

Index

• func Register(typ string, ...)
• type CQHandleFunc
• type Service
  • func NewService(logger *log.Logger, searcher ekanite.Searcher, metaStore *service.MetaStore, ...) *Service
  • func (s *Service) RunLoop(stop chan struct{})

Functions

func Register

func Register(typ string, create func(*service.ContinuousQuery, []string) (CQHandleFunc, error))

Types

type CQHandleFunc

type CQHandleFunc func(cq *service.ContinuousQuery, value interface{}) error

type Service

type Service struct {
	Logger *log.Logger
	// contains filtered or unexported fields
}

func NewService

func NewService(logger *log.Logger, searcher ekanite.Searcher, metaStore *service.MetaStore,
	stop chan struct{}, runInterval time.Duration) *Service

NewService returns a new CQ instance.

func (*Service) RunLoop

func (s *Service) RunLoop(stop chan struct{})

runs on a go routine and periodically executes CQs.