failover

Documentation

Index

• Constants
• type Cluster
  • func NewCluster(ns, cluster string, stor *storage.Storage, cfg *config.FailOverConfig) *Cluster
  • func (c *Cluster) AddTask(task *storage.FailoverTask) error
  • func (c *Cluster) Close() error
  • func (c *Cluster) GetTasks() ([]*storage.FailoverTask, error)
  • func (c *Cluster) IsEmpty() bool
  • func (c *Cluster) RemoveNodeTask(addr string)
• type ClusterConfig
• type FailOver
  • func New(storage *storage.Storage, failOverConfig *config.FailOverConfig) *FailOver
  • func (f *FailOver) AddNode(ns, cluster string, shardIdx int, node metadata.NodeInfo, typ int) error
  • func (f *FailOver) AddNodeTask(task *storage.FailoverTask) error
  • func (f *FailOver) Config() *config.FailOverConfig
  • func (f *FailOver) GetTasks(ctx context.Context, ns, cluster string, queryType string) ([]*storage.FailoverTask, error)
  • func (f *FailOver) Load() error
  • func (f *FailOver) Shutdown()

Constants

const (
	TaskQueued = iota + 1
	TaskStarted
	TaskSuccess
	TaskFailed
)

const (
	AutoType = iota + 1
	ManualType
)

Types

type Cluster

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

func NewCluster

func NewCluster(ns, cluster string, stor *storage.Storage, cfg *config.FailOverConfig) *Cluster

NewCluster return a Cluster instance and start schedule goroutine

func (*Cluster) AddTask

func (c *Cluster) AddTask(task *storage.FailoverTask) error

func (*Cluster) Close

func (c *Cluster) Close() error

Close will release the resource when closing

func (*Cluster) GetTasks

func (c *Cluster) GetTasks() ([]*storage.FailoverTask, error)

func (*Cluster) IsEmpty

func (c *Cluster) IsEmpty() bool

IsEmpty return an indicator whether the tasks queue has tasks, callend gcClusters

func (*Cluster) RemoveNodeTask

func (c *Cluster) RemoveNodeTask(addr string)

type ClusterConfig

type ClusterConfig struct {
	PingInterval    int
	MaxPingCount    int
	MinAliveSize    int
	MaxFailureRatio float64
}

type FailOver

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

func New

func New(storage *storage.Storage, failOverConfig *config.FailOverConfig) *FailOver

func (*FailOver) AddNode

func (f *FailOver) AddNode(ns, cluster string, shardIdx int, node metadata.NodeInfo, typ int) error

func (*FailOver) AddNodeTask

func (f *FailOver) AddNodeTask(task *storage.FailoverTask) error

func (*FailOver) Config

func (f *FailOver) Config() *config.FailOverConfig

func (*FailOver) GetTasks

func (f *FailOver) GetTasks(ctx context.Context, ns, cluster string, queryType string) ([]*storage.FailoverTask, error)

func (*FailOver) Load

func (f *FailOver) Load() error

func (*FailOver) Shutdown

func (f *FailOver) Shutdown()