database

package
v0.0.0-...-c1be4bf Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 2, 2025 License: MIT Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ChangeFilterParams

type ChangeFilterParams struct {
	ChangedAt time.Time
	RemindAt  time.Time
}

type CreateEventParams

type CreateEventParams struct {
	EventType int32
	EventData json.RawMessage
}

type DBTX

type DBTX interface {
	ExecContext(context.Context, string, ...interface{}) (sql.Result, error)
	PrepareContext(context.Context, string) (*sql.Stmt, error)
	QueryContext(context.Context, string, ...interface{}) (*sql.Rows, error)
	QueryRowContext(context.Context, string, ...interface{}) *sql.Row
}

type Event

type Event struct {
	ID        uuid.UUID
	CreatedAt time.Time
	UpdatedAt time.Time
	EventType int32
	EventData json.RawMessage
}

type Filter

type Filter struct {
	ID        uuid.UUID
	CreatedAt time.Time
	UpdatedAt time.Time
	ChangedAt time.Time
	RemindAt  time.Time
}

type GetEventsByTypeParams

type GetEventsByTypeParams struct {
	EventType int32
	Limit     int32
}

type Leak

type Leak struct {
	ID         uuid.UUID
	CreatedAt  time.Time
	UpdatedAt  time.Time
	DetectedAt time.Time
	ClearedAt  sql.NullTime
}

type Ozone

type Ozone struct {
	ID               uuid.UUID
	CreatedAt        time.Time
	UpdatedAt        time.Time
	StartTime        sql.NullTime
	EndTime          sql.NullTime
	Running          bool
	ExpectedDuration int32
	StatusMessage    sql.NullString
}

type Plunge

type Plunge struct {
	ID               uuid.UUID
	CreatedAt        time.Time
	UpdatedAt        time.Time
	StartTime        sql.NullTime
	StartWaterTemp   string
	StartRoomTemp    string
	EndTime          sql.NullTime
	EndWaterTemp     string
	EndRoomTemp      string
	Running          bool
	ExpectedDuration int32
	AvgWaterTemp     string
	AvgRoomTemp      string
}

type Queries

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

func New

func New(db DBTX) *Queries

func (*Queries) ChangeFilter

func (q *Queries) ChangeFilter(ctx context.Context, arg ChangeFilterParams) (Filter, error)

func (*Queries) ClearDetectedLeak

func (q *Queries) ClearDetectedLeak(ctx context.Context, id uuid.UUID) (Leak, error)

func (*Queries) CreateEvent

func (q *Queries) CreateEvent(ctx context.Context, arg CreateEventParams) (Event, error)

func (*Queries) CreateLeakDetected

func (q *Queries) CreateLeakDetected(ctx context.Context, detectedAt time.Time) (Leak, error)

func (*Queries) CreateUser

func (q *Queries) CreateUser(ctx context.Context, email string) (User, error)

func (*Queries) FindMostRecentTemperatures

func (q *Queries) FindMostRecentTemperatures(ctx context.Context) (Temperature, error)

func (*Queries) GetEventsByType

func (q *Queries) GetEventsByType(ctx context.Context, arg GetEventsByTypeParams) ([]Event, error)

func (*Queries) GetFilter

func (q *Queries) GetFilter(ctx context.Context, id uuid.UUID) (Filter, error)

func (*Queries) GetFilters

func (q *Queries) GetFilters(ctx context.Context) ([]Filter, error)

func (*Queries) GetLatestEventByType

func (q *Queries) GetLatestEventByType(ctx context.Context, eventType int32) (Event, error)

func (*Queries) GetLatestFilterChange

func (q *Queries) GetLatestFilterChange(ctx context.Context) (Filter, error)

func (*Queries) GetLatestLeakDetected

func (q *Queries) GetLatestLeakDetected(ctx context.Context) (Leak, error)

func (*Queries) GetLatestOzoneEntry

func (q *Queries) GetLatestOzoneEntry(ctx context.Context) (Ozone, error)

func (*Queries) GetLatestPlunge

func (q *Queries) GetLatestPlunge(ctx context.Context) (Plunge, error)

func (*Queries) GetPlungeByID

func (q *Queries) GetPlungeByID(ctx context.Context, id uuid.UUID) (Plunge, error)

func (*Queries) GetPlunges

func (q *Queries) GetPlunges(ctx context.Context) ([]Plunge, error)

func (*Queries) GetUserByApiKey

func (q *Queries) GetUserByApiKey(ctx context.Context, apiKey string) (User, error)

func (*Queries) SaveTemperature

func (q *Queries) SaveTemperature(ctx context.Context, arg SaveTemperatureParams) (Temperature, error)

func (*Queries) StartOzoneGenerator

func (q *Queries) StartOzoneGenerator(ctx context.Context, arg StartOzoneGeneratorParams) (Ozone, error)

func (*Queries) StartPlunge

func (q *Queries) StartPlunge(ctx context.Context, arg StartPlungeParams) (Plunge, error)

func (*Queries) StopOzoneGenerator

func (q *Queries) StopOzoneGenerator(ctx context.Context, id uuid.UUID) (Ozone, error)

func (*Queries) StopPlunge

func (q *Queries) StopPlunge(ctx context.Context, arg StopPlungeParams) (Plunge, error)

func (*Queries) UpdateOzoneEntryStatus

func (q *Queries) UpdateOzoneEntryStatus(ctx context.Context, arg UpdateOzoneEntryStatusParams) (Ozone, error)

func (*Queries) UpdatePlungeAvgTemp

func (q *Queries) UpdatePlungeAvgTemp(ctx context.Context, arg UpdatePlungeAvgTempParams) (Plunge, error)

func (*Queries) WithTx

func (q *Queries) WithTx(tx *sql.Tx) *Queries

type SaveTemperatureParams

type SaveTemperatureParams struct {
	WaterTemp sql.NullString
	RoomTemp  sql.NullString
}

type StartOzoneGeneratorParams

type StartOzoneGeneratorParams struct {
	StartTime        sql.NullTime
	ExpectedDuration int32
}

type StartPlungeParams

type StartPlungeParams struct {
	StartTime        sql.NullTime
	StartWaterTemp   string
	StartRoomTemp    string
	ExpectedDuration int32
}

type StopPlungeParams

type StopPlungeParams struct {
	EndTime      sql.NullTime
	EndWaterTemp string
	EndRoomTemp  string
	ID           uuid.UUID
}

type Temperature

type Temperature struct {
	ID        uuid.UUID
	CreatedAt time.Time
	UpdatedAt time.Time
	WaterTemp sql.NullString
	RoomTemp  sql.NullString
}

type UpdateOzoneEntryStatusParams

type UpdateOzoneEntryStatusParams struct {
	StatusMessage sql.NullString
	ID            uuid.UUID
}

type UpdatePlungeAvgTempParams

type UpdatePlungeAvgTempParams struct {
	AvgWaterTemp string
	AvgRoomTemp  string
	ID           uuid.UUID
}

type User

type User struct {
	ID        uuid.UUID
	Email     string
	CreatedAt time.Time
	UpdatedAt time.Time
	ApiKey    string
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL