Function queueFromInternal

riverdriver/riversqlite/river_sqlite_driver.go:1652–1665

(internal *dbsqlc.RiverQueue)

}

func queueFromInternal(internal *dbsqlc.RiverQueue) *rivertype.Queue {
	var pausedAt *time.Time
	if internal.PausedAt != nil {
		t := internal.PausedAt.UTC()
		pausedAt = &t
	}
	return &rivertype.Queue{
		CreatedAt: internal.CreatedAt.UTC(),
		Metadata:  internal.Metadata,
		Name:      internal.Name,
		PausedAt:  pausedAt,
		UpdatedAt: internal.UpdatedAt.UTC(),
	}
}

func timeString(t time.Time) string {
	// SQLite times are really strings, and may god help your immortal soul if