database

package
v2.2.1-rc11 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 12, 2021 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func New 

func New() (plugin.Plugin, error)

New New

Types

type CloudConfig 

type CloudConfig struct {
	Database struct {
		Type            string `yaml:"type" json:"type" validate:"nonzero"`
		URL             string `yaml:"url" json:"url" validate:"nonzero"`
		MaxConns        int    `yaml:"maxConns" json:"maxConns" default:20`
		MaxIdleConns    int    `yaml:"maxIdleConns" json:"maxIdleConns" default:5`
		ConnMaxLifetime int    `yaml:"connMaxLifetime" json:"connMaxLifetime" default:150`
	} `yaml:"database" json:"database" default:"{}"`
}

CloudConfig baetyl-cloud config

type DB added in v2.1.1 

type DB struct {
	Log *log.Logger
	// contains filtered or unexported fields
}

DBStorage

func NewDB added in v2.1.1 

func NewDB(cfg CloudConfig) (*DB, error)

func (*DB) AcquireTaskLock added in v2.2.0 

func (d *DB) AcquireTaskLock(task *models.Task) (bool, error)

func (*DB) AcquireTaskLockTx added in v2.2.0 

func (d *DB) AcquireTaskLockTx(tx *sqlx.Tx, task *entities.Task) (sql.Result, error)

func (*DB) BeginTx added in v2.2.0 

func (d *DB) BeginTx() (*sqlx.Tx, error)

func (*DB) Close added in v2.1.1 

func (d *DB) Close() (err error)

Close Close

func (*DB) Commit added in v2.2.0 

func (d *DB) Commit(tx *sqlx.Tx)

func (DB) CountCertByParentId added in v2.1.1 

func (d DB) CountCertByParentId(parentId string) (int, error)

func (*DB) CountProperty added in v2.1.1 

func (d *DB) CountProperty(name string) (int, error)

func (*DB) Create added in v2.1.1 

func (d *DB) Create(tx interface{}, shadow *models.Shadow) (*models.Shadow, error)

func (DB) CreateCert added in v2.1.1 

func (d DB) CreateCert(cert plugin.Cert) error

func (*DB) CreateIndex added in v2.1.1 

func (d *DB) CreateIndex(namespace string, keyA, keyB common.Resource, valueA, valueB string) (sql.Result, error)

func (*DB) CreateIndexTx added in v2.1.1 

func (d *DB) CreateIndexTx(tx *sqlx.Tx, namespace string, keyA, keyB common.Resource, valueA, valueB string) (sql.Result, error)

func (*DB) CreateModule added in v2.2.0 

func (d *DB) CreateModule(module *models.Module) (*models.Module, error)

func (*DB) CreateModuleTx added in v2.2.0 

func (d *DB) CreateModuleTx(tx *sqlx.Tx, module *models.Module) error

func (*DB) CreateProperty added in v2.1.1 

func (d *DB) CreateProperty(property *models.Property) error

func (*DB) CreateShadowTx added in v2.1.1 

func (d *DB) CreateShadowTx(tx *sqlx.Tx, shadow *models.Shadow) (sql.Result, error)

func (*DB) CreateTask added in v2.1.1 

func (d *DB) CreateTask(task *models.Task) (bool, error)

func (*DB) CreateTaskTx added in v2.1.1 

func (d *DB) CreateTaskTx(tx *sqlx.Tx, task *entities.Task) (sql.Result, error)

func (*DB) Delete added in v2.1.1 

func (d *DB) Delete(namespace, name string) error

func (DB) DeleteCert added in v2.1.1 

func (d DB) DeleteCert(certId string) error

func (*DB) DeleteIndex added in v2.1.1 

func (d *DB) DeleteIndex(namespace string, keyA, byKeyB common.Resource, valueB string) (sql.Result, error)

func (*DB) DeleteIndexTx added in v2.1.1 

func (d *DB) DeleteIndexTx(tx *sqlx.Tx, namespace string, keyA, byKeyB common.Resource, valueB string) (sql.Result, error)

func (*DB) DeleteModuleByVersion added in v2.2.0 

func (d *DB) DeleteModuleByVersion(name, version string) error

func (*DB) DeleteModuleByVersionTx added in v2.2.0 

func (d *DB) DeleteModuleByVersionTx(tx *sqlx.Tx, name, version string) error

func (*DB) DeleteModules added in v2.2.0 

func (d *DB) DeleteModules(name string) error

func (*DB) DeleteModulesTx added in v2.2.0 

func (d *DB) DeleteModulesTx(tx *sqlx.Tx, name string) error

func (*DB) DeleteProperty added in v2.1.1 

func (d *DB) DeleteProperty(name string) error

func (*DB) DeleteShadowTx added in v2.1.1 

func (d *DB) DeleteShadowTx(tx *sqlx.Tx, namespace, name string) (sql.Result, error)

func (*DB) DeleteTask added in v2.1.1 

func (d *DB) DeleteTask(taskName string) (bool, error)

func (*DB) DeleteTaskTx added in v2.1.1 

func (d *DB) DeleteTaskTx(tx *sqlx.Tx, name string) (sql.Result, error)

func (*DB) Exec added in v2.1.1 

func (d *DB) Exec(tx *sqlx.Tx, sql string, args ...interface{}) (res sql.Result, err error)

func (*DB) Get added in v2.1.1 

func (d *DB) Get(tx interface{}, namespace, name string) (*models.Shadow, error)

func (DB) GetCert added in v2.1.1 

func (d DB) GetCert(certId string) (*plugin.Cert, error)

func (*DB) GetLatestModule added in v2.2.0 

func (d *DB) GetLatestModule(name string) (*models.Module, error)

func (*DB) GetLatestModuleImage added in v2.2.0 

func (d *DB) GetLatestModuleImage(name string) (string, error)

func (*DB) GetLatestModuleImageTx added in v2.2.0 

func (d *DB) GetLatestModuleImageTx(tx *sqlx.Tx, name string) (string, error)

func (*DB) GetLatestModuleProgram added in v2.2.0 

func (d *DB) GetLatestModuleProgram(name, platform string) (string, error)

func (*DB) GetLatestModuleProgramTx added in v2.2.0 

func (d *DB) GetLatestModuleProgramTx(tx *sqlx.Tx, name, platform string) (string, error)

func (*DB) GetLatestModuleTx added in v2.2.0 

func (d *DB) GetLatestModuleTx(tx *sqlx.Tx, name string) (*models.Module, error)

func (*DB) GetModuleByImage added in v2.2.0 

func (d *DB) GetModuleByImage(name, image string) (*models.Module, error)

func (*DB) GetModuleByImageTx added in v2.2.0 

func (d *DB) GetModuleByImageTx(tx *sqlx.Tx, name, image string) (*models.Module, error)

func (*DB) GetModuleByVersion added in v2.2.0 

func (d *DB) GetModuleByVersion(name, version string) (*models.Module, error)

func (*DB) GetModuleByVersionTx added in v2.2.0 

func (d *DB) GetModuleByVersionTx(tx *sqlx.Tx, name, version string) (*models.Module, error)

func (*DB) GetModuleTx added in v2.2.0 

func (d *DB) GetModuleTx(tx *sqlx.Tx, name string) ([]models.Module, error)

func (*DB) GetModules added in v2.2.0 

func (d *DB) GetModules(name string) ([]models.Module, error)

func (*DB) GetNeedProcessTask added in v2.2.0 

func (d *DB) GetNeedProcessTask(batchNum, expiredSeconds int32) ([]*models.Task, error)

GetNeedProcessTask only support for mysql

func (*DB) GetProperty added in v2.1.1 

func (d *DB) GetProperty(name string) (*models.Property, error)

func (*DB) GetPropertyValue added in v2.1.1 

func (d *DB) GetPropertyValue(name string) (string, error)

func (*DB) GetShadowTx added in v2.1.1 

func (d *DB) GetShadowTx(tx *sqlx.Tx, namespace, name string) (*models.Shadow, error)

func (*DB) GetTask added in v2.1.1 

func (d *DB) GetTask(name string) (*models.Task, error)

func (*DB) GetTaskTx added in v2.1.1 

func (d *DB) GetTaskTx(tx *sqlx.Tx, name string) (*models.Task, error)

func (*DB) List added in v2.1.1 

func (d *DB) List(namespace string, nodeList *models.NodeList) (*models.ShadowList, error)

func (*DB) ListIndex added in v2.1.1 

func (d *DB) ListIndex(namespace string, keyA, byKeyB common.Resource, valueB string) ([]string, error)

func (*DB) ListIndexTx added in v2.1.1 

func (d *DB) ListIndexTx(tx *sqlx.Tx, namespace string, keyA, byKeyB common.Resource, valueB string) ([]string, error)

func (*DB) ListModules added in v2.2.0 

func (d *DB) ListModules(filter *models.Filter) ([]models.Module, error)

func (*DB) ListModulesTx added in v2.2.0 

func (d *DB) ListModulesTx(tx *sqlx.Tx, filter *models.Filter) ([]models.Module, error)

func (*DB) ListOptionalSysModules added in v2.2.0 

func (d *DB) ListOptionalSysModules(filter *models.Filter) ([]models.Module, error)

func (*DB) ListOptionalSysModulesTx added in v2.2.0 

func (d *DB) ListOptionalSysModulesTx(tx *sqlx.Tx, filter *models.Filter) ([]models.Module, error)

func (*DB) ListProperty added in v2.1.1 

func (d *DB) ListProperty(filter *models.Filter) ([]models.Property, error)

func (*DB) ListRuntimeModules added in v2.2.0 

func (d *DB) ListRuntimeModules(filter *models.Filter) ([]models.Module, error)

func (*DB) ListRuntimeModulesTx added in v2.2.0 

func (d *DB) ListRuntimeModulesTx(tx *sqlx.Tx, filter *models.Filter) ([]models.Module, error)

func (*DB) ListShadowByNamesTx added in v2.1.1 

func (d *DB) ListShadowByNamesTx(tx *sqlx.Tx, namespace string, names []string) ([]entities.Shadow, error)

func (*DB) Query added in v2.1.1 

func (d *DB) Query(tx *sqlx.Tx, sql string, data interface{}, args ...interface{}) (err error)

func (*DB) RefreshIndex added in v2.1.1 

func (d *DB) RefreshIndex(tx interface{}, namespace string, keyA, keyB common.Resource, valueA string, valueBs []string) error

func (*DB) Rollback added in v2.2.0 

func (d *DB) Rollback(tx *sqlx.Tx)

func (*DB) Transact added in v2.1.1 

func (d *DB) Transact(handler func(*sqlx.Tx) error) (err error)

func (DB) UpdateCert added in v2.1.1 

func (d DB) UpdateCert(cert plugin.Cert) error

func (*DB) UpdateDesire added in v2.1.1 

func (d *DB) UpdateDesire(tx interface{}, shadow *models.Shadow) (*models.Shadow, error)

func (*DB) UpdateModuleByVersion added in v2.2.0 

func (d *DB) UpdateModuleByVersion(module *models.Module) (*models.Module, error)

func (*DB) UpdateModuleByVersionTx added in v2.2.0 

func (d *DB) UpdateModuleByVersionTx(tx *sqlx.Tx, module *models.Module) error

func (*DB) UpdateProperty added in v2.1.1 

func (d *DB) UpdateProperty(property *models.Property) error

func (*DB) UpdateReport added in v2.1.1 

func (d *DB) UpdateReport(shadow *models.Shadow) (*models.Shadow, error)

func (*DB) UpdateShadowDesireTx added in v2.1.1 

func (d *DB) UpdateShadowDesireTx(tx *sqlx.Tx, shadow *models.Shadow) (sql.Result, error)

func (*DB) UpdateShadowReportTx added in v2.1.1 

func (d *DB) UpdateShadowReportTx(tx *sqlx.Tx, shadow *models.Shadow) (sql.Result, error)

func (*DB) UpdateTask added in v2.1.1 

func (d *DB) UpdateTask(task *models.Task) (bool, error)

func (*DB) UpdateTaskTx added in v2.1.1 

func (d *DB) UpdateTaskTx(tx *sqlx.Tx, task *entities.Task) (sql.Result, error)

type DBStorage added in v2.1.1 

type DBStorage interface {
	Transact(func(*sqlx.Tx) error) error
	Exec(tx *sqlx.Tx, sql string, args ...interface{}) (sql.Result, error)
	Query(tx *sqlx.Tx, sql string, data interface{}, args ...interface{}) error
	BeginTx() (*sqlx.Tx, error)
	Commit(tx *sqlx.Tx)
	Rollback(tx *sqlx.Tx)

	io.Closer
}

DBStorage

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.