Monorepo for Tangled
Something went wrong. Try again.
Go
at commit-links
123456789101112131415161718192021package db
import "fmt"
func (d *DB) GetLastTimeUs() (int64, error) { var t int64 if err := d.QueryRow(`select last_time_us from jetstream_cursor where id = 0`).Scan(&t); err != nil { return 0, fmt.Errorf("no saved cursor: %w", err) } return t, nil}
func (d *DB) SaveLastTimeUs(t int64) error { _, err := d.Exec( `insert into jetstream_cursor (id, last_time_us) values (0, ?) on conflict(id) do update set last_time_us = excluded.last_time_us`, t, ) return err}