repl

Documentation

Index

• type HostInfo
• type KubeSeeker
  • func NewKubeSeeker(clientSet *kubernetes.Clientset) *KubeSeeker
  • func (s *KubeSeeker) GetHostInfoByClusterID(clusterID string) (hosts []*HostInfo, err error)
  • func (s *KubeSeeker) GetHostInfoByHostname(hostname string) (host *HostInfo, err error)
• type ReplicationService
  • func NewReplicationService(engine *xorm.Engine, replication config.Replication, seeker Seeker) *ReplicationService
  • func (r *ReplicationService) BuildMasterSlave() (err error)
  • func (r *ReplicationService) CheckSlaveStatus() (ready bool, err error)
  • func (r *ReplicationService) RefreshMaster(replication config.Replication)
  • func (r *ReplicationService) Start()
  • func (r *ReplicationService) Stop()
• type Seeker

Types

type HostInfo

type HostInfo struct {
	Host string `yaml:"host" json:"host"`
	IP   string `yaml:"ip" json:"ip"`
	Port int    `yaml:"port" json:"port"`
}

type KubeSeeker

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

func NewKubeSeeker

func NewKubeSeeker(clientSet *kubernetes.Clientset) *KubeSeeker

func (*KubeSeeker) GetHostInfoByClusterID

func (s *KubeSeeker) GetHostInfoByClusterID(clusterID string) (hosts []*HostInfo, err error)

func (*KubeSeeker) GetHostInfoByHostname

func (s *KubeSeeker) GetHostInfoByHostname(hostname string) (host *HostInfo, err error)

type ReplicationService

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

func NewReplicationService

func NewReplicationService(engine *xorm.Engine, replication config.Replication, seeker Seeker) *ReplicationService

func (*ReplicationService) BuildMasterSlave

func (r *ReplicationService) BuildMasterSlave() (err error)

func (*ReplicationService) CheckSlaveStatus

func (r *ReplicationService) CheckSlaveStatus() (ready bool, err error)

func (*ReplicationService) RefreshMaster

func (r *ReplicationService) RefreshMaster(replication config.Replication)

RefreshMaster when the master changes, refresh master

func (*ReplicationService) Start

func (r *ReplicationService) Start()

Start service of replication

func (*ReplicationService) Stop

func (r *ReplicationService) Stop()

Stop service of replication

type Seeker

type Seeker interface {
	GetHostInfoByHostname(hostname string) (*HostInfo, error)
	GetHostInfoByClusterID(id string) ([]*HostInfo, error)
}