database

Documentation

Index

• type Database
• type TimescaleDB
  • func New(databaseURL string) *TimescaleDB
  • func (d *TimescaleDB) Add(m *types.Measurement) error
  • func (d *TimescaleDB) Connect() error
  • func (d *TimescaleDB) GetCrossings(since time.Duration) (crossings []*types.Crossing, err error)
  • func (d *TimescaleDB) GetLines(since time.Duration) (lines []*types.Line, err error)
  • func (d *TimescaleDB) GetPositions(since time.Duration) (positions []*types.Position, err error)

Types

type Database

type Database interface {
	Connect() error
	Add(m *types.Measurement) error
	GetPositions(since time.Duration) ([]*types.Position, error)
	GetLines(since time.Duration) ([]*types.Line, error)
	GetCrossings(since time.Duration) ([]*types.Crossing, error)
}

type TimescaleDB

type TimescaleDB struct {
	Host         string
	Port         uint16
	Username     string
	Password     string
	DatabaseName string
	// contains filtered or unexported fields
}

func New

func New(databaseURL string) *TimescaleDB

func (*TimescaleDB) Add

func (d *TimescaleDB) Add(m *types.Measurement) error

func (*TimescaleDB) Connect

func (d *TimescaleDB) Connect() error

func (*TimescaleDB) GetCrossings

func (d *TimescaleDB) GetCrossings(since time.Duration) (crossings []*types.Crossing, err error)

func (*TimescaleDB) GetLines

func (d *TimescaleDB) GetLines(since time.Duration) (lines []*types.Line, err error)

func (*TimescaleDB) GetPositions

func (d *TimescaleDB) GetPositions(since time.Duration) (positions []*types.Position, err error)