store

Documentation

Index

• Constants
• Variables
• func CompareRecords(x, y api.Record) bool
• func IncidentIsContinued(i *api.Incident, r api.Record) bool
• func NewIncident(r api.Record) *api.Incident
• type IncidentHandler
• type ProbeHistory
• type ProbeHistoryMap
  • func (hs ProbeHistoryMap) Append(r api.Record)
• type Store
  • func New(path string) (*Store, error)
  • func (s *Store) AddTarget(target *url.URL)
  • func (s *Store) Close() error
  • func (s *Store) CurrentIncidents() []*api.Incident
  • func (s *Store) Err() error
  • func (s *Store) Freeze() freeze.Status
  • func (s *Store) IncidentHistory() []*api.Incident
  • func (s *Store) ProbeHistory() []*ProbeHistory
  • func (s *Store) Report(r api.Record)
  • func (s *Store) ReportInternalError(scope, message string)
  • func (s *Store) Restore() error

Constants

const (
	PROBE_HISTORY_LEN    = 40
	INCIDENT_HISTORY_LEN = 10
)

Variables

var (
	LogRestoreBytes int64 = 100 * 1024 * 1024
)

Functions

func CompareRecords

func CompareRecords(x, y api.Record) bool

func IncidentIsContinued

func IncidentIsContinued(i *api.Incident, r api.Record) bool

func NewIncident

func NewIncident(r api.Record) *api.Incident

Types

type IncidentHandler

type IncidentHandler func(*api.Incident)

type ProbeHistory

type ProbeHistory struct {
	Target  *url.URL
	Records []api.Record
}

type ProbeHistoryMap

type ProbeHistoryMap map[string]*ProbeHistory

func (ProbeHistoryMap) Append

func (hs ProbeHistoryMap) Append(r api.Record)

type Store

type Store struct {
	Path string

	Console io.Writer

	OnIncident    []IncidentHandler
	IncidentCount int
	// contains filtered or unexported fields
}

func New

func New(path string) (*Store, error)

func (*Store) AddTarget

func (s *Store) AddTarget(target *url.URL)

func (*Store) Close

func (s *Store) Close() error

func (*Store) CurrentIncidents

func (s *Store) CurrentIncidents() []*api.Incident

func (*Store) Err

func (s *Store) Err() error

func (*Store) Freeze

func (s *Store) Freeze() freeze.Status

func (*Store) IncidentHistory

func (s *Store) IncidentHistory() []*api.Incident

func (*Store) ProbeHistory

func (s *Store) ProbeHistory() []*ProbeHistory

func (*Store) Report

func (s *Store) Report(r api.Record)

func (*Store) ReportInternalError

func (s *Store) ReportInternalError(scope, message string)

func (*Store) Restore

func (s *Store) Restore() error