store

Jun 13, 2021

Changes in this version

type Store

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

May 30, 2021

Changes in this version

+ var LogRestoreBytes int64 = 100 * 1024 * 1024

May 8, 2021

Changes in this version

+ func CompareRecords(x, y api.Record) bool

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

type Store

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

May 3, 2021

Changes in this version

type Status

+ const STATUS_ABORTED

type Store

+ func (s *Store) Report(r Record)

Apr 25, 2021

Changes in this version

+ func EscapeMessage(s string) string

+ func UnescapeMessage(s string) string

type ProbeHistoryMap

+ func (hs ProbeHistoryMap) Append(r Record)

type Store

+ Console io.Writer

+ IncidentCount int

Apr 17, 2021

Changes in this version

+ const INCIDENT_HISTORY_LEN

+ const LOG_RESTORE_BYTES

+ const PROBE_HISTORY_LEN

+ type Incident struct

+ CausedAt time.Time

+ Message string

+ ResolvedAt time.Time

+ Status Status

+ Target *url.URL

+ func NewIncident(r Record) *Incident

+ func (i *Incident) IsContinued(r Record) bool

+ func (i *Incident) SameTarget(r Record) bool

+ type IncidentHandler func(*Incident) []Record

+ type ProbeHistory struct

+ Records []*Record

+ Target *url.URL

+ type ProbeHistoryMap map[string]*ProbeHistory

+ func (hs ProbeHistoryMap) AsSortedArray() []*ProbeHistory

+ type Record struct

+ CheckedAt time.Time

+ Latency time.Duration

+ Message string

+ Status Status

+ Target *url.URL

+ func ParseRecord(s string) (Record, error)

+ func (r Record) Equals(r2 Record) bool

+ func (r Record) Sanitize() Record

+ func (r Record) String() string

+ type Status int8

+ const STATUS_FAILURE

+ const STATUS_HEALTHY

+ const STATUS_UNKNOWN

+ func ParseStatus(s string) Status

+ func (s Status) String() string

+ type Store struct

+ CurrentIncidents []*Incident

+ IncidentHistory []*Incident

+ OnIncident []IncidentHandler

+ Path string

+ ProbeHistory ProbeHistoryMap

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

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

+ func (s *Store) Append(rs ...Record)

+ func (s *Store) Close() error

+ func (s *Store) Err() error

+ func (s *Store) Restore() error