agents

package

Go to main page

Versions in this module

v0

v0.1.72

Sep 3, 2019

v0.1.12

Jun 25, 2020

v0.1.10

Mar 29, 2020

v0.1.9

Nov 25, 2019

Changes in this version

+ var RegexpParamNamedVariable = regexp.MustCompile(`(?U)\${[$\w\s.-]+(\s*\|.+)?}`)

+ 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 RegisterFunc(code string, f interface{})

+ func RunFuncExpr(value interface{}, expr []byte) (interface{}, error)

type ThresholdOperator

+ const ThresholdOperatorEqIP

+ const ThresholdOperatorGtIP

+ const ThresholdOperatorGteIP

+ const ThresholdOperatorIPRange

+ const ThresholdOperatorLtIP

+ const ThresholdOperatorLteIP

+ const ThresholdOperatorVersionRange

v0.1.8

Sep 30, 2019

Changes in this version

type AgentConfig

+ GroupKey string

+ func (this *AgentConfig) FirstGroup() *Group

type AgentList

+ func (this *AgentList) CountAgentsInGroup(groupId string) int

type Group

+ CountAgents int

+ DayFrom string

+ DayTo string

+ Keys []*GroupKey

+ MaxAgents int

+ func (this *Group) AddKey(key *GroupKey)

+ func (this *Group) FindKey(key string) *GroupKey

+ func (this *Group) IsAvailable() bool

+ func (this *Group) IsDateAvailable() bool

+ 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

+ func (this *GroupList) BuildIndexes() 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 MySQLSource

+ func (this *MySQLSource) Stop() error

type NetworkSource

+ InterfaceNames []string

+ func (this *NetworkSource) Presentation() *forms.Presentation

type PostgreSQLSource

+ func (this *PostgreSQLSource) Stop() error

type ProcessLog

+ func (this *ProcessLog) DBColumns() maps.Map

+ func (this *ProcessLog) SetDBColumns(v maps.Map)

type Source

+ func (this *Source) Stop() error

type SourceInterface

+ Stop func() error

type URLConnectivitySource

+ Headers []*shared.Variable

+ Params []*shared.Variable

+ TextBody string

type Value

+ CostMs float64

+ func (this *Value) AllFlatKeys() []string

+ func (this *Value) DBColumns() maps.Map

+ func (this *Value) SetDBColumns(v maps.Map)

type WebHookSource

+ Headers []*shared.Variable

+ Params []*shared.Variable

+ TextBody string

v0.1.7

Sep 1, 2019

Changes in this version

type AgentConfig

+ TeaVersion string

+ func (this *AgentConfig) BelongsToGroup(groupId string) bool

+ func (this *AgentConfig) BelongsToGroups(groupIds []string) bool

+ func (this *AgentConfig) MatchKeyword(keyword string) (matched bool, name string, tags []string)

type AppConfig

+ func (this *AppConfig) MatchKeyword(keyword string) (matched bool, name string, tags []string)

type Board

+ TeaVersion string

type BoardChart

+ DayFrom string

+ DayTo string

+ Name string

+ TimePast teaconfigs.TimePast

+ TimeType string

type DiskSource

+ ContainsAllMountPoints bool

+ func (this *DiskSource) Presentation() *forms.Presentation

type Group

+ IsDefault bool

+ Key string

+ func (this *Group) GenerateKey() string

+ func (this *Group) MatchKeyword(keyword string) (matched bool, name string, tags []string)

+ type GroupList struct

+ Groups []*Group

+ TeaVersion string

+ func SharedGroupList() *GroupList

+ func (this *GroupList) AddGroup(group *Group)

+ 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 Item

+ func (this *Item) AddFilterCharts(charts []*widgets.Chart, chartId ...string)

+ func (this *Item) MatchKeyword(keyword string) (matched bool, name string, tags []string)

+ 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) SetTime(t time.Time)

type TaskConfig

+ func (this *TaskConfig) MatchKeyword(keyword string) (matched bool, name string, tags []string)

v0.1.6

Jul 21, 2019

Changes in this version

+ func DefaultGroupFile() string

type Group

+ func LoadDefaultGroup() *Group

+ func (this *Group) WriteToFile(path string) error

v0.1.5

Jun 9, 2019

Changes in this version

type AgentConfig

+ func (this *AgentConfig) MoveApp(fromIndex int, toIndex int)

+ 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) Thresholds() []*Threshold

+ func (this *PostgreSQLSource) Variables() []*SourceVariable

v0.1.4

May 19, 2019

Changes in this version

type Value

+ NodeId string

v0.1.3

May 4, 2019

Changes in this version

type AgentConfig

+ func (this *AgentConfig) GroupName() string

v0.1.2

Apr 19, 2019

Changes in this version

+ const SourceCategoryBasic

+ const SourceCategoryCommon

+ const SourceCategoryPlugin

+ const ThresholdOperatorNumberEq

+ func ConvertSourceToMap(source SourceInterface) map[string]interface

+ func EvalParam(param string, value interface{}, old interface{}, varMapping maps.Map, ...) (string, error)

+ func NotifyAgentsChange()

+ func RegisterAllDataSources()

+ func RegisterDataSource(dataSource SourceInterface, category SourceCategory)

type AgentConfig

+ AppsIsInitialized bool

+ AutoUpdates bool

+ CheckDisconnections bool

+ NoticeSetting map[notices.NoticeLevel][]*notices.NoticeReceiver

+ func AllSharedAgents() []*AgentConfig

+ func SharedAgents() []*AgentConfig

+ func (this *AgentConfig) AddDefaultApps()

+ func (this *AgentConfig) AddNoticeReceiver(level notices.NoticeLevel, receiver *notices.NoticeReceiver)

+ func (this *AgentConfig) CountNoticeReceivers() int

+ func (this *AgentConfig) FindAllNoticeReceivers(level ...notices.NoticeLevel) []*notices.NoticeReceiver

+ func (this *AgentConfig) HasApp(appId string) bool

+ func (this *AgentConfig) InGroups(groupIds []string) bool

+ func (this *AgentConfig) RemoveMedia(mediaId string) (found bool)

+ func (this *AgentConfig) RemoveNoticeReceiver(level notices.NoticeLevel, receiverId string)

+ func (this *AgentConfig) ReplaceApp(app *AppConfig)

type AppConfig

+ IsSharedWithGroup bool

+ NoticeSetting map[notices.NoticeLevel][]*notices.NoticeReceiver

+ SharedAgentIds []string

+ func (this *AppConfig) AddNoticeReceiver(level notices.NoticeLevel, receiver *notices.NoticeReceiver)

+ func (this *AppConfig) CountNoticeReceivers() int

+ func (this *AppConfig) FindAllNoticeReceivers(level ...notices.NoticeLevel) []*notices.NoticeReceiver

+ func (this *AppConfig) RemoveMedia(mediaId string) (found bool)

+ func (this *AppConfig) RemoveNoticeReceiver(level notices.NoticeLevel, receiverId string)

+ 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

+ func (this *Board) HasChart(chartId string) bool

+ func (this *Board) MoveChart(fromIndex int, toIndex int)

+ func (this *Board) RemoveApp(appId 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

+ 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) 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

+ func (this *FileSource) Form() *forms.Form

+ func (this *FileSource) Presentation() *forms.Presentation

type Group

+ func (this *Group) FindAllNoticeReceivers(level ...notices.NoticeLevel) []*notices.NoticeReceiver

+ func (this *Group) RemoveMedia(mediaId string) (found bool)

type Item

+ RecoverSuccesses int

+ 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) Thresholds() []*Threshold

+ func (this *MySQLSource) Variables() []*SourceVariable

+ type NetworkSource struct

+ 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) 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 PluginSource struct

+ func NewPluginSource() *PluginSource

+ func (this *PluginSource) AddChart(chart *widgets.Chart)

+ func (this *PluginSource) AddThreshold(threshold *Threshold)

+ func (this *PluginSource) AddVariable(variable *SourceVariable)

+ func (this *PluginSource) Charts() []*widgets.Chart

+ func (this *PluginSource) Code() string

+ func (this *PluginSource) Description() string

+ func (this *PluginSource) Execute(params map[string]string) (value interface{}, err error)

+ func (this *PluginSource) Form() *forms.Form

+ func (this *PluginSource) Name() string

+ func (this *PluginSource) Platforms() []string

+ func (this *PluginSource) Presentation() *forms.Presentation

+ func (this *PluginSource) SetCode(code string)

+ func (this *PluginSource) SetDescription(description string)

+ func (this *PluginSource) SetForm(form *forms.Form)

+ func (this *PluginSource) SetName(name string)

+ func (this *PluginSource) SetPlatforms(platforms []string)

+ func (this *PluginSource) SetPresentation(presentation *forms.Presentation)

+ func (this *PluginSource) Thresholds() []*Threshold

+ func (this *PluginSource) Variables() []*SourceVariable

+ 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 ScriptSource

+ func (this *ScriptSource) Form() *forms.Form

+ func (this *ScriptSource) Presentation() *forms.Presentation

+ 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) Thresholds() []*Threshold

+ func (this *Source) Validate() error

+ func (this *Source) Variables() []*SourceVariable

+ type SourceCategory = string

type SourceInterface

+ Charts func() []*widgets.Chart

+ Form func() *forms.Form

+ Platforms func() []string

+ Presentation func() *forms.Presentation

+ Thresholds func() []*Threshold

+ Variables func() []*SourceVariable

+ type SourceVariable struct

+ Code string

+ Description string

+ 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

+ MaxFails int

+ func (this *Threshold) Expression() string

+ func (this *Threshold) TestRow(value interface{}, oldValue interface{}) (ok bool, row interface{}, err error)

+ type URLConnectivitySource struct

+ Method 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

+ CreatedAt int64

+ IsNotified bool

+ Threshold string

+ ThresholdId string

type WebHookSource

+ func (this *WebHookSource) Form() *forms.Form

+ func (this *WebHookSource) Presentation() *forms.Presentation

+ type WindowsLoadValue struct — windows/amd64

+ Timestamp int64

+ Value int

v0.0.9

Mar 4, 2019

Changes in this version

+ const SourceDataFormatJSON

+ const SourceDataFormatMultipleLine

+ const SourceDataFormatSingeLine

+ const SourceDataFormatYAML

+ const ThresholdOperatorContains

+ const ThresholdOperatorEq

+ const ThresholdOperatorGt

+ const ThresholdOperatorGte

+ const ThresholdOperatorLt

+ const ThresholdOperatorLte

+ const ThresholdOperatorNot

+ const ThresholdOperatorNotContains

+ const ThresholdOperatorNotRegexp

+ const ThresholdOperatorPrefix

+ const ThresholdOperatorRegexp

+ const ThresholdOperatorSuffix

+ func AllActions() []maps.Map

+ func AllDataSources() []maps.Map

+ func AllSourceDataFormats() []maps.Map

+ func AllThresholdOperators() []maps.Map

+ func DecodeSource(data []byte, format SourceDataFormat) (value interface{}, err 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

+ 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

+ CountDisconnections int

+ GroupIds []string

+ Host string

+ Id string

+ Key string

+ Name string

+ On bool

+ Version uint

+ func LocalAgentConfig() *AgentConfig

+ func NewAgentConfig() *AgentConfig

+ func NewAgentConfigFromFile(filename string) *AgentConfig

+ func NewAgentConfigFromId(agentId string) *AgentConfig

+ func (this *AgentConfig) AddApp(app *AppConfig)

+ func (this *AgentConfig) AddApps(apps []*AppConfig)

+ func (this *AgentConfig) AddGroup(groupId string)

+ func (this *AgentConfig) Delete() error

+ func (this *AgentConfig) EncodeYAML() ([]byte, error)

+ func (this *AgentConfig) Filename() string

+ func (this *AgentConfig) FindApp(appId string) *AppConfig

+ func (this *AgentConfig) FindItem(itemId string) (appConfig *AppConfig, item *Item)

+ func (this *AgentConfig) FindSystemApps() []*AppConfig

+ func (this *AgentConfig) FindTask(taskId string) (appConfig *AppConfig, taskConfig *TaskConfig)

+ func (this *AgentConfig) IsLocal() bool

+ func (this *AgentConfig) RemoveApp(appId string)

+ func (this *AgentConfig) RemoveGroup(groupId string)

+ func (this *AgentConfig) ResetSystemApps()

+ 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) 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

+ IsSystem bool

+ Items []*Item

+ Name string

+ On bool

+ Tasks []*TaskConfig

+ func NewAppConfig() *AppConfig

+ func NewSystemAppConfig(id string) *AppConfig

+ func (this *AppConfig) AddItem(item *Item)

+ func (this *AppConfig) AddTask(task *TaskConfig)

+ 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) RemoveItem(itemId string)

+ func (this *AppConfig) RemoveTask(taskId string)

+ func (this *AppConfig) Validate() error

+ type Board struct

+ Charts []*BoardChart

+ Filename string

+ func NewAgentBoard(agentId string) *Board

+ func (this *Board) AddChart(appId, itemId, chartId string)

+ func (this *Board) FindChart(chartId string) *BoardChart

+ func (this *Board) RemoveChart(chartId string)

+ func (this *Board) Save() error

+ type BoardChart struct

+ AppId string

+ ChartId string

+ ItemId string

+ type FileSource struct

+ DataFormat SourceDataFormat

+ Path string

+ func NewFileSource() *FileSource

+ func (this *FileSource) Code() string

+ func (this *FileSource) DataFormatCode() SourceDataFormat

+ func (this *FileSource) Description() string

+ func (this *FileSource) Execute(params map[string]string) (value interface{}, err error)

+ func (this *FileSource) Name() string

+ func (this *FileSource) Summary() maps.Map

+ func (this *FileSource) Validate() error

+ type Group struct

+ Id string

+ Index int

+ Name string

+ NoticeSetting map[notices.NoticeLevel][]*notices.NoticeReceiver

+ On bool

+ func NewGroup(name string) *Group

+ func (this *Group) AddNoticeReceiver(level notices.NoticeLevel, receiver *notices.NoticeReceiver)

+ func (this *Group) RemoveNoticeReceiver(level notices.NoticeLevel, receiverId string)

+ type GroupConfig struct

+ Filename string

+ Groups []*Group

+ func SharedGroupConfig() *GroupConfig

+ func (this *GroupConfig) AddGroup(group *Group)

+ func (this *GroupConfig) FindAllGroups() []*Group

+ func (this *GroupConfig) FindGroup(groupId string) *Group

+ func (this *GroupConfig) Move(fromIndex int, toIndex int)

+ func (this *GroupConfig) RemoveGroup(groupId string)

+ func (this *GroupConfig) Save() error

+ type Item struct

+ Charts []*widgets.Chart

+ Id string

+ Interval string

+ Name string

+ On bool

+ SourceCode string

+ SourceOptions map[string]interface{}

+ Thresholds []*Threshold

+ func NewItem() *Item

+ func (this *Item) AddChart(chart *widgets.Chart)

+ func (this *Item) AddThreshold(t *Threshold)

+ func (this *Item) FindChart(chartId string) *widgets.Chart

+ func (this *Item) IntervalDuration() time.Duration

+ func (this *Item) RemoveChart(chartId string)

+ func (this *Item) Source() SourceInterface

+ func (this *Item) TestValue(value interface{}) (level notices.NoticeLevel, message string)

+ func (this *Item) Validate() error

+ 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.EnvVariable

+ 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

+ DataFormat SourceDataFormat

+ Env []*shared.EnvVariable

+ 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) DataFormatCode() SourceDataFormat

+ func (this *ScriptSource) Description() string

+ func (this *ScriptSource) Execute(params map[string]string) (value interface{}, err error)

+ func (this *ScriptSource) FormattedScript() string

+ func (this *ScriptSource) Generate(id string) (path string, err error)

+ func (this *ScriptSource) Name() string

+ func (this *ScriptSource) Summary() maps.Map

+ func (this *ScriptSource) Validate() error

+ type SourceDataFormat = uint8

+ type SourceInterface interface

+ Code func() string

+ DataFormatCode func() SourceDataFormat

+ Description func() string

+ Execute func(params map[string]string) (value interface{}, err error)

+ Name func() string

+ Summary func() maps.Map

+ Validate func() error

+ func FindDataSourceInstance(code string, options map[string]interface{}) SourceInterface

+ type TaskConfig struct

+ Cwd string

+ Env []*shared.EnvVariable

+ 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) Next(now time.Time) (next time.Time, ok bool)

+ func (this *TaskConfig) Validate() error

+ type Threshold struct

+ Actions []map[string]interface{}

+ Id string

+ NoticeLevel notices.NoticeLevel

+ NoticeMessage string

+ Operator ThresholdOperator

+ Param string

+ Value string

+ func NewThreshold() *Threshold

+ func (this *Threshold) Eval(value interface{}) string

+ func (this *Threshold) RunActions(params map[string]string) error

+ func (this *Threshold) Test(value interface{}) bool

+ func (this *Threshold) Validate() error

+ type ThresholdOperator = string

+ type Value struct

+ AgentId string

+ AppId string

+ Error string

+ Id primitive.ObjectID

+ ItemId string

+ NoticeLevel notices.NoticeLevel

+ TimeFormat struct{ ... }

+ Timestamp int64

+ Value interface{}

+ func NewValue() *Value

+ func (this *Value) SetTime(t time.Time)

+ type WebHookSource struct

+ DataFormat SourceDataFormat

+ Method string

+ Timeout string

+ URL string

+ func NewWebHookSource() *WebHookSource

+ func (this *WebHookSource) Code() string

+ func (this *WebHookSource) DataFormatCode() SourceDataFormat

+ func (this *WebHookSource) Description() string

+ func (this *WebHookSource) Execute(params map[string]string) (value interface{}, err error)

+ func (this *WebHookSource) Name() string

+ func (this *WebHookSource) Summary() maps.Map

+ func (this *WebHookSource) Validate() error

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