Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

db

package

Go to main page

Versions in this module

v0

v0.0.17

Nov 3, 2025

v0.0.16

Aug 5, 2025

v0.0.15

Jul 22, 2025

v0.0.14

Apr 23, 2025

v0.0.13

Jan 16, 2025

Changes in this version

type Database

+ func (db *Database) GetAllTaskResultHeaders(runID int) ([]TaskResultHeader, error)

+ func (db *Database) GetTaskResultByIndex(runID, taskID int, resultType string, index int) (*TaskResult, error)

+ func (db *Database) GetTaskResultByName(runID, taskID int, resultType, name string) (*TaskResult, error)

+ func (db *Database) GetTaskResults(runID, taskID int, summaryType string) ([]TaskResult, error)

+ func (db *Database) UpsertTaskResult(tx *sqlx.Tx, result *TaskResult) error

+ type TaskResult struct

+ Data []byte

+ Index int

+ Name string

+ RunID int

+ Size int

+ TaskID int

+ Type string

+ type TaskResultHeader struct

+ Index int

+ Name string

+ Size int

+ TaskID int

+ Type string

v0.0.12

Dec 11, 2024

Changes in this version

+ var EmbedPgsqlSchema embed.FS

+ var EmbedSqliteSchema embed.FS

+ var TaskRunFlagCleanup uint32 = 0x01

+ var TaskRunFlagRunning uint32 = 0x04

+ var TaskRunFlagSkipped uint32 = 0x08

+ var TaskRunFlagStarted uint32 = 0x02

+ var TaskRunFlagTimeout uint32 = 0x10

+ type AssertoorState struct

+ Key string

+ Value string

+ type Database struct

+ func NewDatabase(logger logrus.FieldLogger) *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 struct

+ Engine string

+ Pgsql *PgsqlDatabaseConfig

+ Sqlite *SqliteDatabaseConfig

+ type EngineType int

+ const EngineAny

+ const EnginePgsql

+ const EngineSqlite

+ type PgsqlDatabaseConfig struct

+ Database string

+ Host string

+ MaxIdleConns int

+ MaxOpenConns int

+ Password string

+ Port string

+ Username string

+ type SqliteDatabaseConfig struct

+ File string

+ MaxIdleConns int

+ MaxOpenConns int

+ type TaskLog struct

+ LogFields string

+ LogIndex int

+ LogLevel int

+ LogMessage string

+ LogTime int64

+ RunID int

+ TaskID int

+ type TaskState struct

+ IfCond string

+ Name string

+ ParentTask int

+ RefID string

+ RunFlags uint32

+ RunID int

+ ScopeOwner int

+ StartTime int64

+ StopTime int64

+ TaskConfig string

+ TaskError string

+ TaskID int

+ TaskResult int

+ TaskStatus string

+ Timeout int

+ Title string

+ type TaskStateIndex struct

+ ParentTask int

+ RunFlags uint32

+ TaskID int

+ type TestConfig struct

+ Config string

+ ConfigVars string

+ Name string

+ ScheduleCronYaml string

+ ScheduleStartup bool

+ Source string

+ TestID string

+ Timeout int

+ type TestRun struct

+ Config string

+ Name string

+ RunID int

+ Source string

+ StartTime int64

+ Status string

+ StopTime int64

+ TestID string

+ Timeout int32

+ type TestRunStats struct

+ Count int

+ LastRun uint64

+ TestID string