mysql

Documentation

Index

• type Backup
  • func (p *Backup) SetBackupEnv(cm *kuberlogicv1.KuberLogicBackupSchedule)
  • func (p *Backup) SetBackupImage(repo, version string)
• type Database
  • func (db *Database) Create(name string) error
  • func (db *Database) Drop(name string) error
  • func (db *Database) IsProtected(name string) bool
  • func (db *Database) List() ([]string, error)
• type InternalDetails
  • func (d *InternalDetails) GetAccessPort() int
  • func (d *InternalDetails) GetCredentialsSecret() (*corev1.Secret, error)
  • func (d *InternalDetails) GetDefaultConnectionPassword() (string, string)
  • func (d *InternalDetails) GetDefaultConnectionUser() string
  • func (d *InternalDetails) GetMainPodContainer() string
  • func (d *InternalDetails) GetMasterService() string
  • func (d *InternalDetails) GetPodMasterSelector() map[string]string
  • func (d *InternalDetails) GetPodReplicaSelector() map[string]string
  • func (d *InternalDetails) GetReplicaService() string
• type Mysql
  • func (p *Mysql) AsClientObject() client.Object
  • func (p *Mysql) AsMetaObject() metav1.Object
  • func (p *Mysql) AsRuntimeObject() runtime.Object
  • func (p *Mysql) GetBackupRestore() interfaces.BackupRestore
  • func (p *Mysql) GetBackupSchedule() interfaces.BackupSchedule
  • func (p *Mysql) GetInternalDetails() interfaces.InternalDetails
  • func (p *Mysql) GetSession(kls *kuberlogicv1.KuberLogicService, client kubernetes.Interface, db string) (interfaces.Session, error)
  • func (p *Mysql) Init(kls *kuberlogicv1.KuberLogicService, plat string)
  • func (p *Mysql) InitFrom(o runtime.Object)
  • func (p *Mysql) IsReady() (bool, string)
  • func (p *Mysql) Name(kls *kuberlogicv1.KuberLogicService) string
  • func (p *Mysql) Update(cm *kuberlogicv1.KuberLogicService) error
• type Restore
  • func (p *Restore) SetRestoreEnv(cm *cloudlinuxv1.KuberLogicBackupRestore)
  • func (p *Restore) SetRestoreImage(repo, version string)
• type Session
  • func NewSession(op interfaces.OperatorInterface, cm *kuberlogicv1.KuberLogicService, ...) (*Session, error)
  • func (session *Session) ConnectionString(host, db string) string
  • func (session *Session) CreateTable(table string) error
  • func (session *Session) GetDatabase() interfaces.Database
  • func (session *Session) GetUser() interfaces.User
  • func (session *Session) SetCredentials(password string) error
• type User
  • func (usr *User) Check(name string) error
  • func (usr *User) Create(name, password string) error
  • func (usr *User) Delete(name string) error
  • func (usr *User) Edit(name, password string) error
  • func (usr *User) IsProtected(name string) bool
  • func (usr *User) List() ([]string, error)

Types

type Backup

type Backup struct {
	base.BaseBackup
	Cluster *Mysql
}

func (*Backup) SetBackupEnv

func (p *Backup) SetBackupEnv(cm *kuberlogicv1.KuberLogicBackupSchedule)

func (*Backup) SetBackupImage

func (p *Backup) SetBackupImage(repo, version string)

type Database

type Database struct {
	// contains filtered or unexported fields
}

func (*Database) Create

func (db *Database) Create(name string) error

func (*Database) Drop

func (db *Database) Drop(name string) error

func (*Database) IsProtected

func (db *Database) IsProtected(name string) bool

func (*Database) List

func (db *Database) List() ([]string, error)

type InternalDetails

type InternalDetails struct {
	Cluster *Mysql
}

func (*InternalDetails) GetAccessPort

func (d *InternalDetails) GetAccessPort() int

func (*InternalDetails) GetCredentialsSecret

func (d *InternalDetails) GetCredentialsSecret() (*corev1.Secret, error)

func (*InternalDetails) GetDefaultConnectionPassword

func (d *InternalDetails) GetDefaultConnectionPassword() (string, string)

func (*InternalDetails) GetDefaultConnectionUser

func (d *InternalDetails) GetDefaultConnectionUser() string

func (*InternalDetails) GetMainPodContainer

func (d *InternalDetails) GetMainPodContainer() string

func (*InternalDetails) GetMasterService

func (d *InternalDetails) GetMasterService() string

func (*InternalDetails) GetPodMasterSelector

func (d *InternalDetails) GetPodMasterSelector() map[string]string

func (*InternalDetails) GetPodReplicaSelector

func (d *InternalDetails) GetPodReplicaSelector() map[string]string

func (*InternalDetails) GetReplicaService

func (d *InternalDetails) GetReplicaService() string

type Mysql

type Mysql struct {
	Operator mysqlv1.MysqlCluster
	// contains filtered or unexported fields
}

func (*Mysql) AsClientObject

func (p *Mysql) AsClientObject() client.Object

func (*Mysql) AsMetaObject

func (p *Mysql) AsMetaObject() metav1.Object

func (*Mysql) AsRuntimeObject

func (p *Mysql) AsRuntimeObject() runtime.Object

func (*Mysql) GetBackupRestore

func (p *Mysql) GetBackupRestore() interfaces.BackupRestore

func (*Mysql) GetBackupSchedule

func (p *Mysql) GetBackupSchedule() interfaces.BackupSchedule

func (*Mysql) GetInternalDetails

func (p *Mysql) GetInternalDetails() interfaces.InternalDetails

func (*Mysql) GetSession

func (p *Mysql) GetSession(kls *kuberlogicv1.KuberLogicService, client kubernetes.Interface, db string) (interfaces.Session, error)

func (*Mysql) Init

func (p *Mysql) Init(kls *kuberlogicv1.KuberLogicService, plat string)

func (*Mysql) InitFrom

func (p *Mysql) InitFrom(o runtime.Object)

func (*Mysql) IsReady

func (p *Mysql) IsReady() (bool, string)

func (*Mysql) Name

func (p *Mysql) Name(kls *kuberlogicv1.KuberLogicService) string

func (*Mysql) Update

func (p *Mysql) Update(cm *kuberlogicv1.KuberLogicService) error

type Restore

type Restore struct {
	base.BaseRestore
	Cluster *Mysql
}

func (*Restore) SetRestoreEnv

func (p *Restore) SetRestoreEnv(cm *cloudlinuxv1.KuberLogicBackupRestore)

func (*Restore) SetRestoreImage

func (p *Restore) SetRestoreImage(repo, version string)

type Session

type Session struct {
	base2.BaseSession
	// contains filtered or unexported fields
}

func NewSession

func NewSession(op interfaces.OperatorInterface, cm *kuberlogicv1.KuberLogicService, client kubernetes.Interface, db string) (*Session, error)

func (*Session) ConnectionString

func (session *Session) ConnectionString(host, db string) string

func (*Session) CreateTable

func (session *Session) CreateTable(table string) error

func (*Session) GetDatabase

func (session *Session) GetDatabase() interfaces.Database

func (*Session) GetUser

func (session *Session) GetUser() interfaces.User

func (*Session) SetCredentials

func (session *Session) SetCredentials(password string) error

type User

type User struct {
	// contains filtered or unexported fields
}

func (*User) Check

func (usr *User) Check(name string) error

func (*User) Create

func (usr *User) Create(name, password string) error

func (*User) Delete

func (usr *User) Delete(name string) error

func (*User) Edit

func (usr *User) Edit(name, password string) error

func (*User) IsProtected

func (usr *User) IsProtected(name string) bool

func (*User) List

func (usr *User) List() ([]string, error)