timescale

Documentation

Index

• type Timescale
  • func New(url string, timeout time.Duration) (*Timescale, error)
  • func (t *Timescale) BenchmarkRead(queries int)
  • func (t *Timescale) BenchmarkWrite(dataPoints, sensorsAmount float32)
  • func (t *Timescale) Close()
  • func (t *Timescale) WritePoints(dataPoints int, sensorID int)

Types

type Timescale

type Timescale struct {
	Conn    *pgx.Conn
	Timeout time.Duration
}

Timescale struct to manage the database connection and settings

func New

func New(url string, timeout time.Duration) (*Timescale, error)

New initializes a new TimescaleDB connection

func (*Timescale) BenchmarkRead

func (t *Timescale) BenchmarkRead(queries int)

BenchmarkRead executes multiple queries to benchmark the read speed.

func (*Timescale) BenchmarkWrite

func (t *Timescale) BenchmarkWrite(dataPoints, sensorsAmount float32)

BenchmarkWrite inserts data into the TimescaleDB using multiple goroutines.

func (*Timescale) Close

func (t *Timescale) Close()

Close closes the TimescaleDB connection.

func (*Timescale) WritePoints

func (t *Timescale) WritePoints(dataPoints int, sensorID int)

WritePoints inserts multiple data points for a given sensor.