alice.pds.demo.boltless.dev
This repository has no description
351 B
13 lines
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) 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}