binlog

Documentation

Index

• func RenderDrainerCommand(model *DrainerCommandModel) (string, error)
• func RenderDrainerConfig(model *DrainerConfigModel) (string, error)
• type Drainer
• type DrainerCommandModel
• type DrainerConfigModel
• type Ops
  • func New(ns, name string) *Ops
  • func (t *Ops) Apply() error
  • func (t *Ops) Delete() error
  • func (t *Ops) GetClientNodes() ([]cluster.ClientNode, error)
  • func (t *Ops) GetNodes() ([]cluster.Node, error)

Functions

func RenderDrainerCommand

func RenderDrainerCommand(model *DrainerCommandModel) (string, error)

RenderDrainerCommand ...

func RenderDrainerConfig

func RenderDrainerConfig(model *DrainerConfigModel) (string, error)

RenderDrainerConfig ...

Types

type Drainer

type Drainer struct {
	*corev1.ConfigMap
	*corev1.Service
	*appsv1.StatefulSet
}

Drainer components

type DrainerCommandModel

type DrainerCommandModel struct {
	Component string
}

DrainerCommandModel ...

type DrainerConfigModel

type DrainerConfigModel struct {
	PDAddress    string
	DownStreamDB string
	RelayPath    string
}

DrainerConfigModel ...

type Ops

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

Ops knows how to operate binlog

func New

func New(ns, name string) *Ops

New creates binlog ops

func (*Ops) Apply

func (t *Ops) Apply() error

Apply binlog cluster

func (*Ops) Delete

func (t *Ops) Delete() error

Delete binlog cluster

func (*Ops) GetClientNodes

func (t *Ops) GetClientNodes() ([]cluster.ClientNode, error)

GetClientNodes returns client nodes

func (*Ops) GetNodes

func (t *Ops) GetNodes() ([]cluster.Node, error)

GetNodes returns all nodes(eg. pods on k8s)