failover

Documentation

Index

• Constants
• Variables
• type Cluster
  • func NewCluster(ns, cluster string, stor *storage.Storage) *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 Failover
  • func New(storage *storage.Storage) *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) 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
)

Variables

var (
	// PingInterval stands ping period, at least more than double ProbeInterval
	PingInterval = 6

	MaxPingCount = 2

	// MinAliveSize is min number of cluster nodes to enter the safe mode
	MinAliveSize = 10

	// MaxFailureRatio is gate value, more than clusters failed enter the safe mode
	MaxFailureRatio = 0.4

	GCInterval = 1
)

Types

type Cluster

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

func NewCluster

func NewCluster(ns, cluster string, stor *storage.Storage) *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 Failover

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

func New

func New(storage *storage.Storage) *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) 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()