handler

Documentation

Index

• type Bootstrap
  • func NewBootstrap(fileManager *filemanager.FileManager, responseWriter *mdbhttp.ResponseWriter, ...) *Bootstrap
  • func (b *Bootstrap) Disable(w http.ResponseWriter, r *http.Request)
  • func (b *Bootstrap) Enable(w http.ResponseWriter, r *http.Request)
  • func (b *Bootstrap) IsBootstrapEnabled(w http.ResponseWriter, r *http.Request)
• type Handler
  • func NewHandler(mariadbKey types.NamespacedName, client ctrlclient.Client, ...) *Handler
• type Probe
  • func NewProbe(mariadbKey types.NamespacedName, k8sClient ctrlclient.Client, ...) *Probe
  • func (p *Probe) Liveness(w http.ResponseWriter, r *http.Request)
  • func (p *Probe) Readiness(w http.ResponseWriter, r *http.Request)
• type Recovery
  • func NewRecover(fileManager *filemanager.FileManager, responseWriter *mdbhttp.ResponseWriter, ...) *Recovery
  • func (r *Recovery) Disable(w http.ResponseWriter, req *http.Request)
  • func (r *Recovery) Enable(w http.ResponseWriter, req *http.Request)
  • func (r *Recovery) Start(w http.ResponseWriter, req *http.Request)
• type RecoveryOption
  • func WithRecoveryTimeout(timeout time.Duration) RecoveryOption
• type State
  • func NewState(fileManager *filemanager.FileManager, state *state.State, ...) *State
  • func (g *State) GetGaleraState(w http.ResponseWriter, r *http.Request)

Types

type Bootstrap

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

func NewBootstrap

func NewBootstrap(fileManager *filemanager.FileManager, responseWriter *mdbhttp.ResponseWriter, locker sync.Locker,
	logger *logr.Logger) *Bootstrap

func (*Bootstrap) Disable

func (b *Bootstrap) Disable(w http.ResponseWriter, r *http.Request)

func (*Bootstrap) Enable

func (b *Bootstrap) Enable(w http.ResponseWriter, r *http.Request)

func (*Bootstrap) IsBootstrapEnabled

func (b *Bootstrap) IsBootstrapEnabled(w http.ResponseWriter, r *http.Request)

type Handler

type Handler struct {
	Bootstrap *Bootstrap
	State     *State
	Recovery  *Recovery
	Probe     *Probe
}

func NewHandler

func NewHandler(mariadbKey types.NamespacedName, client ctrlclient.Client, fileManager *filemanager.FileManager,
	initState *state.State, logger *logr.Logger, recoveryOpts ...RecoveryOption) *Handler

type Probe

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

func NewProbe

func NewProbe(mariadbKey types.NamespacedName, k8sClient ctrlclient.Client, responseWriter *mdbhttp.ResponseWriter,
	logger *logr.Logger) *Probe

func (*Probe) Liveness

func (p *Probe) Liveness(w http.ResponseWriter, r *http.Request)

func (*Probe) Readiness

func (p *Probe) Readiness(w http.ResponseWriter, r *http.Request)

type Recovery

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

func NewRecover

func NewRecover(fileManager *filemanager.FileManager, responseWriter *mdbhttp.ResponseWriter, locker sync.Locker,
	logger *logr.Logger, opts ...RecoveryOption) *Recovery

func (*Recovery) Disable

func (r *Recovery) Disable(w http.ResponseWriter, req *http.Request)

func (*Recovery) Enable

func (r *Recovery) Enable(w http.ResponseWriter, req *http.Request)

func (*Recovery) Start

func (r *Recovery) Start(w http.ResponseWriter, req *http.Request)

type RecoveryOption

type RecoveryOption func(*Recovery)

func WithRecoveryTimeout

func WithRecoveryTimeout(timeout time.Duration) RecoveryOption

type State

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

func NewState

func NewState(fileManager *filemanager.FileManager, state *state.State, responseWriter *mdbhttp.ResponseWriter,
	locker sync.Locker, logger *logr.Logger) *State

func (*State) GetGaleraState

func (g *State) GetGaleraState(w http.ResponseWriter, r *http.Request)