executor

type AggregatedAlert struct {
	CumulatedCount  uint32           `json:"cumulated_count"`
	FirstAlertTime  string           `json:"first_alert_time"`
	LastAlertTime   string           `json:"last_alert_time"`
	LastAlertValues []RecordedMetric `json:"last_alert_values"`
}

type AlertReceiver struct {
	// contains filtered or unexported fields
}

type AlertRunner struct {
	AlertConfig ConfigAlert
	AlertStatus StatusAlert
	SignalCh    chan string
	UpdateCh    chan string
}

type AliveReporter struct {
	// contains filtered or unexported fields
}

type BroadcastInfo struct {
	AlertId   string
	Operation string
}

type BroadcastReceiver struct {
	// contains filtered or unexported fields
}

type ConfigAlert struct {
	AlertId            string
	LoadSuccess        bool
	Disabled           bool
	RsTypeName         string
	RsTypeParam        string
	RsFilterName       string
	RsFilterParam      string
	PolicyConfig       map[string]ConfigPolicy `json:"policy_config"`
	AvailableStartTime string
	AvailableEndTime   string
	Language           string
	Rules              map[string]RuleInfo
	Requests           MonitoringRequest
	NfAddressListId    string
}

type ConfigPolicy struct {
	RepeatType              string `json:"repeat_type"`
	RepeatIntervalInitvalue uint32 `json:"repeat_interval_initvalue"`
	MaxSendCount            uint32 `json:"max_send_count"`
}

type Executor struct {
	// contains filtered or unexported fields
}

type ExecutorInfo struct {
	Name      string
	TaskCount int
}

type HealthChecker struct {
	UpdateCh      chan string
	RequestStatus UpdateRequest
	// contains filtered or unexported fields
}

type MonitoringRequest struct {
	RulesSamePeriod map[uint32][]string
	TickCount       map[uint32]uint32
	TickUpperBound  map[uint32]uint32
}

type RecordedMetric struct {
	RuleName     string
	ResourceName string
	// contains filtered or unexported fields
}

type RuleInfo struct {
	RuleName         string
	Disabled         bool
	MonitorPeriods   uint32
	Severity         string
	MetricsType      string
	ConditionType    string
	Thresholds       float64
	Scale            float64
	Unit             string
	ConsecutiveCount uint32
	Inhibit          bool
	MetricName       string
}

type Runner struct {
	sync.RWMutex
	Map map[string]*AlertRunner
}

type StatusAlert struct {
	sync.RWMutex
	ResourceStatus map[string]StatusResource `json:resource_status`
	UpdateTime     time.Time
}

type StatusResource struct {
	CurrentLevel       string          `json:current_level`
	PositiveCount      uint32          `json:positive_count`
	CumulatedSendCount uint32          `json:cumulated_send_count`
	NextResendInterval uint32          `json:next_resend_interval`
	NextSendableTime   time.Time       `json:next_sendable_time`
	AggregatedAlerts   AggregatedAlert `json:aggregated_alerts`
}

type UpdateRequest struct {
	sync.RWMutex
	RequestCount int64
}