dm

Documentation

Index

• type DM
• type Ops
  • func New(namespace, name string, conf fixture.DMConfig) *Ops
  • func (o *Ops) Apply() error
  • func (o *Ops) Delete() error
  • func (o *Ops) GetClientNodes() ([]cluster.ClientNode, error)
  • func (o *Ops) GetNodes() ([]cluster.Node, error)

Types

type DM

type DM struct {
	SvcMaster *corev1.Service
	SvcWorker *corev1.Service
	StsMaster *appsv1.StatefulSet
	StsWorker *appsv1.StatefulSet
}

DM represents a DM cluster in K8s.

type Ops

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

Ops knows how to operate DM cluster on K8s.

func New

func New(namespace, name string, conf fixture.DMConfig) *Ops

New creates a new DM Ops.

func (*Ops) Apply

func (o *Ops) Apply() error

Apply DM cluster.

func (*Ops) Delete

func (o *Ops) Delete() error

Delete DM cluster.

func (*Ops) GetClientNodes

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

GetClientNodes returns the client nodes.

func (*Ops) GetNodes

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

GetNodes returns DM (DM-master & DM-worker) nodes.