ht

Documentation

Index

• type Collector
  • func NewCollector(ctx context.Context, messageChan <-chan mqtt.Message, opts Options) *Collector
  • func (c *Collector) Collect(ch chan<- prometheus.Metric)
  • func (c *Collector) Describe(ch chan<- *prometheus.Desc)
• type Info
• type Options

Types

type Collector

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

func NewCollector

func NewCollector(ctx context.Context, messageChan <-chan mqtt.Message, opts Options) *Collector

func (*Collector) Collect

func (c *Collector) Collect(ch chan<- prometheus.Metric)

func (*Collector) Describe

func (c *Collector) Describe(ch chan<- *prometheus.Desc)

type Info

type Info struct {
	Mac     string `json:"mac"`
	IsValid bool   `json:"is_valid"`
	Tmp     struct {
		Value   float64 `json:"value"`
		Units   string  `json:"units"`
		TC      float64 `json:"tC"`
		TF      float64 `json:"tF"`
		IsValid bool    `json:"is_valid"`
	} `json:"tmp"`
	Hum struct {
		Value   float64 `json:"value"`
		IsValid bool    `json:"is_valid"`
	} `json:"hum"`
	Bat struct {
		Value   int     `json:"value"`
		Voltage float64 `json:"voltage"`
	} `json:"bat"`
}

Info represents the minimal data. If you want more, let me know.

type Options

type Options struct {
	Timeout time.Duration
	Log     *zap.Logger
}