controller

Jul 10, 2024

Changes in this version

+ var ErrClusterNotInitialized = errors.New("CLUSTERDOWN The cluster is not initialized")

+ var ErrRestoringBackUp = errors.New("LOADING kvrocks is restoring the db from backup")

+ type ClusterCheckOptions struct

+ type ClusterChecker struct

+ func NewClusterChecker(s store.Store, ns, cluster string) *ClusterChecker

+ func (c *ClusterChecker) Close()

+ func (c *ClusterChecker) Start()

+ func (c *ClusterChecker) WithMaxFailureCount(count int64) *ClusterChecker

+ func (c *ClusterChecker) WithPingInterval(interval time.Duration) *ClusterChecker

+ type Controller struct

+ func New(s *store.ClusterStore, config *config.ControllerConfig) (*Controller, error)

+ func (c *Controller) Close()

+ func (c *Controller) Start(ctx context.Context) error

+ func (c *Controller) WaitForReady()