influx

Documentation

Index

• type Influx
  • func New(connection, dbname, u, p string) Influx
  • func (s *Influx) Close() error
  • func (s *Influx) Connect(timeout time.Duration) error
  • func (s *Influx) Marshal(resp *client.Response) (string, error)
  • func (s *Influx) Query(q string) (*client.Response, error)

Types

type Influx

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

Influx is the wrapper for the influx client connection

func New

func New(connection, dbname, u, p string) Influx

New returns a newly created influxdb object

func (*Influx) Close

func (s *Influx) Close() error

Close connection to influxdb server

func (*Influx) Connect

func (s *Influx) Connect(timeout time.Duration) error

Connect to influxdb server

func (*Influx) Marshal

func (s *Influx) Marshal(resp *client.Response) (string, error)

Marshal Convert client.Respnse to JSON

func (*Influx) Query

func (s *Influx) Query(q string) (*client.Response, error)

Query executes the provided query string and returns the results as a JSON object