kapacitor

package module

Go to main page

Versions in this module

v0

v0.11.0-rc1

Mar 14, 2016

v0.10.1

Feb 8, 2016

Changes in this version

+ func ConvertResultTimes(r *Result)

type AlertData

+ Details string

type AlertLevel

+ func (l *AlertLevel) UnmarshalText(text []byte) error

type BatchNode

+ func (b *BatchNode) Abort()

type SourceBatchNode

+ func (s *SourceBatchNode) Abort()

type TaskMaster

+ TalkService interface{ ... }

+ func (tm *TaskMaster) StopTasks()

v0.10.0

Jan 26, 2016

Changes in this version

+ var ErrUDFProcessStopped = errors.New("process already stopped")

type ExecutingTask

+ func (et *ExecutingTask) Snapshot() (*TaskSnapshot, error)

+ type StatsNode struct

+ func (n *StatsNode) Err() error

type Task

+ SnapshotInterval time.Duration

type TaskMaster

+ AlertaService interface{ ... }

+ DeadmanService pipeline.DeadmanService

+ SensuService interface{ ... }

+ TaskStore interface{ ... }

+ UDFService UDFService

+ func (tm *TaskMaster) CreateTICKScope() *tick.Scope

+ func (tm *TaskMaster) NewTask(name, script string, tt TaskType, dbrps []DBRP, snapshotInterval time.Duration) (*Task, error)

+ func (tm *TaskMaster) SnapshotTask(name string) (*TaskSnapshot, error)

+ type TaskSnapshot struct

+ NodeSnapshots map[string][]byte

+ type UDFNode struct

+ func (n *UDFNode) Err() error

+ type UDFProcess struct

+ BatchIn chan<- models.Batch

+ BatchOut <-chan models.Batch

+ PointIn chan<- models.Point

+ PointOut <-chan models.Point

+ func NewUDFProcess(commander command.Commander, l *log.Logger, timeout time.Duration, ...) *UDFProcess

+ func (p *UDFProcess) Abort(err error)

+ func (p *UDFProcess) Info() (UDFProcessInfo, error)

+ func (p *UDFProcess) Init(options []*udf.Option) error

+ func (p *UDFProcess) Restore(snapshot []byte) error

+ func (p *UDFProcess) Snapshot() ([]byte, error)

+ func (p *UDFProcess) Start() error

+ func (p *UDFProcess) Stop() error

+ type UDFProcessInfo struct

+ Commander command.Commander

+ Options map[string]*udf.OptionInfo

+ Provides pipeline.EdgeType

+ Timeout time.Duration

+ Wants pipeline.EdgeType

+ type UDFService interface

+ FunctionInfo func(name string) (UDFProcessInfo, bool)

+ FunctionList func() []string

v0.10.0-rc2

Jan 22, 2016

v0.10.0-rc1

Jan 20, 2016

v0.2.4

Jan 7, 2016

Changes in this version

type TaskMaster

+ HipChatService interface{ ... }

+ OpsGenieService interface{ ... }

v0.2.3

Dec 22, 2015

Changes in this version

type ExecutingTask

+ func (et *ExecutingTask) EDot() []byte

type TaskMaster

+ func (tm *TaskMaster) ExecutingDot(name string) string

v0.2.2

Dec 15, 2015

v0.2.1

Dec 14, 2015

Changes in this version

+ var ErrAborted = errors.New("edged aborted")

+ var ErrTaskMasterClosed = errors.New("TaskMaster is closed")

+ var ErrTaskMasterOpen = errors.New("TaskMaster is open")

type Edge

+ func (e *Edge) Abort()

+ type StatsData struct

+ Name string

+ Tags map[string]string

+ Values map[string]interface{}

type TaskMaster

+ func (tm *TaskMaster) Drain()

+ func (tm *TaskMaster) IsExecuting(name string) bool

+ func (tm *TaskMaster) WritePoints(pts *cluster.WritePointsRequest) error

v0.2.0

Dec 7, 2015

Changes in this version

+ const UptimeVarName

+ func Uptime() time.Duration

v0.1.2

Dec 2, 2015

v0.1.1

Nov 30, 2015

Changes in this version

+ const ClusterIDVarName

+ const HostVarName

+ const NumEnabledTasksVarName

+ const NumSubscriptionsVarName

+ const NumTasksVarName

+ const Product

+ const ProductVarName

+ const ServerIDVarName

+ const VersionVarName

+ var ErrWrongTaskType = errors.New("wrong task type")

+ var NumEnabledTasks = &expvar.Int

+ var NumSubscriptions = &expvar.Int

+ var NumTasks = &expvar.Int

+ func CreateDBRPMap(dbrps []DBRP) map[DBRP]bool

+ func EvalPredicate(se *tick.StatefulExpr, fields models.Fields, tags map[string]string) (bool, error)

+ func GetFloatVar(name string) float64

+ func GetIntVar(name string) int64

+ func GetStatsData() ([]client.StatsData, error)

+ func GetStringVar(name string) string

+ func NewStatistics(name string, tags map[string]string) *expvar.Map

+ func WriteBatchForRecording(w io.Writer, b models.Batch) error

+ func WritePointForRecording(w io.Writer, p models.Point, precision string) error

+ type AlertData struct

+ Data influxql.Result

+ ID string

+ Level AlertLevel

+ Message string

+ Time time.Time

+ type AlertHandler func(ad *AlertData)

+ type AlertLevel int

+ const CritAlert

+ const InfoAlert

+ const OKAlert

+ const WarnAlert

+ func (l AlertLevel) MarshalText() ([]byte, error)

+ func (l AlertLevel) String() string

+ type AlertNode struct

+ func (n *AlertNode) Err() error

+ type BatchCollector interface

+ Close func()

+ CollectBatch func(models.Batch) error

+ type BatchNode struct

+ func (b *BatchNode) DBRPs() ([]DBRP, error)

+ func (b *BatchNode) Queries(start, stop time.Time) []string

+ func (b *BatchNode) Start(batch BatchCollector)

+ func (n *BatchNode) Err() error

+ type DBRP struct

+ Database string

+ RetentionPolicy string

+ func (d DBRP) String() string

+ type DerivativeNode struct

+ func (n *DerivativeNode) Err() error

+ type Edge struct

+ func (e *Edge) Close()

+ func (e *Edge) CollectBatch(b models.Batch) (err error)

+ func (e *Edge) CollectMaps(m *MapResult) (err error)

+ func (e *Edge) CollectPoint(p models.Point) (err error)

+ func (e *Edge) Next() (p models.PointInterface, ok bool)

+ func (e *Edge) NextBatch() (b models.Batch, ok bool)

+ func (e *Edge) NextMaps() (m *MapResult, ok bool)

+ func (e *Edge) NextPoint() (p models.Point, ok bool)

+ type EvalNode struct

+ func (n *EvalNode) Err() error

+ type ExecutingTask struct

+ Task *Task

+ func NewExecutingTask(tm *TaskMaster, t *Task) (*ExecutingTask, error)

+ func (et *ExecutingTask) BatchCount() (int, error)

+ func (et *ExecutingTask) BatchQueries(start, stop time.Time) ([][]string, error)

+ func (et *ExecutingTask) Err() error

+ func (et *ExecutingTask) GetOutput(name string) (Output, error)

+ func (et *ExecutingTask) StartBatching() error

+ type GroupByNode struct

+ func (n *GroupByNode) Err() error

+ type HTTPOutNode struct

+ func (h *HTTPOutNode) Endpoint() string

+ func (n *HTTPOutNode) Err() error

+ type InfluxDBOutNode struct

+ func (n *InfluxDBOutNode) Err() error

+ type JoinNode struct

+ func (n *JoinNode) Err() error

+ type LogService interface

+ NewLogger func(prefix string, flag int) *log.Logger

+ type MapFunc func(in *tsdb.MapInput) interface

+ type MapInfo struct

+ Field string

+ Func MapFunc

+ type MapNode struct

+ func (n *MapNode) Err() error

+ type MapResult struct

+ Dims []string

+ Group models.GroupID

+ Name string

+ Outs []interface{}

+ TMax time.Time

+ Tags map[string]string

+ type Node interface

+ Err func() error

+ type Output interface

+ Endpoint func() string

+ type Query struct

+ func NewQuery(q string) (*Query, error)

+ func (q *Query) DBRPs() ([]DBRP, error)

+ func (q *Query) Dimensions(dims []interface{}) error

+ func (q *Query) Fill(option influxql.FillOption, value interface{})

+ func (q *Query) Start(s time.Time)

+ func (q *Query) Stop(s time.Time)

+ func (q *Query) String() string

+ type ReduceFunc func(in []interface{}, tmax time.Time, useTMax bool, as string) interface

+ type ReduceNode struct

+ func (n *ReduceNode) Err() error

+ type Replay struct

+ Setter clock.Setter

+ func NewReplay(c clock.Clock) *Replay

+ func (r *Replay) ReplayBatch(data []io.ReadCloser, batches []BatchCollector, recTime bool) <-chan error

+ func (r *Replay) ReplayStream(data io.ReadCloser, stream StreamCollector, recTime bool, precision string) <-chan error

+ type Result influxql.Result

+ func ResultFromJSON(in io.Reader) (r Result)

+ type SampleNode struct

+ func (n *SampleNode) Err() error

+ type SourceBatchNode struct

+ func (s *SourceBatchNode) Count() int

+ func (s *SourceBatchNode) DBRPs() ([]DBRP, error)

+ func (s *SourceBatchNode) Err() error

+ func (s *SourceBatchNode) Queries(start, stop time.Time) [][]string

+ func (s *SourceBatchNode) Start(collectors []*Edge)

+ type StreamCollector interface

+ Close func()

+ CollectPoint func(models.Point) error

+ type StreamNode struct

+ func (n *StreamNode) Err() error

+ type Task struct

+ DBRPs []DBRP

+ Name string

+ Pipeline *pipeline.Pipeline

+ Type TaskType

+ func NewBatcher(name, script string, dbrps []DBRP) (*Task, error)

+ func NewStreamer(name, script string, dbrps []DBRP) (*Task, error)

+ func NewTask(name, script string, tt TaskType, dbrps []DBRP) (*Task, error)

+ func (t *Task) Dot() []byte

+ type TaskMaster struct

+ HTTPDService interface{ ... }

+ InfluxDBService interface{ ... }

+ LogService LogService

+ PagerDutyService interface{ ... }

+ SMTPService interface{ ... }

+ SlackService interface{ ... }

+ Stream StreamCollector

+ VictorOpsService interface{ ... }

+ func NewTaskMaster(l LogService) *TaskMaster

+ func (tm *TaskMaster) BatchCollectors(name string) []BatchCollector

+ func (tm *TaskMaster) Close() error

+ func (tm *TaskMaster) DelFork(name string)

+ func (tm *TaskMaster) New() *TaskMaster

+ func (tm *TaskMaster) NewFork(taskName string, dbrps []DBRP) *Edge

+ func (tm *TaskMaster) Open() error

+ func (tm *TaskMaster) StartTask(t *Task) (*ExecutingTask, error)

+ func (tm *TaskMaster) StopTask(name string)

+ type TaskType int

+ const BatchTask

+ const StreamTask

+ func (t TaskType) String() string

+ type UnionNode struct

+ func (n *UnionNode) Err() error

+ type WhereNode struct

+ func (n *WhereNode) Err() error

+ type WindowNode struct

+ func (n *WindowNode) Err() error

v0.1.1-rc1

Nov 25, 2015

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