mysql

Documentation

Index

• func NewClient(host, port, dbName string, secretRef taxonomy.SecretRef, client kclient.Client) (*sql.DB, error)
• type MySQLImpl
  • func NewMySQLImpl() *MySQLImpl
  • func (impl *MySQLImpl) AllocateStorage(request *storagemanager.AllocateStorageRequest, client kclient.Client) (taxonomy.Connection, error)
  • func (impl *MySQLImpl) DeleteStorage(request *storagemanager.DeleteStorageRequest, client kclient.Client) error
  • func (impl *MySQLImpl) GetConnectionType() taxonomy.ConnectionType

Functions

func NewClient

func NewClient(host, port, dbName string, secretRef taxonomy.SecretRef, client kclient.Client) (*sql.DB, error)

returns a connection to MySQL

Types

type MySQLImpl

type MySQLImpl struct {
	Name taxonomy.ConnectionType
	Log  zerolog.Logger
}

Storage manager implementation for MySQL

func NewMySQLImpl

func NewMySQLImpl() *MySQLImpl

implementation of AgentInterface for MySQL

func (*MySQLImpl) AllocateStorage

func (impl *MySQLImpl) AllocateStorage(request *storagemanager.AllocateStorageRequest, client kclient.Client) (taxonomy.Connection, error)

storage allocation host, port are taken from the storage account database name is generated, table is taken from the DatasetProperties.Name TODO: allow database and table specification inside FybrikApplication

func (*MySQLImpl) DeleteStorage

func (impl *MySQLImpl) DeleteStorage(request *storagemanager.DeleteStorageRequest, client kclient.Client) error

storage deletion

func (*MySQLImpl) GetConnectionType

func (impl *MySQLImpl) GetConnectionType() taxonomy.ConnectionType

return the supported connection type