Versions in this module Expand all Collapse all v0 v0.1.2 Feb 26, 2020 v0.1.0 Feb 25, 2020 Changes in this version + const AppID + const InvalidOid + var ClientName string + var ConfigDb *sqlx.DB + var DbName string = "timetable" + var Host string = "localhost" + var Password string = "somestrong" + var Port string = "5432" + var SSLMode string = "disable" + var Upgrade bool + var User string = "scheduler" + var VerboseLogLevel = true + func CanProceedChainExecution(chainConfigID int, maxInstances int) bool + func CheckNeedMigrateDb() + func DeleteChainConfig(chainConfigID int) bool + func ExecuteSQLCommand(tx *sqlx.Tx, script string, paramValues []string) error + func FinalizeConfigDBConnection() + func FinalizeRemoteDBConnection(remoteDb *sqlx.DB) + func FixSchedulerCrash() + func GetChainElements(tx *sqlx.Tx, chains interface{}, chainID int) bool + func GetChainParamValues(tx *sqlx.Tx, paramValues interface{}, chainElemExec *ChainElementExecution) bool + func GetConnectionString(databaseConnection sql.NullString) (connectionString string) + func GetLogPrefix(level string) string + func GetLogPrefixLn(level string) string + func GetRemoteDBTransaction(connectionString string) (*sqlx.DB, *sqlx.Tx) + func InitAndTestConfigDBConnection() + func InsertChainRunStatus(tx *sqlx.Tx, chainConfigID int, chainID int) int + func LogChainElementExecution(chainElemExec *ChainElementExecution, retCode int) + func LogToDB(level string, msg ...interface{}) + func MigrateDb() + func MustCommitTransaction(tx *sqlx.Tx) + func MustRollbackTransaction(tx *sqlx.Tx) + func ReconnectDbAndFixLeftovers() + func ResetRole(tx *sqlx.Tx) + func SetRole(tx *sqlx.Tx, runUID sql.NullString) + func SetupCloseHandler() + func StartTransaction() *sqlx.Tx + func TryLockClientName() (res bool) + func UpdateChainRunStatus(chainElemExec *ChainElementExecution, runStatusID int, status string) + type ChainElementExecution struct + ChainConfig int + ChainID int + ConnectString sql.NullString + DatabaseConnection sql.NullString + Duration int64 + IgnoreError bool + Kind string + RunUID sql.NullString + Script string + StartedAt time.Time + TaskID int + TaskName string + func (chainElem ChainElementExecution) String() string