21 lines
546 B
1
package db
2
3
func (d *DB) SaveLastTimeUs(lastTimeUs int64) error {
4
_, err := d.db.Exec(`insert into _jetstream (last_time_us) values (?)`, lastTimeUs)
5
return err
6
}
7
8
func (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
16
func (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
}
22