store

Documentation

Index

• Constants
• func EscapeMessage(s string) string
• func UnescapeMessage(s string) string
• type Incident
  • func NewIncident(r Record) *Incident
  • func (i *Incident) IsContinued(r Record) bool
  • func (i *Incident) SameTarget(r Record) bool
• type IncidentHandler
• type ProbeHistory
• type ProbeHistoryMap
  • func (hs ProbeHistoryMap) Append(r Record)
• type Record
  • 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
  • func ParseStatus(s string) Status
  • func (s Status) String() string
• type Store
  • func New(path string) (*Store, error)
  • func (s *Store) AddTarget(target *url.URL)
  • func (s *Store) Close() error
  • func (s *Store) CurrentIncidents() []*Incident
  • func (s *Store) Err() error
  • func (s *Store) IncidentHistory() []*Incident
  • func (s *Store) ProbeHistory() []*ProbeHistory
  • func (s *Store) Report(r Record)
  • func (s *Store) Restore() error

Constants

const (
	PROBE_HISTORY_LEN    = 40
	INCIDENT_HISTORY_LEN = 10
	LOG_RESTORE_BYTES    = 1024 * 1024
)

Functions

func EscapeMessage

func EscapeMessage(s string) string

func UnescapeMessage

func UnescapeMessage(s string) string

Types

type Incident

type Incident struct {
	Target     *url.URL
	Status     Status
	Message    string
	CausedAt   time.Time
	ResolvedAt time.Time
}

func NewIncident

func NewIncident(r Record) *Incident

func (*Incident) IsContinued

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

func (*Incident) SameTarget

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

type IncidentHandler

type IncidentHandler func(*Incident)

type ProbeHistory

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

type ProbeHistoryMap

type ProbeHistoryMap map[string]*ProbeHistory

func (ProbeHistoryMap) Append

func (hs ProbeHistoryMap) Append(r Record)

type Record

type Record struct {
	CheckedAt time.Time
	Target    *url.URL
	Status    Status
	Message   string
	Latency   time.Duration
}

func ParseRecord

func ParseRecord(s string) (Record, error)

func (Record) Equals

func (r Record) Equals(r2 Record) bool

func (Record) Sanitize

func (r Record) Sanitize() Record

func (Record) String

func (r Record) String() string

type Status

type Status int8

const (
	STATUS_UNKNOWN Status = iota
	STATUS_HEALTHY
	STATUS_FAILURE
	STATUS_ABORTED
)

func ParseStatus

func ParseStatus(s string) Status

func (Status) String

func (s Status) String() string

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() []*Incident

func (*Store) Err

func (s *Store) Err() error

func (*Store) IncidentHistory

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

func (*Store) ProbeHistory

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

func (*Store) Report

func (s *Store) Report(r Record)

func (*Store) Restore

func (s *Store) Restore() error