sqldb

package

v4.0.13 Latest Latest Go to latest Published: Oct 9, 2026 License: Apache-2.0 Imports: 15 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/argoproj/argo-workflows

Links

Open Source Insights

Documentation ¶

Index ¶

func ConfigureDBSession(session db.Session, dbPool *config.ConnectionPool) db.Session
func CreateDBSession(ctx context.Context, kubectlConfig kubernetes.Interface, namespace string, ...) (db.Session, error)
func CreateDBSessionWithCreds(dbConfig config.DBConfig, username, password string) (db.Session, error)
func IsSerializationConflict(err error) bool
func Migrate(ctx context.Context, session db.Session, versionTableName string, ...) error
type AnsiSQLChange
- func (s AnsiSQLChange) Apply(ctx context.Context, session db.Session) error
type Change
- func ByType(dbType DBType, changes TypedChanges) Change
type DBType
- func DBTypeFor(session db.Session) DBType
- func (t DBType) IntType() string
type TypedChanges

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func ConfigureDBSession ¶

func ConfigureDBSession(session db.Session, dbPool *config.ConnectionPool) db.Session

ConfigureDBSession configures the DB session

func CreateDBSessionWithCreds ¶

func CreateDBSessionWithCreds(dbConfig config.DBConfig, username, password string) (db.Session, error)

CreateDBSessionWithCreds creates a database session using direct username and password

func IsSerializationConflict ¶ added in v4.0.10

func IsSerializationConflict(err error) bool

IsSerializationConflict reports whether err is a transaction conflict reported by the database driver itself: PostgreSQL serialization_failure (40001) or deadlock_detected (40P01), or MySQL ER_LOCK_DEADLOCK (1213). These are the errors where the database aborted the transaction because of concurrent activity and the whole transaction can safely be retried.

func Migrate ¶

func Migrate(ctx context.Context, session db.Session, versionTableName string, changes []Change) error

Types ¶

type AnsiSQLChange ¶

type AnsiSQLChange string

represent a straight forward change that is compatible with all database providers

func (AnsiSQLChange) Apply ¶

func (s AnsiSQLChange) Apply(ctx context.Context, session db.Session) error

type Change ¶

type Change interface {
	Apply(ctx context.Context, session db.Session) error
}

func ByType ¶

func ByType(dbType DBType, changes TypedChanges) Change

type DBType ¶

type DBType string

const (
	MySQL    DBType = "mysql"
	Postgres DBType = "postgres"
	SQLite   DBType = "sqlite"
)

func DBTypeFor ¶

func DBTypeFor(session db.Session) DBType

func (DBType) IntType ¶

func (t DBType) IntType() string

type TypedChanges ¶

type TypedChanges map[DBType]Change

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL