task_store

package

v0.10.0 Latest Latest Go to latest Published: Jan 26, 2016 License: MIT Imports: 17 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/aspring/kapacitor

Links

Open Source Insights

Documentation ¶

Index ¶

type Config
- func NewConfig() Config
- func (c Config) Validate() error
type Service
- func NewService(conf Config, l *log.Logger) *Service
type TaskInfo

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Config ¶

type Config struct {
	Dir              string        `toml:"dir"`
	SnapshotInterval toml.Duration `toml:"snapshot-interval"`
}

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 {
		NewTask(
			name,
			script string,
			tt kapacitor.TaskType,
			dbrps []kapacitor.DBRP,
			snapshotInterval time.Duration,
		) (*kapacitor.Task, error)
		StartTask(t *kapacitor.Task) (*kapacitor.ExecutingTask, error)
		StopTask(name string) error
		IsExecuting(name string) bool
		ExecutingDot(name string) 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) HasSnapshot ¶ added in v0.10.0

func (ts *Service) HasSnapshot(name string) bool

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) LoadSnapshot ¶ added in v0.10.0

func (ts *Service) LoadSnapshot(name string) (*kapacitor.TaskSnapshot, error)

func (*Service) Open ¶

func (ts *Service) Open() error

func (*Service) Save ¶

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

func (*Service) SaveLastError ¶ added in v0.2.1

func (ts *Service) SaveLastError(name string, errStr string) error

Save last error from task.

func (*Service) SaveSnapshot ¶ added in v0.10.0

func (ts *Service) SaveSnapshot(name string, snapshot *kapacitor.TaskSnapshot) 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
	Executing  bool
	Error      string
}

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL