Function generateInvalidQueueQuery

validator_test.go:192–203

(queueName string)

}

func generateInvalidQueueQuery(queueName string) string {
	quotedTableName := pg.QuoteIdentifier(queueName)
	return fmt.Sprintf(`	CREATE TABLE IF NOT EXISTS %[1]s
	(
		id            UUID        DEFAULT gen_random_uuid() NOT NULL PRIMARY KEY,
		created_at     TIMESTAMPTZ DEFAULT CURRENT_TIMESTAMP NOT NULL,
		started_at     TIMESTAMPTZ                           NULL,
		description    TEXT  								 NULL,
		name		   TEXT 								 NULL
	);
	`, quotedTableName, quotedTableName[1:len(quotedTableName)-1])
}

func generateCreateTableQuery(queueName string) string {
	quotedTableName := pg.QuoteIdentifier(queueName)