replay

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

type RecordingInfo struct {
	ID      string
	Type    kapacitor.TaskType `json:",omitempty"`
	Size    int64              `json:",omitempty"`
	Created time.Time          `json:",omitempty"`
	Error   string             `json:",omitempty"`
}

type Service struct {
	TaskStore interface {
		Load(name string) (*kapacitor.Task, error)
	}
	HTTPDService interface {
		AddRoutes([]httpd.Route) error
		DelRoutes([]httpd.Route)
	}
	InfluxDBService interface {
		NewClient() (*client.Client, error)
	}
	TaskMaster interface {
		NewFork(name string, dbrps []kapacitor.DBRP) (*kapacitor.Edge, error)
		DelFork(name string)
		New() *kapacitor.TaskMaster
		Stream(name string) (kapacitor.StreamCollector, error)
	}
	// contains filtered or unexported fields
}