influxdbhandler

Documentation

Overview

Package influxdbhandler implements a InfluxDB handler

Index

• Variables
• type Handler
  • func NewHandler(conf HandlerConfig) (*Handler, error)
  • 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
  • func (c HandlerConfig) Validate() error

Variables

var (
	ErrInvalidPrecision = errors.New("invalid precision value")
)

errors

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) Close

func (h *Handler) Close() error

Close closes the handler.

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.