pagerduty

Documentation

Index

• Constants
• type Event
  • func NewEvent(routingKey, owner string, meta *scheduler.Event) Event
• type Notifier
  • func NewNotifier(ctx context.Context, eventBatchInterval time.Duration, errHandler func(error), ...) *Notifier
  • func (s *Notifier) Close() error
  • func (s *Notifier) Notify(_ context.Context, attr scheduler.NotifyAttrs) error
  • func (s *Notifier) Worker(ctx context.Context)
• type PagerDutyService
• type PagerDutyServiceImpl
  • func (*PagerDutyServiceImpl) SendAlert(ctx context.Context, evt Event) error

Constants

const (
	DefaultEventBatchInterval = time.Second * 10
)

Types

type Event

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

func NewEvent

func NewEvent(routingKey, owner string, meta *scheduler.Event) Event

type Notifier

type Notifier struct {
	io.Closer
	// contains filtered or unexported fields
}

func NewNotifier

func NewNotifier(ctx context.Context, eventBatchInterval time.Duration, errHandler func(error), pdService PagerDutyService) *Notifier

func (*Notifier) Close

func (s *Notifier) Close() error

func (*Notifier) Notify

func (s *Notifier) Notify(_ context.Context, attr scheduler.NotifyAttrs) error

func (*Notifier) Worker

func (s *Notifier) Worker(ctx context.Context)

type PagerDutyService

type PagerDutyService interface {
	SendAlert(context.Context, Event) error
}

type PagerDutyServiceImpl

type PagerDutyServiceImpl struct{}

func (*PagerDutyServiceImpl) SendAlert

func (*PagerDutyServiceImpl) SendAlert(ctx context.Context, evt Event) error