alert

Documentation

Index

• type Alert
  • func NewAlert(hb healthcheck.Healthcheck) *Alert
  • func (alert *Alert) IsFailed() bool
  • func (alert *Alert) MarkFailed(failureTime time.Time, failureReason string)
  • func (alert *Alert) MarkSucceed(successTime time.Time)
• type Alerts
  • func (alerts Alerts) Len() int
  • func (alerts Alerts) Less(i, j int) bool
  • func (alerts Alerts) Swap(i, j int)
• type Event
• type EventType
• type Manager
  • func NewManager(globalConf *healthcheck.GlobalConfig, sche *scheduler.Scheduler, ...) *Manager
  • func (m *Manager) GetAlerts() Alerts
  • func (m *Manager) Run(ctx context.Context) <-chan interface{}
• type Provider
  • func (s Provider) Daemon(ctx context.Context, app infra.Resolver)
  • func (s Provider) Register(cc infra.Binder)

Types

type Alert

type Alert struct {
	healthcheck.Event
}

func NewAlert

func NewAlert(hb healthcheck.Healthcheck) *Alert

func (*Alert) IsFailed

func (alert *Alert) IsFailed() bool

func (*Alert) MarkFailed

func (alert *Alert) MarkFailed(failureTime time.Time, failureReason string)

func (*Alert) MarkSucceed

func (alert *Alert) MarkSucceed(successTime time.Time)

type Alerts

type Alerts []Alert

func (Alerts) Len

func (alerts Alerts) Len() int

func (Alerts) Less

func (alerts Alerts) Less(i, j int) bool

func (Alerts) Swap

func (alerts Alerts) Swap(i, j int)

type Event

type Event struct {
	Type  EventType `json:"type,omitempty"`
	Alert Alert     `json:"alert,omitempty"`
}

type EventType

type EventType string

const (
	EventTypeSuccess EventType = "success"
	EventTypeFail    EventType = "fail"
)

type Manager

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

func NewManager

func NewManager(globalConf *healthcheck.GlobalConfig, sche *scheduler.Scheduler, queueSize int64) *Manager

func (*Manager) GetAlerts

func (m *Manager) GetAlerts() Alerts

func (*Manager) Run

func (m *Manager) Run(ctx context.Context) <-chan interface{}

type Provider

type Provider struct{}

func (Provider) Daemon

func (s Provider) Daemon(ctx context.Context, app infra.Resolver)

func (Provider) Register

func (s Provider) Register(cc infra.Binder)