db

Documentation

Index

• func ConnectSqlite(file string, debug bool) (*bun.DB, error)
• type InfluxDB
  • func ConnectInfluxDB(url, org, bucket, token string) (*InfluxDB, error)
  • func (i *InfluxDB) Bucket() string
  • func (i *InfluxDB) QueryAPI() api.QueryAPI
  • func (i *InfluxDB) WriteAPI() api.WriteAPI
  • func (i *InfluxDB) WriteAPIBlocking() api.WriteAPIBlocking
  • func (i *InfluxDB) Writer(batchSize int) *Writer
• type Writer
  • func (w *Writer) CurrentBatch() []*write.Point
  • func (w *Writer) Flush(ctx context.Context) error
  • func (w *Writer) Write(ctx context.Context, p *write.Point) error

Functions

func ConnectSqlite

func ConnectSqlite(file string, debug bool) (*bun.DB, error)

Types

type InfluxDB

type InfluxDB struct {
	influxdb2.Client
	// contains filtered or unexported fields
}

func ConnectInfluxDB

func ConnectInfluxDB(url, org, bucket, token string) (*InfluxDB, error)

func (*InfluxDB) Bucket

func (i *InfluxDB) Bucket() string

func (*InfluxDB) QueryAPI

func (i *InfluxDB) QueryAPI() api.QueryAPI

func (*InfluxDB) WriteAPI

func (i *InfluxDB) WriteAPI() api.WriteAPI

func (*InfluxDB) WriteAPIBlocking

func (i *InfluxDB) WriteAPIBlocking() api.WriteAPIBlocking

func (*InfluxDB) Writer

func (i *InfluxDB) Writer(batchSize int) *Writer

type Writer

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

func (*Writer) CurrentBatch

func (w *Writer) CurrentBatch() []*write.Point

func (*Writer) Flush

func (w *Writer) Flush(ctx context.Context) error

func (*Writer) Write

func (w *Writer) Write(ctx context.Context, p *write.Point) error