db

Documentation

Index

• Variables
• func DeleteAllRowsFromTable(db *sql.DB, table string) (sql.Result, error)
• func NewConnection(dbConfigFile, env string) (*sql.DB, error)

Variables

var AddAgentTag = `` /* 145-byte string literal not displayed */

var CheckConnection = "SELECT 1"

var CleanPkiCertificatesQuery = `DELETE FROM certificates WHERE not_after < NOW()`

var CollectLogPartsQuery = "SELECT array_to_string(array_agg(log_parts.content ORDER BY number, job_id), '') AS content FROM log_parts WHERE job_id=$1"

var CountAgentsQuery = "SELECT count(*) FROM agents %s %s"

var CountAllJobsQuery = "SELECT count(*) FROM jobs %s %s"

var DeleteAgentQuery = `DELETE FROM agents WHERE agent_id=$1`

var DeleteAgentTagQuery = `` /* 138-byte string literal not displayed */

var DeleteJobsOldQuery = `
	DELETE FROM jobs
	WHERE id IN
	(
		SELECT DISTINCT id
		FROM jobs
		WHERE (updated_at <= NOW() - INTERVAL '1 day' * $1)
	)
`

var DeleteLocksQuery = `` /* 141-byte string literal not displayed */

var DeleteLogPartsQuery = `DELETE FROM log_parts WHERE job_id=$1`

var DeletePkiTokensQuery = `DELETE FROM tokens WHERE created_at < NOW() - INTERVAL '1 second' * $1`

pki

var DeleteQuery = "DELETE FROM "

Global

var FailJobsNonHeartbeatQuery = `` /* 168-byte string literal not displayed */

var FailJobsTimeoutQuery = `` /* 214-byte string literal not displayed */

var GetAgentQuery = `` /* 194-byte string literal not displayed */

var GetAgentsQuery = `` /* 217-byte string literal not displayed */

Agents

var GetAllJobsQuery = "SELECT * FROM jobs %s order by created_at DESC %s"

var GetJobQuery = "SELECT * FROM jobs WHERE id=$1"

var GetLockQuery = "SELECT * FROM locks WHERE lock_id=$1"

Locks

var GetLogPartQuery = `SELECT * FROM log_parts WHERE job_id=$1 AND number=$2`

Log parts

var GetLogPartsToAggregateQuery = `` /* 167-byte string literal not displayed */

var GetLogQuery = "SELECT * FROM logs WHERE job_id=$1"

Log

var GetTokenQuery = `SELECT profile, subject FROM tokens WHERE id=$1 AND created_at > NOW() - INTERVAL '1 hour' FOR UPDATE`

var InsertAgentQuery = `` /* 160-byte string literal not displayed */

var InsertCertificateQuery = `` /* 176-byte string literal not displayed */

var InsertJobQuery = `` /* 178-byte string literal not displayed */

Jobs

var InsertLockQuery = `INSERT INTO locks(lock_id,agent_id,created_at) VALUES($1,$2,$3) returning lock_id`

var InsertLogPartQuery = `INSERT INTO log_parts(job_id,number,content,final,created_at) VALUES($1,$2,$3,$4,$5) returning job_id;`

var InsertLogQuery = "INSERT INTO logs(job_id,content,created_at,updated_at) VALUES($1,$2,$3,$4) returning job_id"

var InsertTokenQuery = `INSERT INTO tokens (id, profile, subject) VALUES($1, $2, $3)`

var InsertTokenWithCreatedAtQuery = `INSERT INTO tokens (id, profile, subject,created_at) VALUES($1, $2, $3, $4)`

var UpdateAgentWithRegistration = `` /* 208-byte string literal not displayed */

var UpdateJobQuery = `UPDATE jobs SET status=GREATEST(status, $1), updated_at=$2 WHERE id=$3`

Only allow increasing the status value This means a job status can not decrease e.g. don't go from executing -> pending, failed/complete -> executing

Functions

func DeleteAllRowsFromTable

func DeleteAllRowsFromTable(db *sql.DB, table string) (sql.Result, error)

func NewConnection

func NewConnection(dbConfigFile, env string) (*sql.DB, error)