task_store

Documentation

Index

• type Config
  • func NewConfig() Config
  • func (c Config) Validate() error
• type Service
  • func NewService(conf Config, l *log.Logger) *Service
  • func (ts *Service) Close() error
  • func (ts *Service) Delete(name string) error
  • func (ts *Service) Disable(name string) error
  • func (ts *Service) Enable(name string) error
  • func (ts *Service) GetTaskInfo(tasks []string) ([]taskInfo, error)
  • func (ts *Service) IsEnabled(name string) (e bool)
  • func (ts *Service) Load(name string) (*kapacitor.Task, error)
  • func (ts *Service) LoadRaw(name string) (*rawTask, error)
  • func (ts *Service) Open() error
  • func (ts *Service) Save(task *rawTask) error
  • func (ts *Service) StartTask(t *kapacitor.Task) error
• type TaskInfo

Types

type Config

type Config struct {
	Dir string `toml:"dir"`
}

func NewConfig

func NewConfig() Config

func (Config) Validate

func (c Config) Validate() error

type Service

type Service struct {
	HTTPDService interface {
		AddRoutes([]httpd.Route) error
		DelRoutes([]httpd.Route)
	}
	TaskMaster interface {
		StartTask(t *kapacitor.Task) (*kapacitor.ExecutingTask, error)
		StopTask(name string)
	}
	// contains filtered or unexported fields
}

func NewService

func NewService(conf Config, l *log.Logger) *Service

func (*Service) Close

func (ts *Service) Close() error

func (*Service) Delete

func (ts *Service) Delete(name string) error

func (*Service) Disable

func (ts *Service) Disable(name string) error

func (*Service) Enable

func (ts *Service) Enable(name string) error

func (*Service) GetTaskInfo

func (ts *Service) GetTaskInfo(tasks []string) ([]taskInfo, error)

func (*Service) IsEnabled

func (ts *Service) IsEnabled(name string) (e bool)

func (*Service) Load

func (ts *Service) Load(name string) (*kapacitor.Task, error)

func (*Service) LoadRaw

func (ts *Service) LoadRaw(name string) (*rawTask, error)

func (*Service) Open

func (ts *Service) Open() error

func (*Service) Save

func (ts *Service) Save(task *rawTask) error

func (*Service) StartTask

func (ts *Service) StartTask(t *kapacitor.Task) error

type TaskInfo

type TaskInfo struct {
	Name       string
	Type       kapacitor.TaskType
	DBRPs      []kapacitor.DBRP
	TICKscript string
	Dot        string
	Enabled    bool
	Error      string
}