events

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

type ChannelReceiverProvider interface {
	GetChannelReceiver(channel string, names []string) map[string]string
}

type ChannelSpec struct {
	Key       string            `yaml:"key" json:"key"`
	Name      string            `yaml:"name" json:"name"`
	MaxLength int               `yaml:"max_length" json:"-"` // 允许最大消息长度,单位字节
	Append    string            `yaml:"message_addon" json:"-"`
	Prepend   string            `yaml:"message_header" json:"-"`
	Setting   map[string]string `yaml:"setting" json:"-"`
	// contains filtered or unexported fields
}

type Emitter interface {
	Emit(Alert)
}

type Engine struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

type Event struct {
	ID             int64       `json:"id" db:"id"`
	Name           string      `json:"name" db:"name"`
	Fingerprint    string      `json:"fingerprint" db:"fingerprint"`
	Level          types.Level `json:"level" db:"level"`
	Metric         string      `json:"metric" db:"metric"`
	Message        string      `json:"message" db:"message"`
	Notified       int64       `json:"notified" db:"notified"`               // 记录事件累计通知人次
	RecoveryNotice bool        `json:"recovery_notice" db:"recovery_notice"` // 是否发送恢复通知

	ExpireTime  time.Time `json:"expire_time" db:"expire_time"`
	CreatedTime time.Time `json:"created_time" db:"created_time"`
	UpdatedTime time.Time `json:"updated_time" db:"updated_time"`

	Expired           bool   `json:"expired" db:"expired"` // 事件是否过期, 只有 Closed = true 时才为 true, 表示是因过期而关闭, 而不是恢复关闭
	Acked             bool   `json:"acked" db:"acked"`     // 事件是否被认领(确认)
	AckUser           string `json:"ackuser" db:"ackuser"`
	Recovery          bool   `json:"recovery" db:"recovery"` // 事件是否恢复, 只有 Closed = true 时这个值才有意义
	Closed            bool   `json:"closed" db:"closed"`     // 事件是否关闭, 即非活动
	CloseTimeUnixnano int64  `json:"close_time_unixnano" db:"close_time_unixnano"`

	Handlers []Handler `json:"handlers" db:"-"`

	Tags types.StringList `json:"tags" db:"tags"`
	// contains filtered or unexported fields
}

type EventCommand interface {
	Exec(*Event) error
}

type EventSetting func(event *Event)

type GroupProvider interface {
	Groups2Users(types.Set) types.Set
}

type Handler struct {
	ID        int64            `json:"id" db:"id"`
	EventID   int64            `json:"event_id" db:"event_id"`
	Receivers types.StringList `json:"receivers" db:"receivers"` // 接收人
	Channels  types.Chan       `json:"channels" db:"channels"`   // 发送渠道

	Everytime bool `json:"everytime" db:"everytime"` // 每次事件来了都通知, 如果为 true, delay 和 interval 会被忽略.

	Delay    time.Duration `json:"delay" db:"delay"`       // 延迟多久后通知
	Interval time.Duration `json:"interval" db:"interval"` // 到达 delay 的时间后, 每隔 interval 时间, 就通知一次

	CreatedTime time.Time `json:"created_time" db:"created_time"`
	UpdatedTime time.Time `json:"updated_time" db:"updated_time"`
}

type Mute struct {
	ID          int64     `json:"id" db:"id"`
	User        string    `json:"user" db:"user"`
	Name        string    `json:"name" db:"name"`
	Fingerprint string    `json:"fingerprint" db:"fingerprint"`
	Deadline    time.Time `json:"deadline" db:"deadline"`
	Description string    `json:"description" db:"description"`
	CreatedTime time.Time `json:"created_time" db:"created_time"`
	UpdatedTime time.Time `json:"updated_time" db:"updated_time"`
}

type Mutes []Mute

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

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

type Stage interface {
	Handle(Alert) []Alert
}

type StageMute struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

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