Documentation
¶
Overview ¶
Package influxdbhandler implements a InfluxDB handler
Index ¶
- Variables
- type Handler
- func (h *Handler) Close() error
- func (h *Handler) SendACKNotification(pl handler.ACKNotification) error
- func (h *Handler) SendDataUp(pl handler.DataUpPayload) error
- func (h *Handler) SendErrorNotification(pl handler.ErrorNotification) error
- func (h *Handler) SendJoinNotification(pl handler.JoinNotification) error
- func (h *Handler) SendLocationNotification(pl handler.LocationNotification) error
- func (h *Handler) SendStatusNotification(pl handler.StatusNotification) error
- type HandlerConfig
Constants ¶
This section is empty.
Variables ¶
View Source
var (
ErrInvalidPrecision = errors.New("invalid precision value")
)
errors
Functions ¶
This section is empty.
Types ¶
type Handler ¶
type Handler struct {
// contains filtered or unexported fields
}
Handler implements an InfluxDB handler for writing received sensor-data into an InfluxDB database.
func NewHandler ¶
func NewHandler(conf HandlerConfig) (*Handler, error)
NewHandler creates a new InfluxDBHandler.
func (*Handler) SendACKNotification ¶
func (h *Handler) SendACKNotification(pl handler.ACKNotification) error
SendACKNotification is not implemented.
func (*Handler) SendDataUp ¶
func (h *Handler) SendDataUp(pl handler.DataUpPayload) error
SendDataUp stores the uplink data into InfluxDB.
func (*Handler) SendErrorNotification ¶
func (h *Handler) SendErrorNotification(pl handler.ErrorNotification) error
SendErrorNotification is not implemented.
func (*Handler) SendJoinNotification ¶
func (h *Handler) SendJoinNotification(pl handler.JoinNotification) error
SendJoinNotification is not implemented.
func (*Handler) SendLocationNotification ¶
func (h *Handler) SendLocationNotification(pl handler.LocationNotification) error
SendLocationNotification is not implemented.
func (*Handler) SendStatusNotification ¶
func (h *Handler) SendStatusNotification(pl handler.StatusNotification) error
SendStatusNotification writes the device-status.
type HandlerConfig ¶
type HandlerConfig struct {
Endpoint string `json:"endpoint"`
DB string `json:"db"`
Username string `json:"username"`
Password string `json:"password"`
RetentionPolicyName string `json:"retentionPolicyName"`
Precision string `json:"precision"`
}
HandlerConfig contains the configuration for a InfluxDB handler.
func (HandlerConfig) Validate ¶
func (c HandlerConfig) Validate() error
Validate validates the HandlerConfig data.
Source Files
Click to show internal directories.
Click to hide internal directories.