Help us shape the future of Go! Take the 2026 Go Developer Survey

internal

package
v0.0.6 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 10, 2026 License: MIT Imports: 3 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type CreateSensorParams 

type CreateSensorParams struct {
	Code         string    `json:"code"`
	Label        string    `json:"label"`
	Kind         string    `json:"kind"`
	Unit         string    `json:"unit"`
	Location     *string   `json:"location"`
	Active       int64     `json:"active"`
	Firmware     string    `json:"firmware"`
	SampleRateMs int64     `json:"sample_rate_ms"`
	InstalledAt  time.Time `json:"installed_at"`
	CreatedAt    time.Time `json:"created_at"`
	UpdatedAt    time.Time `json:"updated_at"`
}

type CreateSensorReadingParams added in v0.0.6 

type CreateSensorReadingParams struct {
	SensorID   int64     `json:"sensor_id"`
	Value      float64   `json:"value"`
	Quality    int64     `json:"quality"`
	Flagged    int64     `json:"flagged"`
	RecordedAt time.Time `json:"recorded_at"`
	CreatedAt  time.Time `json:"created_at"`
}

type DBTX 

type DBTX interface {
	ExecContext(context.Context, string, ...interface{}) (sql.Result, error)
	PrepareContext(context.Context, string) (*sql.Stmt, error)
	QueryContext(context.Context, string, ...interface{}) (*sql.Rows, error)
	QueryRowContext(context.Context, string, ...interface{}) *sql.Row
}

type GetSensorReadingStatsParams 

type GetSensorReadingStatsParams struct {
	SensorID int64     `json:"sensor_id"`
	FromTs   time.Time `json:"from_ts"`
	ToTs     time.Time `json:"to_ts"`
}

type GetSensorReadingStatsRow 

type GetSensorReadingStatsRow struct {
	ReadingCount int64       `json:"reading_count"`
	AvgValue     *float64    `json:"avg_value"`
	MinValue     interface{} `json:"min_value"`
	MaxValue     interface{} `json:"max_value"`
}

type ListSensorFilterByLabelKindActiveParams 

type ListSensorFilterByLabelKindActiveParams struct {
	Label  string `json:"label"`
	Kind   string `json:"kind"`
	Active int64  `json:"active"`
	Offset int64  `json:"offset"`
	Limit  int64  `json:"limit"`
}

type ListSensorFilterByLabelKindActiveRow added in v0.0.5 

type ListSensorFilterByLabelKindActiveRow struct {
	ID           int64     `json:"id"`
	Code         string    `json:"code"`
	Label        string    `json:"label"`
	Kind         string    `json:"kind"`
	Unit         string    `json:"unit"`
	Location     *string   `json:"location"`
	Active       int64     `json:"active"`
	Firmware     string    `json:"firmware"`
	SampleRateMs int64     `json:"sample_rate_ms"`
	InstalledAt  time.Time `json:"installed_at"`
	CreatedAt    time.Time `json:"created_at"`
	UpdatedAt    time.Time `json:"updated_at"`
	TotalSize    int64     `json:"total_size"`
}

type ListSensorReadingBySensorIdParams added in v0.0.6 

type ListSensorReadingBySensorIdParams struct {
	SensorID int64 `json:"sensor_id"`
	Offset   int64 `json:"offset"`
	Limit    int64 `json:"limit"`
}

type ListSensorReadingFilterBySensorIdRecordedAtFlaggedParams added in v0.0.6 

type ListSensorReadingFilterBySensorIdRecordedAtFlaggedParams struct {
	SensorID      int64     `json:"sensor_id"`
	MinRecordedAt time.Time `json:"min_recorded_at"`
	MaxRecordedAt time.Time `json:"max_recorded_at"`
	Flagged       int64     `json:"flagged"`
	Offset        int64     `json:"offset"`
	Limit         int64     `json:"limit"`
}

type ListSensorReadingFilterBySensorIdRecordedAtFlaggedRow added in v0.0.6 

type ListSensorReadingFilterBySensorIdRecordedAtFlaggedRow struct {
	ID         int64     `json:"id"`
	SensorID   int64     `json:"sensor_id"`
	Value      float64   `json:"value"`
	Quality    int64     `json:"quality"`
	Flagged    int64     `json:"flagged"`
	RecordedAt time.Time `json:"recorded_at"`
	CreatedAt  time.Time `json:"created_at"`
	TotalSize  int64     `json:"total_size"`
}

type ListSensorsWithLatestReadingParams 

type ListSensorsWithLatestReadingParams struct {
	Offset int64 `json:"offset"`
	Limit  int64 `json:"limit"`
}

type ListSensorsWithLatestReadingRow 

type ListSensorsWithLatestReadingRow struct {
	Sensor           Sensor     `json:"sensor"`
	LatestValue      *float64   `json:"latest_value"`
	LatestRecordedAt *time.Time `json:"latest_recorded_at"`
}

type Queries 

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

func New 

func New(db DBTX) *Queries

func (*Queries) CreateSensor 

func (q *Queries) CreateSensor(ctx context.Context, arg CreateSensorParams) (int64, error)

Code generated by entlite. DO NOT EDIT. SQLC compatible query definitions Sensor CRUD operations

func (*Queries) CreateSensorReading added in v0.0.6 

func (q *Queries) CreateSensorReading(ctx context.Context, arg CreateSensorReadingParams) (int64, error)

SensorReading CRUD operations

func (*Queries) DB 

func (q *Queries) DB() DBTX

DB returns the handle this Queries was constructed with.

func (*Queries) DeleteSensor 

func (q *Queries) DeleteSensor(ctx context.Context, id int64) error

func (*Queries) DeleteSensorReading added in v0.0.6 

func (q *Queries) DeleteSensorReading(ctx context.Context, id int64) error

func (*Queries) GetSensorByCode 

func (q *Queries) GetSensorByCode(ctx context.Context, code string) (Sensor, error)

Look up a sensor by its hardware code

func (*Queries) GetSensorById added in v0.0.6 

func (q *Queries) GetSensorById(ctx context.Context, id int64) (Sensor, error)

func (*Queries) GetSensorReadingById added in v0.0.6 

func (q *Queries) GetSensorReadingById(ctx context.Context, id int64) (SensorReading, error)

func (*Queries) GetSensorReadingStats 

func (q *Queries) GetSensorReadingStats(ctx context.Context, arg GetSensorReadingStatsParams) (GetSensorReadingStatsRow, error)

Hand-written queries the DSL cannot express. entlite never writes this file. The tables are defined in the generated schema.sql. Aggregate value statistics for a single sensor over a time window. >= / <= instead of BETWEEN: sqlc drops the bounds from the params struct unless the range is the first filter.

func (*Queries) ListSensorFilterByLabelKindActive 

func (q *Queries) ListSensorFilterByLabelKindActive(ctx context.Context, arg ListSensorFilterByLabelKindActiveParams) ([]ListSensorFilterByLabelKindActiveRow, error)

func (*Queries) ListSensorReadingBySensorId added in v0.0.6 

func (q *Queries) ListSensorReadingBySensorId(ctx context.Context, arg ListSensorReadingBySensorIdParams) ([]SensorReading, error)

func (*Queries) ListSensorReadingFilterBySensorIdRecordedAtFlagged added in v0.0.6 

func (q *Queries) ListSensorReadingFilterBySensorIdRecordedAtFlagged(ctx context.Context, arg ListSensorReadingFilterBySensorIdRecordedAtFlaggedParams) ([]ListSensorReadingFilterBySensorIdRecordedAtFlaggedRow, error)

func (*Queries) ListSensorsWithLatestReading 

func (q *Queries) ListSensorsWithLatestReading(ctx context.Context, arg ListSensorsWithLatestReadingParams) ([]ListSensorsWithLatestReadingRow, error)

Every active sensor with its most recent reading. LEFT JOIN, so a sensor that never reported comes back with NULL latest values. sqlc.embed(s) maps the joined columns back to the Sensor struct.

func (*Queries) PruneReadingsOlderThan 

func (q *Queries) PruneReadingsOlderThan(ctx context.Context, cutoff time.Time) (int64, error)

Drops readings older than a cutoff.

func (*Queries) UpdateSensor 

func (q *Queries) UpdateSensor(ctx context.Context, arg UpdateSensorParams) (Sensor, error)

func (*Queries) UpdateSensorReading added in v0.0.6 

func (q *Queries) UpdateSensorReading(ctx context.Context, arg UpdateSensorReadingParams) (SensorReading, error)

func (*Queries) WithTx 

func (q *Queries) WithTx(tx *sql.Tx) *Queries

type Sensor 

type Sensor struct {
	ID           int64     `json:"id"`
	Code         string    `json:"code"`
	Label        string    `json:"label"`
	Kind         string    `json:"kind"`
	Unit         string    `json:"unit"`
	Location     *string   `json:"location"`
	Active       int64     `json:"active"`
	Firmware     string    `json:"firmware"`
	SampleRateMs int64     `json:"sample_rate_ms"`
	InstalledAt  time.Time `json:"installed_at"`
	CreatedAt    time.Time `json:"created_at"`
	UpdatedAt    time.Time `json:"updated_at"`
}

type SensorReading added in v0.0.6 

type SensorReading struct {
	ID         int64     `json:"id"`
	SensorID   int64     `json:"sensor_id"`
	Value      float64   `json:"value"`
	Quality    int64     `json:"quality"`
	Flagged    int64     `json:"flagged"`
	RecordedAt time.Time `json:"recorded_at"`
	CreatedAt  time.Time `json:"created_at"`
}

type UpdateSensorParams 

type UpdateSensorParams struct {
	Code         string    `json:"code"`
	Label        string    `json:"label"`
	Kind         string    `json:"kind"`
	Unit         string    `json:"unit"`
	Location     *string   `json:"location"`
	Active       *int64    `json:"active"`
	Firmware     *string   `json:"firmware"`
	SampleRateMs *int64    `json:"sample_rate_ms"`
	UpdatedAt    time.Time `json:"updated_at"`
	ID           int64     `json:"id"`
}

type UpdateSensorReadingParams added in v0.0.6 

type UpdateSensorReadingParams struct {
	SensorID   int64     `json:"sensor_id"`
	Value      float64   `json:"value"`
	Quality    int64     `json:"quality"`
	Flagged    *int64    `json:"flagged"`
	RecordedAt time.Time `json:"recorded_at"`
	ID         int64     `json:"id"`
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.