veryroundbird.house
1package db
2
3func (d *DB) SaveLastTimeUs(lastTimeUs int64) error {
4 _, err := d.db.Exec(`insert into _jetstream (last_time_us) values (?)`, lastTimeUs)
5 return err
6}
7
8func (d *DB) UpdateLastTimeUs(lastTimeUs int64) error {
9 _, err := d.db.Exec(`update _jetstream set last_time_us = ? where rowid = 1`, lastTimeUs)
10 if err != nil {
11 return err
12 }
13 return nil
14}
15
16func (d *DB) GetLastTimeUs() (int64, error) {
17 var lastTimeUs int64
18 row := d.db.QueryRow(`select last_time_us from _jetstream`)
19 err := row.Scan(&lastTimeUs)
20 return lastTimeUs, err
21}