13 lines
341 B
1
package db
2
3
func (d *DB) SaveLastTimeUs(lastTimeUs int64) error {
4
_, err := d.db.Exec(`update _jetstream set last_time_us = ?`, lastTimeUs)
5
return err
6
}
7
8
func (d *DB) GetLastTimeUs() (int64, error) {
9
var lastTimeUs int64
10
row := d.db.QueryRow(`select last_time_us from _jetstream`)
11
err := row.Scan(&lastTimeUs)
12
return lastTimeUs, err
13
}
14