Jay Brown
79 lines
2.5 KiB
Go
79 lines
2.5 KiB
Go
// Code generated by sqlc. DO NOT EDIT.
|
|
// versions:
|
|
// sqlc v1.27.0
|
|
// source: collector.sql
|
|
|
|
package repository
|
|
|
|
import (
|
|
"context"
|
|
)
|
|
|
|
const addLatestCollectorVersion = `-- name: AddLatestCollectorVersion :one
|
|
INSERT INTO collectorVersions (clientId) VALUES ($1) RETURNING id
|
|
`
|
|
|
|
// AddLatestCollectorVersion
|
|
//
|
|
// INSERT INTO collectorVersions (clientId) VALUES ($1) RETURNING id
|
|
func (q *Queries) AddLatestCollectorVersion(ctx context.Context, clientid string) (int32, error) {
|
|
row := q.db.QueryRow(ctx, addLatestCollectorVersion, clientid)
|
|
var id int32
|
|
err := row.Scan(&id)
|
|
return id, err
|
|
}
|
|
|
|
const getCollectorByClientID = `-- name: GetCollectorByClientID :one
|
|
SELECT clientid, mincleanversion, activeversion, latestversion FROM fullActiveCollectors WHERE clientId = $1 LIMIT 1
|
|
`
|
|
|
|
// GetCollectorByClientID
|
|
//
|
|
// SELECT clientid, mincleanversion, activeversion, latestversion FROM fullActiveCollectors WHERE clientId = $1 LIMIT 1
|
|
func (q *Queries) GetCollectorByClientID(ctx context.Context, clientid string) (*Fullactivecollector, error) {
|
|
row := q.db.QueryRow(ctx, getCollectorByClientID, clientid)
|
|
var i Fullactivecollector
|
|
err := row.Scan(
|
|
&i.Clientid,
|
|
&i.Mincleanversion,
|
|
&i.Activeversion,
|
|
&i.Latestversion,
|
|
)
|
|
return &i, err
|
|
}
|
|
|
|
const setActiveCollectorVersion = `-- name: SetActiveCollectorVersion :exec
|
|
INSERT INTO collectorActiveVersions (clientId, versionId) VALUES ($1, $2)
|
|
`
|
|
|
|
type SetActiveCollectorVersionParams struct {
|
|
Clientid string `db:"clientid"`
|
|
Versionid int32 `db:"versionid"`
|
|
}
|
|
|
|
// SetActiveCollectorVersion
|
|
//
|
|
// INSERT INTO collectorActiveVersions (clientId, versionId) VALUES ($1, $2)
|
|
func (q *Queries) SetActiveCollectorVersion(ctx context.Context, arg *SetActiveCollectorVersionParams) error {
|
|
_, err := q.db.Exec(ctx, setActiveCollectorVersion, arg.Clientid, arg.Versionid)
|
|
return err
|
|
}
|
|
|
|
const setCollectorCleanVersion = `-- name: SetCollectorCleanVersion :exec
|
|
INSERT INTO collectorMinCleanVersions (clientId, addedVersion, versionId) VALUES ($1, $2, $3)
|
|
`
|
|
|
|
type SetCollectorCleanVersionParams struct {
|
|
Clientid string `db:"clientid"`
|
|
Addedversion int32 `db:"addedversion"`
|
|
Versionid int64 `db:"versionid"`
|
|
}
|
|
|
|
// SetCollectorCleanVersion
|
|
//
|
|
// INSERT INTO collectorMinCleanVersions (clientId, addedVersion, versionId) VALUES ($1, $2, $3)
|
|
func (q *Queries) SetCollectorCleanVersion(ctx context.Context, arg *SetCollectorCleanVersionParams) error {
|
|
_, err := q.db.Exec(ctx, setCollectorCleanVersion, arg.Clientid, arg.Addedversion, arg.Versionid)
|
|
return err
|
|
}
|