controller

Documentation

Index

• type Controller
  • func New(s *storage.Storage, config *config.Config) (*Controller, error)
  • func (c *Controller) GetFailOver() *failover.FailOver
  • func (c *Controller) GetMigrate() *migrate.Migrator
  • func (c *Controller) Start() error
  • func (c *Controller) Stop() error
• type Syncer
  • func NewSyncer(s *storage.Storage) *Syncer
  • func (syncer *Syncer) Close()
  • func (syncer *Syncer) Notify(event *storage.Event)

Types

type Controller

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

func New

func New(s *storage.Storage, config *config.Config) (*Controller, error)

func (*Controller) GetFailOver

func (c *Controller) GetFailOver() *failover.FailOver

func (*Controller) GetMigrate

func (c *Controller) GetMigrate() *migrate.Migrator

func (*Controller) Start

func (c *Controller) Start() error

func (*Controller) Stop

func (c *Controller) Stop() error

type Syncer

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

Syncer would sync the cluster topology information to cluster nodes when it's changed.

func NewSyncer

func NewSyncer(s *storage.Storage) *Syncer

func (*Syncer) Close

func (syncer *Syncer) Close()

func (*Syncer) Notify

func (syncer *Syncer) Notify(event *storage.Event)