samples

Nov 1, 2026

Changes in this version

type PartitionJanitor

+ func (j *PartitionJanitor) Tick(ctx context.Context)

Oct 31, 2026

Changes in this version

type Store

+ func (s *Store) DeleteBefore(ctx context.Context, cutoff time.Time) (int64, error)

Oct 25, 2026

Changes in this version

type Factory

+ func NewFactoryWithSystem(d, sys *sql.DB, resolvers *db.VehicleResolverFactory) *Factory

Oct 25, 2026

Changes in this version

+ var ErrBackupUnavailable = errors.New("backup unavailable: the request carries no user for the archive")

Oct 23, 2026

Changes in this version

type DriveCondition

+ Trailer bool

Oct 19, 2026

Changes in this version

+ func ThinCandidates(months []time.Time, thinned map[time.Time]bool, now time.Time, afterDays int) []time.Time

Oct 19, 2026

Changes in this version

type Thinner

+ OnRepair func(partition string, flagged int64)

+ OnRethin func(partition string, uid, vid uuid.UUID, deleted int64)

Oct 19, 2026

Changes in this version

+ type ArchiveRows interface

+ EachRow func(ctx context.Context, uid, vehicleID uuid.UUID, month time.Time, ...) error

+ Objects func(ctx context.Context, uid uuid.UUID) ([]archive.ObjectRef, error)

type Downsampled

+ Truncated bool

type Store

+ func (s *Store) EachAllArchived(ctx context.Context, src ArchiveRows, fn func(Sample) error) (reduced []string, err error)

Oct 19, 2026

Changes in this version

+ const FullKeep

+ const MinRetentionMonths

+ const MinThinAfterDays

+ var ErrNotArchived = errors.New("month not archived: needs a verified archive first")

+ var ErrThinVerify = errors.New("thinned copy failed verification")

+ func ParseRetentionMonths(v string) (int, error)

+ func ParseThinAfterDays(v string) (int, error)

+ func RetentionCutoff(now time.Time, months int) time.Time

+ func ThinCandidate(months []time.Time, thinned map[time.Time]bool, now time.Time, afterDays int) (time.Time, bool)

+ type Retention struct

+ Dropped func(name string, estRows int64)

+ func NewRetention(db *sql.DB, months int) *Retention

+ func (r *Retention) Run(ctx context.Context) (int64, error)

+ type ThinReport struct

+ BytesAfter int64

+ BytesBefore int64

+ DryRun bool

+ Partition string

+ RowsAfter int64

+ RowsBefore int64

+ type Thinner struct

+ DryRun bool

+ Now func() time.Time

+ Report func(r ThinReport)

+ func NewThinner(db *sql.DB, afterDays int) *Thinner

+ func (t *Thinner) Run(ctx context.Context) (int64, error)

Oct 19, 2026

Changes in this version

+ const MaxBatchMonths

+ var ErrSampleOutOfWindow = errors.New("samples: a sample is dated outside the accepted window")

+ var ErrTooManyMonths = errors.New("samples: batch spans too many months")

+ var WindowAhead = 24 * time.Hour

+ var WindowStart = time.Date(2018, 1, 1, 0, 0, 0, 0, time.UTC)

+ func TimeInWindow(t, now time.Time) bool

Oct 18, 2026

Changes in this version

type Store

+ func (s *Store) EachAll(ctx context.Context, fn func(Sample) error) error

Oct 17, 2026

Changes in this version

+ type DriveCondition struct

+ AvgSpeedMph float64

+ CreatedAt time.Time

+ DistanceMi float64

+ DriveMode string

+ EndedAt time.Time

+ EnergyKWh float64

+ ID string

+ OutsideTempC *float64

+ Source string

+ StartedAt time.Time

+ VehicleID string

type Store

+ func (s *Store) DriveConditions(ctx context.Context, vehicleID string, since, until time.Time) ([]DriveCondition, error)

Oct 16, 2026

Changes in this version

type Store

+ func (s *Store) ListBetweenDownsampledVehicle(ctx context.Context, vehicleID string, since, until time.Time, limit int) (Downsampled, error)

+ func (s *Store) ListBetweenVehicle(ctx context.Context, vehicleID string, since, until time.Time, limit int) ([]Sample, error)

Oct 16, 2026

Changes in this version

+ const MaxDownsampleSpan

+ type Downsampled struct

+ Reduced bool

+ Samples []Sample

+ Total int

type Sample

+ ChargerStatus string

type Store

+ func (s *Store) ListBetweenDownsampled(ctx context.Context, since, until time.Time, limit int) (Downsampled, error)

Oct 14, 2026

Changes in this version

type Store

+ func (s *Store) InsertBulk(ctx context.Context, batch []Sample) error

Oct 2, 2026

Changes in this version

type DayActivity

+ FailedSleeps int

+ Sleeps int

Jul 18, 2026

Changes in this version

+ type DayActivity struct

+ AsleepH float64

+ Day time.Time

+ IdleAwakeH float64

type Sample

+ PowerState string

type Store

+ func (s *Store) SleepActivity(ctx context.Context, vehicleID string, since, until time.Time) ([]DayActivity, error)

Jul 10, 2026

Changes in this version

type Sample

+ PackTempAvgC *float64

+ PackTempMaxC *float64

+ PackTempMinC *float64

May 12, 2026

Changes in this version

+ type Factory struct

+ func NewFactory(d *sql.DB, resolvers *db.VehicleResolverFactory) *Factory

+ func (f *Factory) For(userID uuid.UUID) *Store

+ type PartitionJanitor struct

+ func NewPartitionJanitor(db *sql.DB) *PartitionJanitor

+ func (j *PartitionJanitor) EnsureLookahead(ctx context.Context) error

+ func (j *PartitionJanitor) Run(ctx context.Context)

+ type Sample struct

+ AltitudeM *float64

+ At time.Time

+ BatteryLevelPct float64

+ ChargeLimitPct float64

+ ChargeNumber int64

+ ChargerPowerKW float64

+ ChargingState string

+ DriveMode string

+ DriveNumber int64

+ InsideTempC float64

+ Lat float64

+ LocationFixAt *time.Time

+ Lon float64

+ OdometerMi float64

+ OutsideTempC float64

+ RangeMi float64

+ ShiftState string

+ Source string

+ SpeedMph float64

+ TirePressureMinBar *float64

+ VehicleID string

+ type Store struct

+ func OpenStore(d *sql.DB, userID uuid.UUID, v *db.VehicleResolver) (*Store, error)

+ func (s *Store) Close() error

+ func (s *Store) Count(ctx context.Context) (int, error)

+ func (s *Store) InsertBatch(ctx context.Context, batch []Sample) error

+ func (s *Store) ListAll(ctx context.Context) ([]Sample, error)

+ func (s *Store) ListBetween(ctx context.Context, since, until time.Time, limit int) ([]Sample, error)

+ func (s *Store) ListSince(ctx context.Context, since time.Time, limit int) ([]Sample, error)

+ func (s *Store) Reset(ctx context.Context) (int64, error)