Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DebugLogger ¶
type DebugLogger struct {
}
func (DebugLogger) Printf ¶
func (DebugLogger) Printf(format string, v ...interface{})
func (DebugLogger) Println ¶
func (DebugLogger) Println(v ...interface{})
type ServiceMQTT ¶
type ServiceMQTT struct {
Server string
Topics []string
QoS int
ClientID string
Username string
Password string
SSLCA string // Path to CA file
SSLCert string // Path to host cert file
SSLKey string // Path to cert key file
RetryMin int
RetryRatio float64
RetryMax int
CleanSession bool
OrderMatters bool
ClientIDAutoInc bool
KeepAlive int
Version int // 3 - MQTT 3.1 or 4 - MQTT 3.1.1
// contains filtered or unexported fields
}
ServiceMQTT ...
func (*ServiceMQTT) Collect ¶
func (p *ServiceMQTT) Collect(pipeline.Collector) error
Collect takes in an accumulator and adds the metrics that the Input gathers. This is called every "interval"
func (*ServiceMQTT) Description ¶
func (p *ServiceMQTT) Description() string
func (*ServiceMQTT) Start ¶
func (p *ServiceMQTT) Start(c pipeline.Collector) error
Start starts the ServiceInput's service, whatever that may be
func (*ServiceMQTT) Stop ¶
func (p *ServiceMQTT) Stop() error
Stop stops the services and closes any necessary channels and connections
Source Files
Click to show internal directories.
Click to hide internal directories.