package
0.0.11
Repository: https://github.com/ppacer/core.git
Documentation: pkg.go.dev

# Functions

CleanUpSqliteTmp deletes SQLite database source file if all tests in the scope passed.
Produces new Client using in-memory SQLite database with schema created based on given script.
Produces new Client based on given connection to PostgreSQL database.
Produces new Client for logs based on given connection to PostgreSQL database.
Produces new Client based on given connection string to SQLite database.
Produces new Client for logs based on given connection string to SQLite database.
Produces new Client based on SQLite in-memory database.
Produces new Client using SQLite database created as temp file.
Produces new Client for logs using SQLite database created as temp file.
SchemaStatements returns a list of SQL statements that setups new instance of scheduler internal database.
Like SchemaStatements but for database for logs.

# Constants

No description provided by the author
Name for environment variable for setting ppacer default logger severity level.

# Variables

TableNames is a list of ppacer database table names.

# Structs

Client represents the main database client.
No description provided by the author
DagRun represent a row of data in dagruns table.
DagRunRestart represents a row in dagrunrestarts table.
No description provided by the author
No description provided by the author
DagRunWithTaskInfo contains information about a DAG run and additionally information about that DAG tasks.
DagTask represents single row in dagtasks table in the database.
LogsClient represents ppacer task logs database client.
PostgresDB represents Client for PostgreSQL database.
Schedule represents a row in schedules table.
No description provided by the author
SQLite database where data is stored in the memory rather than in a file on a disk.
LogRecord represents single row in tasklogs table.

# Interfaces

DB defines a set of operations required from a database.
DBClient defines abstraction class for database clients.
Scannable interface is mainly to define parsers both for *sql.Row and *sql.Rows types.