telemetry

type AdafruitIO struct {
	Enable bool   `json:"enable"`
	Token  string `json:"token"`
	User   string `json:"user"`
	Prefix string `json:"prefix"`
}

type AlertStats struct {
	Count        int       `json:"count"`
	FirstTrigger time.Time `json:"first_trigger"`
}

type ErrorLogger func(string, string) error

type Factory func(ctx context.Context, name string, arg ...string) Runner

type HealthChecker interface {
	Check()
	Start()
	Stop()
	GetStats(http.ResponseWriter, *http.Request)
}

type HealthMetric struct {
	Load5      float64  `json:"cpu"`
	UsedMemory float64  `json:"memory"`
	Time       TeleTime `json:"time"`

	UnderVoltage float64 `json:"throttle"`
	// contains filtered or unexported fields
}

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

type MQTTConfig struct {
	Enable   bool   `json:"enable"`
	Server   string `json:"server"`
	Username string `json:"username"`
	ClientID string `json:"client_id"`
	Password string `json:"password"`
	QoS      int    `json:"qos"`
	Retained bool   `json:"retained"`
	Prefix   string `json:"prefix"`
}

type Mailer interface {
	Email(subject, body string) error
}

type MailerConfig struct {
	Server   string   `json:"server"`
	Port     int      `json:"port"`
	From     string   `json:"from"`
	Username string   `json:"username"`
	Password string   `json:"password"`
	To       []string `json:"to"`
}

type MailerCustomizer func(m *mailer)

type Metric interface {
	Rollup(Metric) (Metric, bool)
	Before(Metric) bool
}

type NoopMailer struct{}

type Runner func() ([]byte, error)

type Stats struct {
	Current    *ring.Ring
	Historical *ring.Ring
}

type StatsManager interface {
	Get(string) (StatsResponse, error)
	IsLoaded(string) bool
	Initialize(string) error
	Load(string, func(json.RawMessage) interface{}) error
	Save(string) error
	Update(string, Metric)
	Delete(string) error
}

type StatsOnDisk struct {
	Current    []json.RawMessage `json:"current"`
	Historical []json.RawMessage `json:"historical"`
}

type StatsResponse struct {
	Current    []Metric `json:"current"`
	Historical []Metric `json:"historical"`
}

type TeleTime time.Time

type Telemetry interface {
	Alert(string, string) (bool, error)
	Mail(string, string) (bool, error)
	EmitMetric(string, string, float64)
	CreateFeedIfNotExist(string)
	DeleteFeedIfExist(string)
	NewStatsManager(string) StatsManager
	SendTestMessage(http.ResponseWriter, *http.Request)
	GetConfig(http.ResponseWriter, *http.Request)
	UpdateConfig(http.ResponseWriter, *http.Request)
	LogError(string, string) error
}

type TelemetryConfig struct {
	AdafruitIO      AdafruitIO   `json:"adafruitio"`
	MQTT            MQTTConfig   `json:"mqtt"`
	Mailer          MailerConfig `json:"mailer"`
	Notify          bool         `json:"notify"`
	Prometheus      bool         `json:"prometheus"`
	Throttle        int          `json:"throttle"`
	HistoricalLimit int          `json:"historical_limit"`
	CurrentLimit    int          `json:"current_limit"`
}

type ThrottleType uint64