Something went wrong. Try again.
This repository has no description
Something went wrong. Try again.
Go
123456789101112131415161718package db
func (db *DB) 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 *DB) 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}