internal

Documentation

Index

• type PodExecutor
  • func NewPodExecutor() (*PodExecutor, error)
  • func (p *PodExecutor) Exec(namespace, podName, containerName string, command ...string) ([]byte, []byte, error)
  • func (p *PodExecutor) SetGlobalSysVar(namespace, podName string, query string) error
• type SQLRunner
  • func NewSQLRunner(user, password, host string, port int) (*SQLRunner, error)
  • func (s *SQLRunner) CheckReadOnly() (corev1.ConditionStatus, error)
  • func (s *SQLRunner) CheckSlaveStatusWithRetry(retry uint32) (isLagged, isReplicating corev1.ConditionStatus, err error)
  • func (sr *SQLRunner) Close() error
  • func (sr *SQLRunner) GetGlobalVariable(param string, val interface{}) error

Types

type PodExecutor

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

func NewPodExecutor

func NewPodExecutor() (*PodExecutor, error)

func (*PodExecutor) Exec

func (p *PodExecutor) Exec(namespace, podName, containerName string, command ...string) ([]byte, []byte, error)

func (*PodExecutor) SetGlobalSysVar

func (p *PodExecutor) SetGlobalSysVar(namespace, podName string, query string) error

type SQLRunner

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

func NewSQLRunner

func NewSQLRunner(user, password, host string, port int) (*SQLRunner, error)

func (*SQLRunner) CheckReadOnly

func (s *SQLRunner) CheckReadOnly() (corev1.ConditionStatus, error)

func (*SQLRunner) CheckSlaveStatusWithRetry

func (s *SQLRunner) CheckSlaveStatusWithRetry(retry uint32) (isLagged, isReplicating corev1.ConditionStatus, err error)

func (*SQLRunner) Close

func (sr *SQLRunner) Close() error

func (*SQLRunner) GetGlobalVariable

func (sr *SQLRunner) GetGlobalVariable(param string, val interface{}) error