Versions in this module Expand all Collapse all v3 v3.35.0 Mar 30, 2023 Changes in this version + func DropDatabase(trans Transactor) error + func EnvOr(envName, defaultVal string) string + func GetTestConfig() *controller.SQLDBConfig + func GetTestConfigRandomDB(dbprefix string) *controller.SQLDBConfig + func NewBalancer(log logger.Logger) *balancer.Balancer + func NewDirectiveVersion(log logger.Logger) dax.DirectiveVersion + func NewFreeJobService(log logger.Logger) balancer.FreeJobService + func NewFreeWorkerService(log logger.Logger) balancer.FreeWorkerService + func NewNodeService(log logger.Logger) *nodeService + func NewSchemar(log logger.Logger) schemar.Schemar + func NewWorkerJobService(log logger.Logger) balancer.WorkerJobService + type DaxTransaction struct + C *pop.Connection + func (w *DaxTransaction) Commit() error + func (w *DaxTransaction) Context() context.Context + func (w *DaxTransaction) Rollback() error + type EmbedMigrator struct + FS fs.FS + func NewEmbedMigrator(fs fs.FS, c *pop.Connection, log logger.Logger) (*EmbedMigrator, error) + type Schemar struct + func (s *Schemar) CreateDatabase(tx dax.Transaction, qdb *dax.QualifiedDatabase) error + func (s *Schemar) CreateField(tx dax.Transaction, qtid dax.QualifiedTableID, field *dax.Field) error + func (s *Schemar) CreateTable(tx dax.Transaction, qtbl *dax.QualifiedTable) error + func (s *Schemar) DatabaseByID(tx dax.Transaction, qdb dax.QualifiedDatabaseID) (*dax.QualifiedDatabase, error) + func (s *Schemar) DatabaseByName(tx dax.Transaction, orgID dax.OrganizationID, dbname dax.DatabaseName) (*dax.QualifiedDatabase, error) + func (s *Schemar) Databases(tx dax.Transaction, orgID dax.OrganizationID, dbIDs ...dax.DatabaseID) ([]*dax.QualifiedDatabase, error) + func (s *Schemar) DropDatabase(tx dax.Transaction, qdb dax.QualifiedDatabaseID) error + func (s *Schemar) DropField(tx dax.Transaction, qtid dax.QualifiedTableID, fieldName dax.FieldName) error + func (s *Schemar) DropTable(tx dax.Transaction, qtid dax.QualifiedTableID) error + func (s *Schemar) SetDatabaseOption(tx dax.Transaction, qdbid dax.QualifiedDatabaseID, option string, value string) error + func (s *Schemar) Table(tx dax.Transaction, qtid dax.QualifiedTableID) (*dax.QualifiedTable, error) + func (s *Schemar) TableID(tx dax.Transaction, qdbid dax.QualifiedDatabaseID, tableName dax.TableName) (dax.QualifiedTableID, error) + func (s *Schemar) Tables(tx dax.Transaction, qdbid dax.QualifiedDatabaseID, tableIDs ...dax.TableID) ([]*dax.QualifiedTable, error) + type Transactor struct + func NewTransactor(cfg *controller.SQLDBConfig, log logger.Logger) (Transactor, error) + func (t Transactor) BeginTx(ctx context.Context, writable bool) (dax.Transaction, error) + func (t Transactor) Close() error + func (t Transactor) Start() error