notifier

Documentation

Index

• Constants
• type Alert
• type AlertManager
  • func NewAlertManager(addr string, distribution bool) *AlertManager
  • func (a *AlertManager) Send(ctx context.Context, b []byte, alertName string) error
• type Limiter
• type NotifyManager
  • func NewManager(done chan interface{}, amAddr string, isDistribution bool) *NotifyManager
  • func (m *NotifyManager) Consume() []*Alert
  • func (m *NotifyManager) Run()
  • func (m *NotifyManager) Send(alerts ...*Alert)

Constants

const MaxNumPerBatch = 64

Types

type Alert

type Alert struct {
	Name         string            `json:"name"`
	Labels       map[string]string `json:"labels"`
	Annotations  map[string]string `json:"annotations"`
	StartsAt     time.Time         `json:"startsAt,omitempty"`
	EndsAt       time.Time         `json:"endsAt,omitempty"`
	GeneratorURL string            `json:"generatorURL,omitempty"`
}

type AlertManager

type AlertManager struct {
	Endpoint string
	// contains filtered or unexported fields
}

func NewAlertManager

func NewAlertManager(addr string, distribution bool) *AlertManager

func (*AlertManager) Send

func (a *AlertManager) Send(ctx context.Context, b []byte, alertName string) error

type Limiter

type Limiter interface {
	//Allow() bool
	//AllowN(now time.Time, n int) bool
	Wait(ctx context.Context) error
}

type NotifyManager

type NotifyManager struct {
	QueueCapacity int
	// contains filtered or unexported fields
}

func NewManager

func NewManager(done chan interface{}, amAddr string, isDistribution bool) *NotifyManager

func (*NotifyManager) Consume

func (m *NotifyManager) Consume() []*Alert

func (*NotifyManager) Run

func (m *NotifyManager) Run()

func (*NotifyManager) Send

func (m *NotifyManager) Send(alerts ...*Alert)