bo

package
v1.2.28 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 12, 2025 License: MIT Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Alarm 

type Alarm struct {
	Receiver          string             `json:"receiver"`
	Status            vobj.AlertStatus   `json:"status"`
	Alerts            []*Alert           `json:"alerts"`
	GroupLabels       *label.Labels      `json:"groupLabels"`
	CommonLabels      *label.Labels      `json:"commonLabels"`
	CommonAnnotations *label.Annotations `json:"commonAnnotations"`
	ExternalURL       string             `json:"externalURL"`
	Version           string             `json:"version"`
	GroupKey          string             `json:"groupKey"`
	TruncatedAlerts   int32              `json:"truncatedAlerts"`
}

Alarm alarm detail info

func (*Alarm) Index 

func (a *Alarm) Index() string

Index 生成告警索引

func (*Alarm) Message 

func (a *Alarm) Message() *watch.Message

Message 生成告警消息

func (*Alarm) String 

func (a *Alarm) String() string

String 将告警信息转换为字符串

type Alert 

type Alert struct {
	Status       vobj.AlertStatus  `json:"status"`
	Labels       *label.Labels     `json:"labels"`
	Annotations  label.Annotations `json:"annotations"`
	StartsAt     *types.Time       `json:"startsAt"`
	EndsAt       *types.Time       `json:"endsAt"`
	GeneratorURL string            `json:"generatorURL"`
	Fingerprint  string            `json:"fingerprint"`
	Value        float64           `json:"value"`
}

Alert alert detail info

func NewAlertWithAlertStrInfo 

func NewAlertWithAlertStrInfo(info string) (*Alert, error)

NewAlertWithAlertStrInfo 从告警字符串信息创建告警结构体

func (*Alert) GetExternalURL 

func (a *Alert) GetExternalURL() string

GetExternalURL 生成告警外部链接

func (*Alert) GetFingerprint 

func (a *Alert) GetFingerprint() string

GetFingerprint 生成告警指纹

func (*Alert) Index 

func (a *Alert) Index() string

Index 生成告警索引

func (*Alert) MarshalBinary added in v1.1.0 

func (a *Alert) MarshalBinary() (data []byte, err error)

MarshalBinary 将告警信息编码为二进制

func (*Alert) Message 

func (a *Alert) Message() *watch.Message

Message 生成告警消息

func (*Alert) PushedFlag added in v1.1.0 

func (a *Alert) PushedFlag() string

PushedFlag 生成推送标识

func (*Alert) String 

func (a *Alert) String() string

func (*Alert) UnmarshalBinary added in v1.1.0 

func (a *Alert) UnmarshalBinary(data []byte) error

UnmarshalBinary 将告警信息解码为告警结构体

type Datasource 

type Datasource struct {
	// 数据源类型
	Category vobj.DatasourceType `json:"category,omitempty"`
	// 存储器类型
	StorageType vobj.StorageType `json:"storage_type,omitempty"`
	// 数据源配置 json
	Config string `json:"config,omitempty"`
	// 数据源地址
	Endpoint string `json:"endpoint,omitempty"`
	// 数据源ID
	ID uint32 `json:"id,omitempty"`
	// 状态
	Status vobj.Status `json:"status,omitempty"`
	// 团队ID
	TeamID uint32 `json:"teamId,omitempty"`
}

Datasource 数据源明细

type EventDatasource added in v1.2.0 

type EventDatasource struct {
	TeamID uint32      `json:"team_id"`
	ID     uint32      `json:"id"`
	Status vobj.Status `json:"status"`

	Conf *conf.Event `json:"conf"`
}

EventDatasource MQ 数据源配置

func (*EventDatasource) GetConfig added in v1.2.0 

func (m *EventDatasource) GetConfig() *conf.Event

GetConfig 获取 MQ 配置

func (*EventDatasource) Index added in v1.2.0 

func (m *EventDatasource) Index() string

Index 实现 watch.Indexer 接口

func (*EventDatasource) String added in v1.2.0 

func (m *EventDatasource) String() string

String 实现 fmt.Stringer 接口

type GetMetricsParams 

type GetMetricsParams struct {
	Endpoint string             `json:"endpoint"`
	Config   *datasource.Config `json:"config"`
	// 存储类型
	StorageType vobj.StorageType `json:"storageType"`
}

GetMetricsParams 查询指标请求参数

type IStrategy added in v1.1.0 

type IStrategy interface {
	watch.Indexer
	Message() *watch.Message
	BuilderAlarmBaseInfo() *Alarm
	GetTeamID() uint32
	GetStatus() vobj.Status
	GetReceiverGroupIDs() []uint32
	GetLabelNotices() []*LabelNotices
	GetAnnotations() map[string]string
	GetInterval() *types.Duration
	Eval(ctx context.Context) (map[watch.Indexer]*datasource.Point, error)
	IsCompletelyMeet(values []*datasource.Value) (map[string]any, bool)
}

IStrategy 策略接口

type IStrategyEvent added in v1.1.38 

type IStrategyEvent interface {
	IStrategy

	// SetValue 设置数据
	SetValue(msg *mq.Msg) IStrategyEvent
	// GetDatasource 获取数据源
	GetDatasource() []*EventDatasource
	// GetTopic 获取主题
	GetTopic() string
}

IStrategyEvent 事件策略统一接口

type LabelNotices added in v1.1.0 

type LabelNotices struct {
	// label key
	Key string `json:"key,omitempty"`
	// label value 支持正则
	Value string `json:"value,omitempty"`
	// 接收者 （告警组ID列表）
	ReceiverGroupIDs []uint32 `json:"receiverGroupIDs,omitempty"`
}

LabelNotices 自定义接收者匹配对象

type LogDatasource added in v1.2.26 

type LogDatasource struct {
	TeamID uint32         `json:"team_id"`
	ID     uint32         `json:"id"`
	Status vobj.Status    `json:"status"`
	Conf   *conf.LogQuery `json:"conf"`
}

func (*LogDatasource) Index added in v1.2.26 

func (l *LogDatasource) Index() string

func (*LogDatasource) String added in v1.2.26 

func (l *LogDatasource) String() string

type MetricDetail 

type MetricDetail struct {
	// 指标名称
	Name string `json:"name"`
	// 帮助信息
	Help string `json:"help"`
	// 类型
	Type string `json:"type"`
	// 标签集合
	Labels map[string][]string `json:"labels"`
	// 指标单位
	Unit string `json:"unit"`
}

MetricDetail 指标详情

type PushMetricParams 

type PushMetricParams struct {
	// 指标明细
	*MetricDetail
	// 数据源ID
	DatasourceID uint32 `json:"datasourceId"`
	// 是否完成
	Done bool `json:"done"`
	// 团队ID
	TeamID uint32 `json:"teamId"`
}

PushMetricParams 推送指标请求参数

type QueryQLParams 

type QueryQLParams struct {
	// 查询指标请求参数
	GetMetricsParams
	// 查询QL
	QueryQL string `json:"queryQL"`
	// 时间范围
	TimeRange []string `json:"timeRange"`
	// 步长
	Step uint32 `json:"step"`
}

QueryQLParams 查询QL请求参数

type StrategyDomain added in v1.1.0 

type StrategyDomain struct {
	// 接收者 （告警组ID列表）
	ReceiverGroupIDs []uint32 `json:"receiverGroupIDs,omitempty"`
	// 自定义接收者匹配对象
	LabelNotices []*LabelNotices `json:"labelNotices,omitempty"`
	// 策略ID
	ID uint32 `json:"id,omitempty"`
	// 策略等级ID
	LevelID uint32 `json:"levelId,omitempty"`
	// 团队ID
	TeamID uint32 `json:"teamId,omitempty"`
	// 状态
	Status vobj.Status `json:"status,omitempty"`
	// 策略名称
	Alert string `json:"alert,omitempty"`
	// 阈值
	Threshold float64 `json:"threshold,omitempty"`
	// 策略标签
	Labels *label.Labels `json:"labels,omitempty"`
	// 策略注解
	Annotations *label.Annotations `json:"annotations,omitempty"`
	// 域名
	Domain string `json:"domain,omitempty"`
	// 端口
	Port uint32 `json:"port,omitempty"`
	// 类型
	StrategyType vobj.StrategyType `json:"strategyType,omitempty"`
	// 判断条件
	Condition vobj.Condition `json:"condition,omitempty"`
}

StrategyDomain 证书策略

func (*StrategyDomain) BuilderAlarmBaseInfo added in v1.1.0 

func (s *StrategyDomain) BuilderAlarmBaseInfo() *Alarm

BuilderAlarmBaseInfo 构建告警基础信息

func (*StrategyDomain) Eval added in v1.1.0 

func (s *StrategyDomain) Eval(ctx context.Context) (map[watch.Indexer]*datasource.Point, error)

Eval 策略评估

func (*StrategyDomain) GetAnnotations added in v1.1.0 

func (s *StrategyDomain) GetAnnotations() map[string]string

GetAnnotations 获取策略注解

func (*StrategyDomain) GetInterval added in v1.1.0 

func (s *StrategyDomain) GetInterval() *types.Duration

GetInterval 获取执行频率

func (*StrategyDomain) GetLabelNotices added in v1.1.0 

func (s *StrategyDomain) GetLabelNotices() []*LabelNotices

GetLabelNotices 获取自定义接收者匹配对象

func (*StrategyDomain) GetReceiverGroupIDs added in v1.1.0 

func (s *StrategyDomain) GetReceiverGroupIDs() []uint32

GetReceiverGroupIDs 获取接收者组ID列表

func (*StrategyDomain) GetStatus added in v1.1.0 

func (s *StrategyDomain) GetStatus() vobj.Status

GetStatus 获取策略状态

func (*StrategyDomain) GetTeamID added in v1.1.0 

func (s *StrategyDomain) GetTeamID() uint32

GetTeamID 获取团队ID

func (*StrategyDomain) Index added in v1.1.0 

func (s *StrategyDomain) Index() string

Index 策略唯一索引

func (*StrategyDomain) IsCompletelyMeet added in v1.1.0 

func (s *StrategyDomain) IsCompletelyMeet(values []*datasource.Value) (map[string]any, bool)

IsCompletelyMeet 判断策略是否完全满足条件

func (*StrategyDomain) Message added in v1.1.0 

func (s *StrategyDomain) Message() *watch.Message

Message 策略转消息

func (*StrategyDomain) String added in v1.1.0 

func (s *StrategyDomain) String() string

String 策略转字符串

type StrategyEvent added in v1.1.38 

type StrategyEvent struct {
	// 策略类型
	StrategyType vobj.StrategyType `json:"strategyType,omitempty"`
	// 团队ID
	TeamID uint32 `json:"teamId,omitempty"`
	// 接收者 （告警组ID列表）
	ReceiverGroupIDs []uint32 `json:"receiverGroupIDs,omitempty"`
	// 策略ID
	ID uint32 `json:"id,omitempty"`
	// 策略等级ID
	LevelID uint32 `json:"levelId,omitempty"`
	// 策略名称
	Alert string `json:"alert,omitempty"`
	// 策略语句
	Expr string `json:"expr,omitempty"`
	// 阈值
	Threshold string `json:"threshold,omitempty"`
	// 判断条件
	Condition vobj.EventCondition `json:"condition,omitempty"`
	// 数据类型
	DataType vobj.EventDataType `json:"dataType,omitempty"`
	// 数据 Key
	DataKey string `json:"dataKey,omitempty"`
	// 数据源
	Datasource []*EventDatasource `json:"datasource,omitempty"`
	// 策略状态
	Status vobj.Status `json:"status,omitempty"`
	// 策略标签
	Labels *label.Labels `json:"labels,omitempty"`
	// 策略注解
	Annotations *label.Annotations `json:"annotations,omitempty"`
	// contains filtered or unexported fields
}

StrategyEvent 事件策略明细

func (*StrategyEvent) BuilderAlarmBaseInfo added in v1.1.38 

func (s *StrategyEvent) BuilderAlarmBaseInfo() *Alarm

BuilderAlarmBaseInfo 实现 IStrategy 接口

func (*StrategyEvent) Eval added in v1.1.38 

func (s *StrategyEvent) Eval(_ context.Context) (map[watch.Indexer]*datasource.Point, error)

Eval 实现 IStrategy 接口

func (*StrategyEvent) GetAnnotations added in v1.1.38 

func (s *StrategyEvent) GetAnnotations() map[string]string

GetAnnotations 实现 IStrategy 接口

func (*StrategyEvent) GetDatasource added in v1.1.38 

func (s *StrategyEvent) GetDatasource() []*EventDatasource

GetDatasource 获取数据源

func (*StrategyEvent) GetInterval added in v1.1.38 

func (s *StrategyEvent) GetInterval() *types.Duration

GetInterval 实现 IStrategy 接口

func (*StrategyEvent) GetLabelNotices added in v1.1.38 

func (s *StrategyEvent) GetLabelNotices() []*LabelNotices

GetLabelNotices 实现 IStrategy 接口

func (*StrategyEvent) GetReceiverGroupIDs added in v1.1.38 

func (s *StrategyEvent) GetReceiverGroupIDs() []uint32

GetReceiverGroupIDs 实现 IStrategy 接口

func (*StrategyEvent) GetStatus added in v1.1.38 

func (s *StrategyEvent) GetStatus() vobj.Status

GetStatus 实现 IStrategy 接口

func (*StrategyEvent) GetTeamID added in v1.1.38 

func (s *StrategyEvent) GetTeamID() uint32

GetTeamID 实现 IStrategy 接口

func (*StrategyEvent) GetTopic added in v1.1.38 

func (s *StrategyEvent) GetTopic() string

GetTopic 获取主题

func (*StrategyEvent) Index added in v1.1.38 

func (s *StrategyEvent) Index() string

Index 实现 watch.Indexer 接口

func (*StrategyEvent) IsCompletelyMeet added in v1.1.38 

func (s *StrategyEvent) IsCompletelyMeet(values []*datasource.Value) (map[string]any, bool)

IsCompletelyMeet 实现 IStrategy 接口

func (*StrategyEvent) Message added in v1.1.38 

func (s *StrategyEvent) Message() *watch.Message

Message 实现 watch.Message 接口

func (*StrategyEvent) SetValue added in v1.1.38 

func (s *StrategyEvent) SetValue(msg *mq.Msg) IStrategyEvent

SetValue 设置数据

func (*StrategyEvent) String added in v1.1.38 

func (s *StrategyEvent) String() string

String 实现 fmt.Stringer 接口

type StrategyHTTP added in v1.2.0 

type StrategyHTTP struct {
	// 类型
	StrategyType vobj.StrategyType `json:"strategyType,omitempty"`
	// url 地址
	URL string `json:"url,omitempty"`
	// 状态码 200 404 500
	StatusCode string `json:"statusCode,omitempty"`
	// 状态码匹配模式
	StatusCodeCondition vobj.Condition `json:"statusCodeCondition,omitempty"`
	// 请求头
	Headers map[string]string `json:"headers,omitempty"`
	// 请求体
	Body string `json:"body,omitempty"`
	// 请求方式
	Method vobj.HTTPMethod `json:"method,omitempty"`
	// 响应时间阈值
	ResponseTime float64 `json:"responseTime,omitempty"`
	// 响应时间阈值条件
	ResponseTimeCondition vobj.Condition `json:"responseTimeCondition,omitempty"`
	// 策略标签
	Labels *label.Labels `json:"labels,omitempty"`
	// 策略注解
	Annotations *label.Annotations `json:"annotations,omitempty"`
	// 接收者 （告警组ID列表）
	ReceiverGroupIDs []uint32 `json:"receiverGroupIDs,omitempty"`
	// 自定义接收者匹配对象
	LabelNotices []*LabelNotices `json:"labelNotices,omitempty"`
	// 团队ID
	TeamID uint32 `json:"teamId,omitempty"`
	// 状态
	Status vobj.Status `json:"status,omitempty"`
	// 策略名称
	Alert string `json:"alert,omitempty"`
	// 策略级别ID
	LevelID uint32 `json:"levelId,omitempty"`
	// 策略ID
	ID uint32 `json:"id,omitempty"`
}

StrategyHTTP 端点响应时间、状态码策略

func (*StrategyHTTP) BuilderAlarmBaseInfo added in v1.2.0 

func (e *StrategyHTTP) BuilderAlarmBaseInfo() *Alarm

BuilderAlarmBaseInfo 生成告警基础信息

func (*StrategyHTTP) Eval added in v1.2.0 

func (e *StrategyHTTP) Eval(ctx context.Context) (map[watch.Indexer]*datasource.Point, error)

Eval 评估策略

func (*StrategyHTTP) GetAnnotations added in v1.2.0 

func (e *StrategyHTTP) GetAnnotations() map[string]string

GetAnnotations 获取策略注解

func (*StrategyHTTP) GetInterval added in v1.2.0 

func (e *StrategyHTTP) GetInterval() *types.Duration

GetInterval 获取执行频率

func (*StrategyHTTP) GetLabelNotices added in v1.2.0 

func (e *StrategyHTTP) GetLabelNotices() []*LabelNotices

GetLabelNotices 获取自定义接收者匹配对象

func (*StrategyHTTP) GetReceiverGroupIDs added in v1.2.0 

func (e *StrategyHTTP) GetReceiverGroupIDs() []uint32

GetReceiverGroupIDs 获取接收者组ID列表

func (*StrategyHTTP) GetStatus added in v1.2.0 

func (e *StrategyHTTP) GetStatus() vobj.Status

GetStatus 获取策略状态

func (*StrategyHTTP) GetTeamID added in v1.2.0 

func (e *StrategyHTTP) GetTeamID() uint32

GetTeamID 获取团队ID

func (*StrategyHTTP) Index added in v1.2.0 

func (e *StrategyHTTP) Index() string

Index 生成策略索引

func (*StrategyHTTP) IsCompletelyMeet added in v1.2.0 

func (e *StrategyHTTP) IsCompletelyMeet(values []*datasource.Value) (map[string]any, bool)

IsCompletelyMeet 是否完全满足策略条件

func (*StrategyHTTP) Message added in v1.2.0 

func (e *StrategyHTTP) Message() *watch.Message

Message 生成策略消息

func (*StrategyHTTP) String added in v1.2.0 

func (e *StrategyHTTP) String() string

String 将策略端点转换为字符串

type StrategyLogs added in v1.2.26 

type StrategyLogs struct {
	// 类型
	Type vobj.StrategyType `json:"type,omitempty"`
	// 团队ID
	TeamID uint32 `json:"teamId,omitempty"`
	// 接收者 （告警组ID列表）
	ReceiverGroupIDs []uint32 `json:"receiverGroupIDs,omitempty"`
	// 策略ID
	ID uint32 `json:"id,omitempty"`
	// 策略等级ID
	LevelID uint32 `json:"levelId,omitempty"`
	// 策略名称
	Alert string `json:"alert,omitempty"`
	// 策略语句
	Expr string `json:"expr,omitempty"`
	// 策略状态
	Status vobj.Status `json:"status,omitempty"`
	// 策略标签
	Labels *label.Labels `json:"labels,omitempty"`
	// 策略注解
	Annotations *label.Annotations      `json:"annotations,omitempty"`
	ResLog      *datasource.LogResponse `json:"resLog,omitempty"`
	// 自定义接收者匹配对象
	LabelNotices []*LabelNotices `json:"labelNotices,omitempty"`
	// 数据源
	Datasource []*LogDatasource `json:"datasource,omitempty"`
	// 持续次数
	Count uint32 `json:"count,omitempty"`
	// 策略持续时间
	For *types.Duration `json:"for,omitempty"`
}

func (*StrategyLogs) BuilderAlarmBaseInfo added in v1.2.26 

func (s *StrategyLogs) BuilderAlarmBaseInfo() *Alarm

func (*StrategyLogs) Eval added in v1.2.26 

func (s *StrategyLogs) Eval(ctx context.Context) (map[watch.Indexer]*datasource.Point, error)

func (*StrategyLogs) GetAnnotations added in v1.2.26 

func (s *StrategyLogs) GetAnnotations() map[string]string

GetAnnotations 获取策略注解

func (*StrategyLogs) GetInterval added in v1.2.26 

func (s *StrategyLogs) GetInterval() *types.Duration

GetInterval 获取执行频率

func (*StrategyLogs) GetLabelNotices added in v1.2.26 

func (s *StrategyLogs) GetLabelNotices() []*LabelNotices

GetLabelNotices 获取自定义接收者匹配对象

func (*StrategyLogs) GetReceiverGroupIDs added in v1.2.26 

func (s *StrategyLogs) GetReceiverGroupIDs() []uint32

GetReceiverGroupIDs 获取接收者组ID列表

func (*StrategyLogs) GetStatus added in v1.2.26 

func (s *StrategyLogs) GetStatus() vobj.Status

GetStatus 获取策略状态

func (*StrategyLogs) GetTeamID added in v1.2.26 

func (s *StrategyLogs) GetTeamID() uint32

GetTeamID 获取团队ID

func (*StrategyLogs) Index added in v1.2.26 

func (s *StrategyLogs) Index() string

func (*StrategyLogs) IsCompletelyMeet added in v1.2.26 

func (s *StrategyLogs) IsCompletelyMeet(values []*datasource.Value) (map[string]any, bool)

IsCompletelyMeet 是否满足条件

func (*StrategyLogs) Message added in v1.2.26 

func (s *StrategyLogs) Message() *watch.Message

func (*StrategyLogs) String added in v1.2.26 

func (s *StrategyLogs) String() string

type StrategyMetric added in v1.1.0 

type StrategyMetric struct {
	// 接收者 （告警组ID列表）
	ReceiverGroupIDs []uint32 `json:"receiverGroupIDs,omitempty"`
	// 自定义接收者匹配对象
	LabelNotices []*LabelNotices `json:"labelNotices,omitempty"`
	// 策略ID
	ID uint32 `json:"id,omitempty"`
	// 策略等级ID
	LevelID uint32 `json:"levelId,omitempty"`
	// 策略名称
	Alert string `json:"alert,omitempty"`
	// 策略语句
	Expr string `json:"expr,omitempty"`
	// 策略持续时间
	For *types.Duration `json:"for,omitempty"`
	// 持续次数
	Count uint32 `json:"count,omitempty"`
	// 持续的类型
	SustainType vobj.Sustain `json:"sustainType,omitempty"`
	// 策略标签
	Labels *label.Labels `json:"labels,omitempty"`
	// 策略注解
	Annotations *label.Annotations `json:"annotations,omitempty"`
	// 数据源
	Datasource []*Datasource `json:"datasource,omitempty"`
	// 策略状态
	Status vobj.Status `json:"status,omitempty"`
	// 判断条件
	Condition vobj.Condition `json:"condition,omitempty"`
	// 阈值
	Threshold float64 `json:"threshold,omitempty"`
	// 团队ID
	TeamID uint32 `json:"teamId,omitempty"`
	// 策略类型
	StrategyType vobj.StrategyType `json:"strategyType,omitempty"`
}

StrategyMetric 策略明细

func (*StrategyMetric) BuilderAlarmBaseInfo added in v1.1.0 

func (s *StrategyMetric) BuilderAlarmBaseInfo() *Alarm

BuilderAlarmBaseInfo 生成告警基础信息

func (*StrategyMetric) Eval added in v1.1.0 

func (s *StrategyMetric) Eval(ctx context.Context) (map[watch.Indexer]*datasource.Point, error)

Eval 评估策略

func (*StrategyMetric) GetAnnotations added in v1.1.0 

func (s *StrategyMetric) GetAnnotations() map[string]string

GetAnnotations 获取策略注解

func (*StrategyMetric) GetInterval added in v1.1.0 

func (s *StrategyMetric) GetInterval() *types.Duration

GetInterval 获取执行频率

func (*StrategyMetric) GetLabelNotices added in v1.1.0 

func (s *StrategyMetric) GetLabelNotices() []*LabelNotices

GetLabelNotices 获取自定义接收者匹配对象

func (*StrategyMetric) GetReceiverGroupIDs added in v1.1.0 

func (s *StrategyMetric) GetReceiverGroupIDs() []uint32

GetReceiverGroupIDs 获取接收者组ID列表

func (*StrategyMetric) GetStatus added in v1.1.0 

func (s *StrategyMetric) GetStatus() vobj.Status

GetStatus 获取策略状态

func (*StrategyMetric) GetTeamID added in v1.1.0 

func (s *StrategyMetric) GetTeamID() uint32

GetTeamID 获取团队ID

func (*StrategyMetric) Index added in v1.1.0 

func (s *StrategyMetric) Index() string

Index 策略唯一索引

func (*StrategyMetric) IsCompletelyMeet added in v1.1.0 

func (s *StrategyMetric) IsCompletelyMeet(values []*datasource.Value) (map[string]any, bool)

IsCompletelyMeet 判断策略是否完全满足条件

func (*StrategyMetric) Message added in v1.1.0 

func (s *StrategyMetric) Message() *watch.Message

Message 策略转消息

func (*StrategyMetric) String added in v1.1.0 

func (s *StrategyMetric) String() string

String 将策略转换为字符串

type StrategyPing added in v1.1.0 

type StrategyPing struct {
	// 类型
	Type vobj.StrategyType `json:"type,omitempty"`
	// 策略ID
	StrategyID uint32 `json:"strategy_id,omitempty"`
	// 团队ID
	TeamID uint32 `json:"teamId,omitempty"`
	// 状态
	Status vobj.Status `json:"status,omitempty"`
	// 策略名称
	Alert string `json:"alert,omitempty"`
	// 策略级别ID
	LevelID uint32 `json:"levelId,omitempty"`
	// 策略标签
	Labels *label.Labels `json:"labels,omitempty"`
	// 策略注解
	Annotations *label.Annotations `json:"annotations,omitempty"`
	// 接收者 （告警组ID列表）
	ReceiverGroupIDs []uint32 `json:"receiverGroupIDs,omitempty"`
	// 域名或IP
	Address string `json:"address,omitempty"`

	// 总包数
	TotalPackets float64 `json:"totalPackets,omitempty"`
	// 成功包数
	SuccessPackets float64 `json:"successPackets,omitempty"`
	// 丢包率
	LossRate float64 `json:"lossRate,omitempty"`
	// 最小延迟
	MinDelay float64 `json:"minDelay,omitempty"`
	// 最大延迟
	MaxDelay float64 `json:"maxDelay,omitempty"`
	// 平均延迟
	AvgDelay float64 `json:"avgDelay,omitempty"`
	// 标准差
	StdDevDelay float64 `json:"stdDevDelay,omitempty"`
}

StrategyPing ping 策略

func (*StrategyPing) BuilderAlarmBaseInfo added in v1.1.0 

func (s *StrategyPing) BuilderAlarmBaseInfo() *Alarm

BuilderAlarmBaseInfo 生成告警基础信息

func (*StrategyPing) Eval added in v1.1.0 

func (s *StrategyPing) Eval(ctx context.Context) (map[watch.Indexer]*datasource.Point, error)

Eval 评估策略

func (*StrategyPing) GetAnnotations added in v1.1.0 

func (s *StrategyPing) GetAnnotations() map[string]string

GetAnnotations 获取策略注解

func (*StrategyPing) GetInterval added in v1.1.0 

func (s *StrategyPing) GetInterval() *types.Duration

GetInterval 获取执行频率

func (*StrategyPing) GetLabelNotices added in v1.1.0 

func (s *StrategyPing) GetLabelNotices() []*LabelNotices

GetLabelNotices 获取自定义接收者匹配对象

func (*StrategyPing) GetReceiverGroupIDs added in v1.1.0 

func (s *StrategyPing) GetReceiverGroupIDs() []uint32

GetReceiverGroupIDs 获取接收者组ID列表

func (*StrategyPing) GetStatus added in v1.1.0 

func (s *StrategyPing) GetStatus() vobj.Status

GetStatus 获取策略状态

func (*StrategyPing) GetTeamID added in v1.1.0 

func (s *StrategyPing) GetTeamID() uint32

GetTeamID 获取团队ID

func (*StrategyPing) Index added in v1.1.0 

func (s *StrategyPing) Index() string

Index 生成策略索引

func (*StrategyPing) IsCompletelyMeet added in v1.1.0 

func (s *StrategyPing) IsCompletelyMeet(values []*datasource.Value) (map[string]any, bool)

IsCompletelyMeet 是否完全满足策略条件

func (*StrategyPing) Message added in v1.1.0 

func (s *StrategyPing) Message() *watch.Message

Message 生成策略消息

func (*StrategyPing) String added in v1.1.0 

func (s *StrategyPing) String() string

String 将策略转换为字符串

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.