probe

Documentation

Index

• Variables
• type Cluster
  • func NewCluster(ns, cluster string, storage *storage.Storage, failOver *failover.FailOver) *Cluster
• type Probe
  • func New(storage *storage.Storage, failOver *failover.FailOver) *Probe
  • func (p *Probe) AddCluster(ns, cluster string)
  • func (p *Probe) Load(ctx context.Context) error
  • func (p *Probe) RemoveCluster(ns, cluster string)
  • func (p *Probe) Shutdown()

Variables

var (
	ErrClusterNotInitialized = errors.New("CLUSTERDOWN The cluster is not initialized")
	ErrRestoringBackUp       = errors.New("LOADING kvrocks is restoring the db from backup")
)

Types

type Cluster

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

func NewCluster

func NewCluster(ns, cluster string, storage *storage.Storage, failOver *failover.FailOver) *Cluster

type Probe

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

func New

func New(storage *storage.Storage, failOver *failover.FailOver) *Probe

New return Probe contain all methods to manager loop

func (*Probe) AddCluster

func (p *Probe) AddCluster(ns, cluster string)

AddCluster add cluster loop and start

func (*Probe) Load

func (p *Probe) Load(ctx context.Context) error

func (*Probe) RemoveCluster

func (p *Probe) RemoveCluster(ns, cluster string)

RemoveCluster delete cluster loop and stop

func (*Probe) Shutdown

func (p *Probe) Shutdown()

Shutdown all cluster loop when leader-follower switch