driver

Documentation

Index

• type Database
• type DriverManager
  • func NewManager(k8sclient client.Client, instance *v1alpha1.AppHook, secret *corev1.Secret) (*DriverManager, error)
  • func (d *DriverManager) DBConnect() error
  • func (d *DriverManager) DBPrepare() (*v1alpha1.PreservedConfig, error)
  • func (d *DriverManager) DBQuiesce() (*v1alpha1.QuiesceResult, error)
  • func (d *DriverManager) DBUnquiesce(prev *v1alpha1.PreservedConfig) error
  • func (d *DriverManager) NotReady()
  • func (d *DriverManager) Ready()
  • func (d *DriverManager) Update(instance *v1alpha1.AppHook, secret *corev1.Secret) error
• type SupportedDB

Types

type Database

type Database interface {
	Init(appconfig.Config) error
	Connect() error
	Prepare() (*v1alpha1.PreservedConfig, error)
	Quiesce() (*v1alpha1.QuiesceResult, error)
	Unquiesce(*v1alpha1.PreservedConfig) error
}

type DriverManager

type DriverManager struct {
	client.Client
	// contains filtered or unexported fields
}

func NewManager

func NewManager(k8sclient client.Client, instance *v1alpha1.AppHook, secret *corev1.Secret) (*DriverManager, error)

func (*DriverManager) DBConnect

func (d *DriverManager) DBConnect() error

func (*DriverManager) DBPrepare

func (d *DriverManager) DBPrepare() (*v1alpha1.PreservedConfig, error)

func (*DriverManager) DBQuiesce

func (d *DriverManager) DBQuiesce() (*v1alpha1.QuiesceResult, error)

func (*DriverManager) DBUnquiesce

func (d *DriverManager) DBUnquiesce(prev *v1alpha1.PreservedConfig) error

func (*DriverManager) NotReady

func (d *DriverManager) NotReady()

func (*DriverManager) Ready

func (d *DriverManager) Ready()

func (*DriverManager) Update

func (d *DriverManager) Update(instance *v1alpha1.AppHook, secret *corev1.Secret) error

danger, do NOT update the config when database is quiesced

type SupportedDB

type SupportedDB string

const (
	MySQL    SupportedDB = "MySQL"
	Postgres SupportedDB = "Postgres"
	MongoDB  SupportedDB = "MongoDB"
	Redis    SupportedDB = "Redis"
)