collator

type Alert ¶

type Alert struct {
	InAlertState         bool
	AverageHitsPerSecond float64
	Time                 time.Time
}

An Alert notifies the listener of high traffic, and also when traffic returns to a normal level

type ByHits ¶

type ByHits []Site

ByHits implements sort.Interface for []SizeHite, based on the number of hits

func (a ByHits) Len() int

func (a ByHits) Less(i, j int) bool

func (a ByHits) Swap(i, j int)

type Collator ¶

type Collator struct {
	ErrorChan  chan error
	SitesChan  chan *Sites
	StatusChan chan *Status
	AlertChan  chan *Alert
	ResetChan  chan bool
	// contains filtered or unexported fields
}

func NewAndRun(ctx context.Context, filename string, alertThreshold int) (*Collator, error)

type Site ¶

type Site struct {
	TotalHits int
	Site      string
}

type Sites ¶

type Sites struct {
	Sites []Site
}

The Sites object lists the # of hits per site, and are sent less often (every 10 seconds)

type Status ¶

type Status struct {
	HitsLastSecond       int
	AverageHitsPerSecond float64
}

These Status objects are sent frequently (one per second)