db

Documentation

Index

• Constants
• Variables
• func DurationToMilliseconds(d time.Duration) int64
• func JulianDayToTime(d float64) time.Time
• func JulianDayToTimestamp(f float64) *timestamppb.Timestamp
• func JulianNow() float64
• func MigrationsFromFS(migrationsFS embed.FS, migrationsDir string) ([]string, error)
• func MillisecondsToDuration(ms int64) time.Duration
• func StmtBytes(stmt *sqlite.Stmt, colName string) []byte
• func StmtBytesByCol(stmt *sqlite.Stmt, col int) []byte
• func StmtJulianToTime(stmt *sqlite.Stmt, colName string) time.Time
• func StmtJulianToTimestamp(stmt *sqlite.Stmt, colName string) *timestamppb.Timestamp
• func TimeToJulianDay(t time.Time) float64
• func TimestampJulian(ts *timestamppb.Timestamp) float64
• type Database
  • func NewDatabase(ctx context.Context, opts ...DatabaseOption) (*Database, error)
  • func (db *Database) Close() error
  • func (db *Database) Path() string
  • func (db *Database) ReadTX(ctx context.Context, fn TxFn) (err error)
  • func (db *Database) Reset(ctx context.Context, shouldClear bool) (err error)
  • func (db *Database) WriteTX(ctx context.Context, fn TxFn) (err error)
  • func (db *Database) WriteWithoutTx(ctx context.Context, fn TxFn) error
• type DatabaseOption
  • func DatabaseWithFilename(filename string) DatabaseOption
  • func DatabaseWithMigrations(migrations []string) DatabaseOption
  • func DatabaseWithPragmas(pragmas ...string) DatabaseOption
  • func DatabaseWithShouldClear(shouldClear bool) DatabaseOption
• type TxFn

Constants

const (
	UnixEpochJulianDay = 2440587.5
)

Variables

var (
	JulianZeroTime = JulianDayToTime(0)
)

Functions

func DurationToMilliseconds

func DurationToMilliseconds(d time.Duration) int64

func JulianDayToTime

func JulianDayToTime(d float64) time.Time

JulianDayToTime converts a Julian day into a time.Time.

func JulianDayToTimestamp

func JulianDayToTimestamp(f float64) *timestamppb.Timestamp

func JulianNow

func JulianNow() float64

func MigrationsFromFS

func MigrationsFromFS(migrationsFS embed.FS, migrationsDir string) ([]string, error)

func MillisecondsToDuration

func MillisecondsToDuration(ms int64) time.Duration

func StmtBytes

func StmtBytes(stmt *sqlite.Stmt, colName string) []byte

func StmtBytesByCol

func StmtBytesByCol(stmt *sqlite.Stmt, col int) []byte

func StmtJulianToTime

func StmtJulianToTime(stmt *sqlite.Stmt, colName string) time.Time

func StmtJulianToTimestamp

func StmtJulianToTimestamp(stmt *sqlite.Stmt, colName string) *timestamppb.Timestamp

func TimeToJulianDay

func TimeToJulianDay(t time.Time) float64

TimeToJulianDay converts a time.Time into a Julian day.

func TimestampJulian

func TimestampJulian(ts *timestamppb.Timestamp) float64

Types

type Database

type Database struct {
	// contains filtered or unexported fields
}

func NewDatabase

func NewDatabase(ctx context.Context, opts ...DatabaseOption) (*Database, error)

func (*Database) Close

func (db *Database) Close() error

func (*Database) Path

func (db *Database) Path() string

func (*Database) ReadTX

func (db *Database) ReadTX(ctx context.Context, fn TxFn) (err error)

func (*Database) Reset

func (db *Database) Reset(ctx context.Context, shouldClear bool) (err error)

func (*Database) WriteTX

func (db *Database) WriteTX(ctx context.Context, fn TxFn) (err error)

func (*Database) WriteWithoutTx

func (db *Database) WriteWithoutTx(ctx context.Context, fn TxFn) error

type DatabaseOption

type DatabaseOption func(*databaseOptions)

func DatabaseWithFilename

func DatabaseWithFilename(filename string) DatabaseOption

func DatabaseWithMigrations

func DatabaseWithMigrations(migrations []string) DatabaseOption

func DatabaseWithPragmas

func DatabaseWithPragmas(pragmas ...string) DatabaseOption

func DatabaseWithShouldClear

func DatabaseWithShouldClear(shouldClear bool) DatabaseOption

type TxFn

type TxFn func(tx *sqlite.Conn) error