Versions in this module Expand all Collapse all v0 v0.2.0 Dec 1, 2020 Changes in this version + const SourceCategoryBasic + const SourceCategoryCommon + const SourceCategoryPlugin + const SourceDataFormatJSON + const SourceDataFormatMultipleLine + const SourceDataFormatSingeLine + const SourceDataFormatYAML + var RegexpParamNamedVariable = regexp.MustCompile(`(?U)\${[$\w\s.-]+(\s*\|.+)?}`) + func AllActions() []maps.Map + func AllDataSources() []maps.Map + func AllSourceDataFormats() []maps.Map + func AllThresholdOperators() []maps.Map + func ConvertSourceToMap(source SourceInterface) map[string]interface + func DecodeSource(data []byte, format SourceDataFormat) (value interface{}, err error) + func EvalParam(param string, value interface{}, old interface{}, varMapping maps.Map, ...) (string, error) + func FindAction(code string) maps.Map + func FindDataSource(code string) maps.Map + func FindSourceDataFormat(dataFormat SourceDataFormat) maps.Map + func FindThresholdOperator(op string) maps.Map + func FuncAppend(args ...interface{}) interface + func FuncCeil(args ...interface{}) interface + func FuncFloat(args ...interface{}) interface + func FuncFloor(args ...interface{}) interface + func FuncFormat(args ...interface{}) interface + func FuncRound(args ...interface{}) interface + func NotifyAgentsChange() + func RegisterAllDataSources() + func RegisterDataSource(dataSource SourceInterface, category SourceCategory) + func RegisterFunc(code string, f interface{}) + func RunFuncExpr(value interface{}, expr []byte) (interface{}, error) + type ActionInterface interface + Code func() string + Description func() string + Name func() string + Run func(params map[string]string) (result string, err error) + Summary func() maps.Map + Validate func() error + func FindActionInstance(code string, options map[string]interface{}) ActionInterface + type AgentConfig struct + Allow []string + AllowAll bool + Apps []*AppConfig + AppsIsInitialized bool + AutoUpdates bool + CheckDisconnections bool + CountDisconnections int + GroupIds []string + GroupKey string + Host string + Id string + Key string + Name string + NoticeSetting map[notices.NoticeLevel][]*notices.NoticeReceiver + On bool + TeaVersion string + Version uint + func AllSharedAgents() []*AgentConfig + func LocalAgentConfig() *AgentConfig + func NewAgentConfig() *AgentConfig + func NewAgentConfigFromFile(filename string) *AgentConfig + func NewAgentConfigFromId(agentId string) *AgentConfig + func SharedAgents() []*AgentConfig + func (this *AgentConfig) AddApp(app *AppConfig) + func (this *AgentConfig) AddApps(apps []*AppConfig) + func (this *AgentConfig) AddDefaultApps() + func (this *AgentConfig) AddGroup(groupId string) + func (this *AgentConfig) AddNoticeReceiver(level notices.NoticeLevel, receiver *notices.NoticeReceiver) + func (this *AgentConfig) BelongsToGroup(groupId string) bool + func (this *AgentConfig) BelongsToGroups(groupIds []string) bool + func (this *AgentConfig) CountNoticeReceivers() int + func (this *AgentConfig) Delete() error + func (this *AgentConfig) EncodeYAML() ([]byte, error) + func (this *AgentConfig) Filename() string + func (this *AgentConfig) FindAllNoticeReceivers(level ...notices.NoticeLevel) []*notices.NoticeReceiver + func (this *AgentConfig) FindApp(appId string) *AppConfig + func (this *AgentConfig) FindItem(itemId string) (appConfig *AppConfig, item *Item) + func (this *AgentConfig) FindTask(taskId string) (appConfig *AppConfig, taskConfig *TaskConfig) + func (this *AgentConfig) FirstGroup() *Group + func (this *AgentConfig) GroupName() string + func (this *AgentConfig) HasApp(appId string) bool + func (this *AgentConfig) IsLocal() bool + func (this *AgentConfig) MatchKeyword(keyword string) (matched bool, name string, tags []string) + func (this *AgentConfig) MoveApp(fromIndex int, toIndex int) + func (this *AgentConfig) RemoveApp(appId string) + func (this *AgentConfig) RemoveGroup(groupId string) + func (this *AgentConfig) RemoveMedia(mediaId string) (found bool) + func (this *AgentConfig) RemoveNoticeReceiver(level notices.NoticeLevel, receiverId string) + func (this *AgentConfig) ReplaceApp(app *AppConfig) + func (this *AgentConfig) Save() error + func (this *AgentConfig) Validate() error + type AgentList struct + Files []string + func SharedAgentList() (*AgentList, error) + func (this *AgentList) AddAgent(agentFile string) + func (this *AgentList) CountAgentsInGroup(groupId string) int + func (this *AgentList) FindAllAgents() []*AgentConfig + func (this *AgentList) MoveAgent(fromId string, toId string) + func (this *AgentList) RemoveAgent(agentFile string) + func (this *AgentList) Save() error + type AppConfig struct + Id string + IsSharedWithGroup bool + Items []*Item + Name string + NoticeSetting map[notices.NoticeLevel][]*notices.NoticeReceiver + On bool + SharedAgentIds []string + Tasks []*TaskConfig + func NewAppConfig() *AppConfig + func (this *AppConfig) AddItem(item *Item) + func (this *AppConfig) AddNoticeReceiver(level notices.NoticeLevel, receiver *notices.NoticeReceiver) + func (this *AppConfig) AddTask(task *TaskConfig) + func (this *AppConfig) CountNoticeReceivers() int + func (this *AppConfig) FindAllNoticeReceivers(level ...notices.NoticeLevel) []*notices.NoticeReceiver + func (this *AppConfig) FindBootingTasks() []*TaskConfig + func (this *AppConfig) FindItem(itemId string) *Item + func (this *AppConfig) FindManualTasks() []*TaskConfig + func (this *AppConfig) FindSchedulingTasks() []*TaskConfig + func (this *AppConfig) FindTask(taskId string) *TaskConfig + func (this *AppConfig) MatchKeyword(keyword string) (matched bool, name string, tags []string) + func (this *AppConfig) RemoveItem(itemId string) + func (this *AppConfig) RemoveMedia(mediaId string) (found bool) + func (this *AppConfig) RemoveNoticeReceiver(level notices.NoticeLevel, receiverId string) + func (this *AppConfig) RemoveTask(taskId string) + func (this *AppConfig) Validate() error + type AppProcessesSource struct + CmdlineKeyword string + func NewAppProcessesSource() *AppProcessesSource + func (this *AppProcessesSource) Charts() []*widgets.Chart + func (this *AppProcessesSource) Code() string + func (this *AppProcessesSource) Description() string + func (this *AppProcessesSource) Execute(params map[string]string) (value interface{}, err error) + func (this *AppProcessesSource) Form() *forms.Form + func (this *AppProcessesSource) Name() string + func (this *AppProcessesSource) Platforms() []string + func (this *AppProcessesSource) Presentation() *forms.Presentation + func (this *AppProcessesSource) Thresholds() []*Threshold + func (this *AppProcessesSource) Variables() []*SourceVariable + type Board struct + Charts []*BoardChart + Filename string + TeaVersion string + func NewAgentBoard(agentId string) *Board + func (this *Board) AddChart(appId, itemId, chartId string) + func (this *Board) FindChart(chartId string) *BoardChart + func (this *Board) HasChart(chartId string) bool + func (this *Board) MoveChart(fromIndex int, toIndex int) + func (this *Board) RemoveApp(appId string) + func (this *Board) RemoveChart(chartId string) + func (this *Board) Save() error + type BoardChart struct + AppId string + ChartId string + DayFrom string + DayTo string + ItemId string + Name string + TimePast teaconfigs.TimePast + TimeType string + type CPUSource struct + func NewCPUSource() *CPUSource + func (this *CPUSource) Charts() []*widgets.Chart + func (this *CPUSource) Code() string + func (this *CPUSource) Description() string + func (this *CPUSource) Execute(params map[string]string) (value interface{}, err error) + func (this *CPUSource) Form() *forms.Form + func (this *CPUSource) Name() string + func (this *CPUSource) Thresholds() []*Threshold + func (this *CPUSource) Variables() []*SourceVariable + type ConnectionsSource struct + func NewConnectionsSource() *ConnectionsSource + func (this *ConnectionsSource) Charts() []*widgets.Chart + func (this *ConnectionsSource) Code() string + func (this *ConnectionsSource) Description() string + func (this *ConnectionsSource) Execute(params map[string]string) (value interface{}, err error) + func (this *ConnectionsSource) Form() *forms.Form + func (this *ConnectionsSource) Name() string + func (this *ConnectionsSource) Presentation() *forms.Presentation + func (this *ConnectionsSource) Thresholds() []*Threshold + func (this *ConnectionsSource) Variables() []*SourceVariable + type DNSSource struct + Domain string + Type string + func NewDNSSource() *DNSSource + func (this *DNSSource) Charts() []*widgets.Chart + func (this *DNSSource) Code() string + func (this *DNSSource) Description() string + func (this *DNSSource) Execute(params map[string]string) (value interface{}, err error) + func (this *DNSSource) Form() *forms.Form + func (this *DNSSource) Name() string + func (this *DNSSource) Presentation() *forms.Presentation + func (this *DNSSource) Thresholds() []*Threshold + func (this *DNSSource) Variables() []*SourceVariable + type DateSource struct + func NewDateSource() *DateSource + func (this *DateSource) Charts() []*widgets.Chart + func (this *DateSource) Code() string + func (this *DateSource) Description() string + func (this *DateSource) Execute(params map[string]string) (value interface{}, err error) + func (this *DateSource) Form() *forms.Form + func (this *DateSource) Name() string + func (this *DateSource) Presentation() *forms.Presentation + func (this *DateSource) Thresholds() []*Threshold + func (this *DateSource) Variables() []*SourceVariable + type DiskSource struct + ContainsAllMountPoints bool + func NewDiskSource() *DiskSource + func (this *DiskSource) Charts() []*widgets.Chart + func (this *DiskSource) Code() string + func (this *DiskSource) Description() string + func (this *DiskSource) Execute(params map[string]string) (value interface{}, err error) + func (this *DiskSource) Form() *forms.Form + func (this *DiskSource) Name() string + func (this *DiskSource) Presentation() *forms.Presentation + func (this *DiskSource) Thresholds() []*Threshold + func (this *DiskSource) Variables() []*SourceVariable + type DockerSource struct + func NewDockerSource() *DockerSource + func (this *DockerSource) Charts() []*widgets.Chart + func (this *DockerSource) Code() string + func (this *DockerSource) Description() string + func (this *DockerSource) Execute(params map[string]string) (value interface{}, err error) + func (this *DockerSource) Form() *forms.Form + func (this *DockerSource) Name() string + func (this *DockerSource) Thresholds() []*Threshold + func (this *DockerSource) Variables() []*SourceVariable + type FileChangeSource struct + Path string + func NewFileChangeSource() *FileChangeSource + func (this *FileChangeSource) Charts() []*widgets.Chart + func (this *FileChangeSource) Code() string + func (this *FileChangeSource) Description() string + func (this *FileChangeSource) Execute(params map[string]string) (value interface{}, err error) + func (this *FileChangeSource) Form() *forms.Form + func (this *FileChangeSource) Name() string + func (this *FileChangeSource) Presentation() *forms.Presentation + func (this *FileChangeSource) Thresholds() []*Threshold + func (this *FileChangeSource) Variables() []*SourceVariable + type FileSource struct + Path string + func NewFileSource() *FileSource + func (this *FileSource) Code() string + func (this *FileSource) Description() string + func (this *FileSource) Execute(params map[string]string) (value interface{}, err error) + func (this *FileSource) Form() *forms.Form + func (this *FileSource) Name() string + func (this *FileSource) Presentation() *forms.Presentation + func (this *FileSource) Validate() error + type Group struct + CountAgents int + DayFrom string + DayTo string + Id string + Index int + IsDefault bool + Key string + Keys []*GroupKey + MaxAgents int + Name string + NoticeSetting map[notices.NoticeLevel][]*notices.NoticeReceiver + On bool + func NewGroup(name string) *Group + func (this *Group) AddKey(key *GroupKey) + func (this *Group) AddNoticeReceiver(level notices.NoticeLevel, receiver *notices.NoticeReceiver) + func (this *Group) FindAllNoticeReceivers(level ...notices.NoticeLevel) []*notices.NoticeReceiver + func (this *Group) FindKey(key string) *GroupKey + func (this *Group) GenerateKey() string + func (this *Group) IsAvailable() bool + func (this *Group) IsDateAvailable() bool + func (this *Group) MatchKeyword(keyword string) (matched bool, name string, tags []string) + func (this *Group) RemoveMedia(mediaId string) (found bool) + func (this *Group) RemoveNoticeReceiver(level notices.NoticeLevel, receiverId string) + func (this *Group) WriteToFile(path string) error + type GroupKey struct + CountAgents int + DayFrom string + DayTo string + Id string + Key string + MaxAgents int + Name string + On bool + func NewGroupKey() *GroupKey + func (this *GroupKey) IsAvailable() bool + func (this *GroupKey) IsDateAvailable() bool + type GroupList struct + Groups []*Group + TeaVersion string + func SharedGroupList() *GroupList + func (this *GroupList) AddGroup(group *Group) + func (this *GroupList) BuildIndexes() error + func (this *GroupList) FindAllGroups() []*Group + func (this *GroupList) FindDefaultGroup() *Group + func (this *GroupList) FindGroup(groupId string) *Group + func (this *GroupList) FindGroupWithKey(key string) *Group + func (this *GroupList) Move(fromIndex int, toIndex int) + func (this *GroupList) RemoveGroup(groupId string) + func (this *GroupList) Save() error + type IOStatSource struct + func NewIOStatSource() *IOStatSource + func (this *IOStatSource) Charts() []*widgets.Chart + func (this *IOStatSource) Code() string + func (this *IOStatSource) Description() string + func (this *IOStatSource) Execute(params map[string]string) (value interface{}, err error) + func (this *IOStatSource) Form() *forms.Form + func (this *IOStatSource) Name() string + func (this *IOStatSource) Thresholds() []*Threshold + func (this *IOStatSource) Variables() []*SourceVariable + type Item struct + Charts []*widgets.Chart + Id string + Interval string + Name string + On bool + RecoverSuccesses int + SourceCode string + SourceOptions map[string]interface{} + Thresholds []*Threshold + func NewItem() *Item + func (this *Item) AddChart(chart *widgets.Chart) + func (this *Item) AddFilterCharts(charts []*widgets.Chart, chartId ...string) + func (this *Item) AddThreshold(t ...*Threshold) + func (this *Item) FindChart(chartId string) *widgets.Chart + func (this *Item) IntervalDuration() time.Duration + func (this *Item) MatchKeyword(keyword string) (matched bool, name string, tags []string) + func (this *Item) RemoveChart(chartId string) + func (this *Item) Source() SourceInterface + func (this *Item) TestValue(value interface{}, oldValue interface{}) (threshold *Threshold, row interface{}, level notices.NoticeLevel, ...) + func (this *Item) Validate() error + type LoadSource struct + func NewLoadSource() *LoadSource + func (this *LoadSource) Charts() []*widgets.Chart + func (this *LoadSource) Code() string + func (this *LoadSource) Description() string + func (this *LoadSource) Execute(params map[string]string) (value interface{}, err error) + func (this *LoadSource) Form() *forms.Form + func (this *LoadSource) Name() string + func (this *LoadSource) Thresholds() []*Threshold + func (this *LoadSource) Variables() []*SourceVariable + type MemorySource struct + func NewMemorySource() *MemorySource + func (this *MemorySource) Charts() []*widgets.Chart + func (this *MemorySource) Code() string + func (this *MemorySource) Description() string + func (this *MemorySource) Execute(params map[string]string) (value interface{}, err error) + func (this *MemorySource) Form() *forms.Form + func (this *MemorySource) Name() string + func (this *MemorySource) Thresholds() []*Threshold + func (this *MemorySource) Variables() []*SourceVariable + type MySQLSource struct + Addr string + DatabaseName string + Password string + SQL string + TimeoutSeconds int + Username string + func NewMySQLSource() *MySQLSource + func (this *MySQLSource) Charts() []*widgets.Chart + func (this *MySQLSource) Code() string + func (this *MySQLSource) Description() string + func (this *MySQLSource) Execute(params map[string]string) (value interface{}, err error) + func (this *MySQLSource) Form() *forms.Form + func (this *MySQLSource) Name() string + func (this *MySQLSource) Presentation() *forms.Presentation + func (this *MySQLSource) Stop() error + func (this *MySQLSource) Thresholds() []*Threshold + func (this *MySQLSource) Variables() []*SourceVariable + type NetworkSource struct + InterfaceNames []string + func NewNetworkSource() *NetworkSource + func (this *NetworkSource) Charts() []*widgets.Chart + func (this *NetworkSource) Code() string + func (this *NetworkSource) Description() string + func (this *NetworkSource) Execute(params map[string]string) (value interface{}, err error) + func (this *NetworkSource) Form() *forms.Form + func (this *NetworkSource) Name() string + func (this *NetworkSource) Presentation() *forms.Presentation + func (this *NetworkSource) Thresholds() []*Threshold + func (this *NetworkSource) Variables() []*SourceVariable + type NginxStatusSource struct + URL string + func NewNginxStatusSource() *NginxStatusSource + func (this *NginxStatusSource) Charts() []*widgets.Chart + func (this *NginxStatusSource) Code() string + func (this *NginxStatusSource) Description() string + func (this *NginxStatusSource) Execute(params map[string]string) (value interface{}, err error) + func (this *NginxStatusSource) Form() *forms.Form + func (this *NginxStatusSource) Name() string + func (this *NginxStatusSource) Presentation() *forms.Presentation + func (this *NginxStatusSource) Thresholds() []*Threshold + func (this *NginxStatusSource) Validate() error + func (this *NginxStatusSource) Variables() []*SourceVariable + type PingSource struct + Host string + func NewPingSource() *PingSource + func (this *PingSource) Charts() []*widgets.Chart + func (this *PingSource) Code() string + func (this *PingSource) Description() string + func (this *PingSource) Execute(params map[string]string) (value interface{}, err error) + func (this *PingSource) Form() *forms.Form + func (this *PingSource) Name() string + func (this *PingSource) Presentation() *forms.Presentation + func (this *PingSource) Thresholds() []*Threshold + func (this *PingSource) Variables() []*SourceVariable + type PostgreSQLSource struct + Addr string + DatabaseName string + Password string + SQL string + TimeoutSeconds int + Username string + func NewPostgreSQLSource() *PostgreSQLSource + func (this *PostgreSQLSource) Charts() []*widgets.Chart + func (this *PostgreSQLSource) Code() string + func (this *PostgreSQLSource) Description() string + func (this *PostgreSQLSource) Execute(params map[string]string) (value interface{}, err error) + func (this *PostgreSQLSource) Form() *forms.Form + func (this *PostgreSQLSource) Name() string + func (this *PostgreSQLSource) Presentation() *forms.Presentation + func (this *PostgreSQLSource) Stop() error + func (this *PostgreSQLSource) Thresholds() []*Threshold + func (this *PostgreSQLSource) Variables() []*SourceVariable + type ProcessLog struct + AgentId string + Data string + EventType string + Id shared.ObjectId + ProcessId string + ProcessPid int + TaskId string + TimeFormat struct{ ... } + Timestamp int64 + func (this *ProcessLog) DBColumns() maps.Map + func (this *ProcessLog) SetDBColumns(v maps.Map) + func (this *ProcessLog) SetTime(t time.Time) + type ProcessesSource struct + func NewProcessesSource() *ProcessesSource + func (this *ProcessesSource) Charts() []*widgets.Chart + func (this *ProcessesSource) Code() string + func (this *ProcessesSource) Description() string + func (this *ProcessesSource) Execute(params map[string]string) (value interface{}, err error) + func (this *ProcessesSource) Form() *forms.Form + func (this *ProcessesSource) Name() string + func (this *ProcessesSource) Presentation() *forms.Presentation + func (this *ProcessesSource) Thresholds() []*Threshold + func (this *ProcessesSource) Variables() []*SourceVariable + type ScheduleConfig struct + DayRanges []*ScheduleRangeConfig + HourRanges []*ScheduleRangeConfig + MinuteRanges []*ScheduleRangeConfig + MonthRanges []*ScheduleRangeConfig + SecondRanges []*ScheduleRangeConfig + WeekDayRanges []*ScheduleRangeConfig + YearRanges []*ScheduleRangeConfig + func NewScheduleConfig() *ScheduleConfig + func (this *ScheduleConfig) AddDayRanges(r ...*ScheduleRangeConfig) + func (this *ScheduleConfig) AddHourRanges(r ...*ScheduleRangeConfig) + func (this *ScheduleConfig) AddMinuteRanges(r ...*ScheduleRangeConfig) + func (this *ScheduleConfig) AddMonthRanges(r ...*ScheduleRangeConfig) + func (this *ScheduleConfig) AddSecondRanges(r ...*ScheduleRangeConfig) + func (this *ScheduleConfig) AddWeekDayRanges(r ...*ScheduleRangeConfig) + func (this *ScheduleConfig) AddYearRanges(r ...*ScheduleRangeConfig) + func (this *ScheduleConfig) Next(now time.Time) (t time.Time, ok bool) + func (this *ScheduleConfig) ShouldRun(t time.Time) bool + func (this *ScheduleConfig) Summary() string + func (this *ScheduleConfig) Validate() error + type ScheduleRangeConfig struct + Every bool + From int + Step int + To int + Value int + func NewScheduleRangeConfig() *ScheduleRangeConfig + type ScheduleRangeList struct + Every bool + Ranges []*ScheduleRangeConfig + func NewScheduleRangeList() *ScheduleRangeList + func (this *ScheduleRangeList) Convert(ranges []*ScheduleRangeConfig) + func (this *ScheduleRangeList) Next(current int, defaultValue int) int + type ScriptAction struct + Cwd string + Env []*shared.Variable + Path string + Script string + ScriptLang string + ScriptType string + func NewScriptAction() *ScriptAction + func (this *ScriptAction) AddEnv(name, value string) + func (this *ScriptAction) Code() string + func (this *ScriptAction) Description() string + func (this *ScriptAction) FormattedScript() string + func (this *ScriptAction) Generate(id string) (path string, err error) + func (this *ScriptAction) Name() string + func (this *ScriptAction) Run(params map[string]string) (result string, err error) + func (this *ScriptAction) Summary() maps.Map + func (this *ScriptAction) Validate() error + type ScriptSource struct + Cwd string + Env []*shared.Variable + Path string + Script string + ScriptLang string + ScriptType string + func NewScriptSource() *ScriptSource + func (this *ScriptSource) AddEnv(name, value string) + func (this *ScriptSource) Code() string + func (this *ScriptSource) Description() string + func (this *ScriptSource) Execute(params map[string]string) (value interface{}, err error) + func (this *ScriptSource) Form() *forms.Form + func (this *ScriptSource) FormattedScript() string + func (this *ScriptSource) Generate(id string) (path string, err error) + func (this *ScriptSource) Name() string + func (this *ScriptSource) Presentation() *forms.Presentation + func (this *ScriptSource) Validate() error + type SocketConnectivitySource struct + Address string + Network string + func NewSocketConnectivitySource() *SocketConnectivitySource + func (this *SocketConnectivitySource) Charts() []*widgets.Chart + func (this *SocketConnectivitySource) Code() string + func (this *SocketConnectivitySource) Description() string + func (this *SocketConnectivitySource) Execute(params map[string]string) (value interface{}, err error) + func (this *SocketConnectivitySource) Form() *forms.Form + func (this *SocketConnectivitySource) Name() string + func (this *SocketConnectivitySource) Presentation() *forms.Presentation + func (this *SocketConnectivitySource) Thresholds() []*Threshold + func (this *SocketConnectivitySource) Variables() []*SourceVariable + type Source struct + DataFormat SourceDataFormat + func (this *Source) Charts() []*widgets.Chart + func (this *Source) Code() string + func (this *Source) DataFormatCode() SourceDataFormat + func (this *Source) Description() string + func (this *Source) Platforms() []string + func (this *Source) Presentation() *forms.Presentation + func (this *Source) Stop() error + func (this *Source) Thresholds() []*Threshold + func (this *Source) Validate() error + func (this *Source) Variables() []*SourceVariable + type SourceCategory = string + type SourceDataFormat = uint8 + type SourceInterface interface + Charts func() []*widgets.Chart + Code func() string + DataFormatCode func() SourceDataFormat + Description func() string + Execute func(params map[string]string) (value interface{}, err error) + Form func() *forms.Form + Name func() string + Platforms func() []string + Presentation func() *forms.Presentation + Stop func() error + Thresholds func() []*Threshold + Validate func() error + Variables func() []*SourceVariable + func FindDataSourceInstance(code string, options map[string]interface{}) SourceInterface + type SourceVariable struct + Code string + Description string + type TaskConfig struct + Cwd string + Env []*shared.Variable + Id string + IsBooting bool + IsManual bool + Name string + On bool + Schedule []*ScheduleConfig + Script string + Version uint + func NewTaskConfig() *TaskConfig + func (this *TaskConfig) AddEnv(name string, value string) + func (this *TaskConfig) AddSchedule(schedule *ScheduleConfig) + func (this *TaskConfig) FormattedScript() string + func (this *TaskConfig) Generate() (path string, err error) + func (this *TaskConfig) GenerateAgain() (path string, err error) + func (this *TaskConfig) MatchKeyword(keyword string) (matched bool, name string, tags []string) + func (this *TaskConfig) Next(now time.Time) (next time.Time, ok bool) + func (this *TaskConfig) Validate() error + type TeaWebSource struct + API string + Timeout int + func NewTeaWebSource() *TeaWebSource + func (this *TeaWebSource) Charts() []*widgets.Chart + func (this *TeaWebSource) Code() string + func (this *TeaWebSource) Description() string + func (this *TeaWebSource) Execute(params map[string]string) (value interface{}, err error) + func (this *TeaWebSource) Form() *forms.Form + func (this *TeaWebSource) Name() string + func (this *TeaWebSource) Presentation() *forms.Presentation + func (this *TeaWebSource) Thresholds() []*Threshold + func (this *TeaWebSource) Variables() []*SourceVariable + type Threshold struct + Actions []map[string]interface{} + Id string + MaxFails int + NoticeLevel notices.NoticeLevel + NoticeMessage string + Operator ThresholdOperator + Param string + Value string + func NewThreshold() *Threshold + func (this *Threshold) Eval(value interface{}, old interface{}) (string, error) + func (this *Threshold) Expression() string + func (this *Threshold) RunActions(params map[string]string) error + func (this *Threshold) Test(value interface{}, oldValue interface{}) (ok bool, err error) + func (this *Threshold) TestRow(value interface{}, oldValue interface{}) (ok bool, row interface{}, err error) + func (this *Threshold) Validate() error + type ThresholdOperator = string + const ThresholdOperatorContains + const ThresholdOperatorEq + const ThresholdOperatorEqIP + const ThresholdOperatorGt + const ThresholdOperatorGtIP + const ThresholdOperatorGte + const ThresholdOperatorGteIP + const ThresholdOperatorIPRange + const ThresholdOperatorLt + const ThresholdOperatorLtIP + const ThresholdOperatorLte + const ThresholdOperatorLteIP + const ThresholdOperatorNot + const ThresholdOperatorNotContains + const ThresholdOperatorNotRegexp + const ThresholdOperatorNumberEq + const ThresholdOperatorPrefix + const ThresholdOperatorRegexp + const ThresholdOperatorSuffix + const ThresholdOperatorVersionRange + type URLConnectivitySource struct + Headers []*shared.Variable + Method string + Params []*shared.Variable + TextBody string + Timeout int + URL string + func NewURLConnectivitySource() *URLConnectivitySource + func (this *URLConnectivitySource) Charts() []*widgets.Chart + func (this *URLConnectivitySource) Code() string + func (this *URLConnectivitySource) Description() string + func (this *URLConnectivitySource) Execute(params map[string]string) (value interface{}, err error) + func (this *URLConnectivitySource) Form() *forms.Form + func (this *URLConnectivitySource) Name() string + func (this *URLConnectivitySource) Presentation() *forms.Presentation + func (this *URLConnectivitySource) Thresholds() []*Threshold + func (this *URLConnectivitySource) Variables() []*SourceVariable + type Value struct + AgentId string + AppId string + CostMs float64 + CreatedAt int64 + Error string + Id shared.ObjectId + IsNotified bool + ItemId string + NodeId string + NoticeLevel notices.NoticeLevel + Threshold string + ThresholdId string + TimeFormat struct{ ... } + Timestamp int64 + Value interface{} + func NewValue() *Value + func (this *Value) AllFlatKeys() []string + func (this *Value) DBColumns() maps.Map + func (this *Value) SetDBColumns(v maps.Map) + func (this *Value) SetTime(t time.Time) + type WebHookSource struct + Headers []*shared.Variable + Method string + Params []*shared.Variable + TextBody string + Timeout string + URL string + func NewWebHookSource() *WebHookSource + func (this *WebHookSource) Code() string + func (this *WebHookSource) Description() string + func (this *WebHookSource) Execute(params map[string]string) (value interface{}, err error) + func (this *WebHookSource) Form() *forms.Form + func (this *WebHookSource) Name() string + func (this *WebHookSource) Presentation() *forms.Presentation + func (this *WebHookSource) Validate() error + type WindowsLoadValue struct — windows/amd64 + Timestamp int64 + Value int