notification

Documentation

Index

• type Client
• type Item
• type Queue
  • func NewQueue(client Client, hostId string) *Queue
  • func (q *Queue) Dequeue(ctx context.Context)
  • func (q *Queue) Enqueue(item Item)

Types

type Client

type Client interface {
	PostCheckReports(crs *mackerel.CheckReports) error
}

type Item

type Item struct {
	OccurredAt int64
	Addr       string
	Message    string
	AlertLevel string
}

type Queue

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

func NewQueue

func NewQueue(client Client, hostId string) *Queue

NewQueue is needed mackerel client, host id.

func (*Queue) Dequeue

func (q *Queue) Dequeue(ctx context.Context)

func (*Queue) Enqueue

func (q *Queue) Enqueue(item Item)