arabolt

Documentation

Overview

Package arabolt provides an implementation of an aranet4 database, backed by bbolt.

Index

• type DB
  • func Open(fname string) (*DB, error)
  • func (db *DB) AddDevice(id string) error
  • func (db *DB) Close() error
  • func (db *DB) Data(id string, beg, end time.Time) iter.Seq2[aranet4.Data, error]
  • func (db *DB) Devices() ([]string, error)
  • func (db *DB) Last(id string) (aranet4.Data, error)
  • func (db *DB) PutData(id string, vs []aranet4.Data) error

Types

type DB

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

func Open

func Open(fname string) (*DB, error)

Open opens and initializes a boltdb-backed aranet4 database.

func (*DB) AddDevice

func (db *DB) AddDevice(id string) error

AddDevice declares a new device id

func (*DB) Close

func (db *DB) Close() error

Close closes an aranet4 database

func (*DB) Data

func (db *DB) Data(id string, beg, end time.Time) iter.Seq2[aranet4.Data, error]

Data iterates over data for the device id and the requested time interval [beg, end)

func (*DB) Devices

func (db *DB) Devices() ([]string, error)

Devices returns the device ids list

func (*DB) Last

func (db *DB) Last(id string) (aranet4.Data, error)

Last returns the last data point for the provided device id

func (*DB) PutData

func (db *DB) PutData(id string, vs []aranet4.Data) error

PutData puts the provided data for the device id into the underlying store