event

Documentation

Index

• Constants
• func Record(name string, detail string)
• func Recordf(name string, format string, args ...interface{})
• func StartDefaultEventStore(stopCh <-chan struct{})
• type Event
• type EventCount
• type EventGroup
  • func Query() []EventGroup
  • func (e *EventGroup) Merge(event Event)
• type EventStore
  • func NewEventStore() *EventStore
  • func (store *EventStore) Query() []EventGroup
  • func (store *EventStore) Record(name string, detail string)
  • func (store *EventStore) Recordf(name string, format string, args ...interface{})
  • func (store *EventStore) Start(stopCh <-chan struct{})

Constants

const (
	MaxMessagesPerEventType int = 5
)

Functions

func Record

func Record(name string, detail string)

func Recordf

func Recordf(name string, format string, args ...interface{})

func StartDefaultEventStore

func StartDefaultEventStore(stopCh <-chan struct{})

Types

type Event

type Event struct {
	Name       string
	Detail     string
	Occurrence time.Time
}

type EventCount

type EventCount struct {
	Key            string    `json:"message"`
	Count          int       `json:"count"`
	LastOccurrence time.Time `json:"last_occurrence"`
}

type EventGroup

type EventGroup struct {
	Name           string       `json:"name"`
	Total          int          `json:"total"`
	Counts         []EventCount `json:"counts"`
	LastOccurrence time.Time    `json:"last_occurrence"`
}

func Query

func Query() []EventGroup

func (*EventGroup) Merge

func (e *EventGroup) Merge(event Event)

type EventStore

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

var DefaultStore *EventStore

func NewEventStore

func NewEventStore() *EventStore

func (*EventStore) Query

func (store *EventStore) Query() []EventGroup

func (*EventStore) Record

func (store *EventStore) Record(name string, detail string)

func (*EventStore) Recordf

func (store *EventStore) Recordf(name string, format string, args ...interface{})

func (*EventStore) Start

func (store *EventStore) Start(stopCh <-chan struct{})