influx

Documentation

Index

• Variables
• type InfluxConn
  • func InitInflux(endpoint string, token string) *InfluxConn
  • func (ic *InfluxConn) Close()
  • func (ic *InfluxConn) GetPM100S(ctx context.Context) (float64, error)
  • func (ic *InfluxConn) GetPM25S(ctx context.Context) (float64, error)

Variables

var (
	ErrCouldNotQueryInflux       = fmt.Errorf("could not query influx")
	ErrCouldNotParseInfluxResult = fmt.Errorf("could not parse influx result")
	ErrUnknownQueryError         = fmt.Errorf("unknown query error")
	ErrUnknownError              = fmt.Errorf("unknown error")
)

Types

type InfluxConn

type InfluxConn struct {
	Conn        influxdb2.Client
	QueryClient api.QueryAPI
}

func InitInflux

func InitInflux(endpoint string, token string) *InfluxConn

func (*InfluxConn) Close

func (ic *InfluxConn) Close()

func (*InfluxConn) GetPM100S

func (ic *InfluxConn) GetPM100S(ctx context.Context) (float64, error)

func (*InfluxConn) GetPM25S

func (ic *InfluxConn) GetPM25S(ctx context.Context) (float64, error)