Something went wrong. Try again.
This repository has no description
Something went wrong. Try again.
493 B · 21 lines
Go
at master
12345678910111213141516171819202122package db
type DbWrapper struct { Execer}
func (db DbWrapper) SaveLastTimeUs(lastTimeUs int64) error { _, err := db.Exec(` insert into _jetstream (id, last_time_us) values (1, ?) on conflict(id) do update set last_time_us = excluded.last_time_us `, lastTimeUs) return err}
func (db DbWrapper) GetLastTimeUs() (int64, error) { var lastTimeUs int64 row := db.QueryRow(`select last_time_us from _jetstream where id = 1;`) err := row.Scan(&lastTimeUs) return lastTimeUs, err}