mysql

Documentation

Index

• type Config
  • func NewConfig(host string, port int, user, pass, dbname, usersHostname string) *Config
  • func (c *Config) ConnString() (string, error)
  • func (c *Config) UsersHostname() string
• type Mysql
  • func NewMysql(conn connection.Connection, config *Config, logger logr.Logger) *Mysql
  • func (m *Mysql) ApplyPrivileges(ctx context.Context, username string, privileges []v1alpha1.PrivilegeSpec) error
  • func (m *Mysql) Close(ctx context.Context) error
  • func (m *Mysql) Connect(ctx context.Context) error
  • func (m *Mysql) CreateUser(ctx context.Context, username, password string) (map[string]string, error)
  • func (m *Mysql) DeleteUser(ctx context.Context, username string) error
  • func (m *Mysql) RevokePrivileges(ctx context.Context, username string, privileges []v1alpha1.PrivilegeSpec) error

Types

type Config

type Config struct {
	Host         string
	Port         int
	User         string
	Password     string
	DatabaseName string
	// contains filtered or unexported fields
}

func NewConfig

func NewConfig(host string, port int, user, pass, dbname, usersHostname string) *Config

func (*Config) ConnString

func (c *Config) ConnString() (string, error)

func (*Config) UsersHostname

func (c *Config) UsersHostname() string

type Mysql

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

func NewMysql

func NewMysql(conn connection.Connection, config *Config, logger logr.Logger) *Mysql

func (*Mysql) ApplyPrivileges

func (m *Mysql) ApplyPrivileges(ctx context.Context, username string, privileges []v1alpha1.PrivilegeSpec) error

func (*Mysql) Close

func (m *Mysql) Close(ctx context.Context) error

func (*Mysql) Connect

func (m *Mysql) Connect(ctx context.Context) error

func (*Mysql) CreateUser

func (m *Mysql) CreateUser(ctx context.Context, username, password string) (map[string]string, error)

func (*Mysql) DeleteUser

func (m *Mysql) DeleteUser(ctx context.Context, username string) error

func (*Mysql) RevokePrivileges

func (m *Mysql) RevokePrivileges(ctx context.Context, username string, privileges []v1alpha1.PrivilegeSpec) error