Documentation
¶
Index ¶
- Variables
- type AssertoorState
- type Database
- func (db *Database) ApplySchema(version int64) error
- func (db *Database) CleanupUncleanTestRuns(tx *sqlx.Tx) error
- func (db *Database) CloseDB() error
- func (db *Database) DeleteTestConfig(tx *sqlx.Tx, testID string) error
- func (db *Database) DeleteTestRun(tx *sqlx.Tx, runID int) error
- func (db *Database) EngineQuery(queryMap map[EngineType]string) string
- func (db *Database) GetAssertoorState(key string, returnValue interface{}) (interface{}, error)
- func (db *Database) GetLastLogIndex(runID, taskID int) (int, error)
- func (db *Database) GetTaskLogs(runID, taskID, fromIdx, limit int) ([]*TaskLog, error)
- func (db *Database) GetTaskStateByTaskID(runID, taskID int) (*TaskState, error)
- func (db *Database) GetTaskStateIndex(runID int) ([]*TaskStateIndex, error)
- func (db *Database) GetTestConfigs() ([]*TestConfig, error)
- func (db *Database) GetTestRunByRunID(runID int) (*TestRun, error)
- func (db *Database) GetTestRunRange(testID string, firstRunID, offset, limit int) ([]*TestRun, int, error)
- func (db *Database) GetTestRunStats() ([]*TestRunStats, error)
- func (db *Database) InitDB(config *DatabaseConfig) error
- func (db *Database) InsertTaskLog(tx *sqlx.Tx, log *TaskLog) error
- func (db *Database) InsertTaskState(tx *sqlx.Tx, state *TaskState) error
- func (db *Database) InsertTestConfig(tx *sqlx.Tx, config *TestConfig) error
- func (db *Database) InsertTestRun(tx *sqlx.Tx, run *TestRun) error
- func (db *Database) RunTransaction(handler func(tx *sqlx.Tx) error) error
- func (db *Database) SetAssertoorState(tx *sqlx.Tx, key string, value interface{}) error
- func (db *Database) UpdateTaskStateStatus(tx *sqlx.Tx, state *TaskState, updateFields []string) error
- func (db *Database) UpdateTestRunStatus(tx *sqlx.Tx, run *TestRun) error
- type DatabaseConfig
- type EngineType
- type PgsqlDatabaseConfig
- type SqliteDatabaseConfig
- type TaskLog
- type TaskState
- type TaskStateIndex
- type TestConfig
- type TestRun
- type TestRunStats
Constants ¶
This section is empty.
Variables ¶
var ( TaskRunFlagCleanup uint32 = 0x01 TaskRunFlagStarted uint32 = 0x02 TaskRunFlagRunning uint32 = 0x04 TaskRunFlagSkipped uint32 = 0x08 TaskRunFlagTimeout uint32 = 0x10 )
var EmbedPgsqlSchema embed.FS
var EmbedSqliteSchema embed.FS
Functions ¶
This section is empty.
Types ¶
type AssertoorState ¶
type Database ¶
type Database struct {
// contains filtered or unexported fields
}
func NewDatabase ¶
func NewDatabase(logger logrus.FieldLogger) *Database
func (*Database) ApplySchema ¶
func (*Database) CleanupUncleanTestRuns ¶
CleanupUncleanTestRuns updates all running test runs and its tasks to aborted
func (*Database) DeleteTestConfig ¶
DeleteTestConfig deletes a test config from the database.
func (*Database) DeleteTestRun ¶
DeleteTestRun deletes a test run and all associated task states and logs.
func (*Database) EngineQuery ¶
func (db *Database) EngineQuery(queryMap map[EngineType]string) string
func (*Database) GetAssertoorState ¶
func (*Database) GetLastLogIndex ¶
func (*Database) GetTaskLogs ¶
func (*Database) GetTaskStateByTaskID ¶
GetTaskStateByTaskID returns a task state by task ID.
func (*Database) GetTaskStateIndex ¶
func (db *Database) GetTaskStateIndex(runID int) ([]*TaskStateIndex, error)
GetTaskStateIndex returns the task index for a given test run.
func (*Database) GetTestConfigs ¶
func (db *Database) GetTestConfigs() ([]*TestConfig, error)
GetTestConfigs returns all test configs.
func (*Database) GetTestRunByRunID ¶
GetTestRunByRunID returns a test run by run ID.
func (*Database) GetTestRunRange ¶
func (db *Database) GetTestRunRange(testID string, firstRunID, offset, limit int) ([]*TestRun, int, error)
GetTestRunRange returns a range of test runs.
func (*Database) GetTestRunStats ¶
func (db *Database) GetTestRunStats() ([]*TestRunStats, error)
GetTestRunStats returns the test run stats for all tests.
func (*Database) InitDB ¶
func (db *Database) InitDB(config *DatabaseConfig) error
func (*Database) InsertTaskState ¶
InsertTaskState inserts a task state into the database.
func (*Database) InsertTestConfig ¶
func (db *Database) InsertTestConfig(tx *sqlx.Tx, config *TestConfig) error
InsertTestConfig inserts a test config into the database.
func (*Database) InsertTestRun ¶
InsertTestRun inserts a test run into the database.
func (*Database) RunTransaction ¶
func (*Database) SetAssertoorState ¶
type DatabaseConfig ¶
type DatabaseConfig struct {
Engine string `yaml:"engine"`
Sqlite *SqliteDatabaseConfig `yaml:"sqlite"`
Pgsql *PgsqlDatabaseConfig `yaml:"pgsql"`
}
type EngineType ¶
type EngineType int
const ( EngineAny EngineType = 0 EngineSqlite EngineType = 1 EnginePgsql EngineType = 2 )
type PgsqlDatabaseConfig ¶
type SqliteDatabaseConfig ¶
type TaskState ¶
type TaskState struct {
RunID int `db:"run_id"`
TaskID int `db:"task_id"`
ParentTask int `db:"parent_task"`
Name string `db:"name"`
Title string `db:"title"`
RefID string `db:"ref_id"`
Timeout int `db:"timeout"`
IfCond string `db:"ifcond"`
RunFlags uint32 `db:"run_flags"`
StartTime int64 `db:"start_time"`
StopTime int64 `db:"stop_time"`
ScopeOwner int `db:"scope_owner"`
TaskConfig string `db:"task_config"`
TaskStatus string `db:"task_status"`
TaskResult int `db:"task_result"`
TaskError string `db:"task_error"`
}