Documentation ¶
Index ¶
- type CommandHandler
- func (handler *CommandHandler) ChangePassword(password string)
- func (h *CommandHandler) EnsureConfig(nodes []*kvrocks.Node) error
- func (h *CommandHandler) EnsureSentinel(masterIP string, index ...int) (bool, error)
- func (h *CommandHandler) EnsureTopo() (bool, error)
- func (h *CommandHandler) GetOrCreateSentinel() (*corev1.PodList, *string, bool, error)
- func (h *CommandHandler) GetSentinel(key types.NamespacedName) (*corev1.PodList, *string, bool, error)
- func (h *CommandHandler) RemoveMonitor(masterName string, index ...int) (bool, error)
- func (h *CommandHandler) ResizeStatefulSet(stsNodes []*kvrocks.Node, index ...int) (bool, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CommandHandler ¶
type CommandHandler struct {
// contains filtered or unexported fields
}
func NewCommandHandler ¶
func NewCommandHandler(instance *kvrocksv1alpha1.KVRocks, k8s *k8s.Client, kvrocks *kvrocks.Client, password string) *CommandHandler
func (*CommandHandler) ChangePassword ¶
func (handler *CommandHandler) ChangePassword(password string)
func (*CommandHandler) EnsureConfig ¶
func (h *CommandHandler) EnsureConfig(nodes []*kvrocks.Node) error
func (*CommandHandler) EnsureSentinel ¶
func (h *CommandHandler) EnsureSentinel(masterIP string, index ...int) (bool, error)
func (*CommandHandler) EnsureTopo ¶
func (h *CommandHandler) EnsureTopo() (bool, error)
func (*CommandHandler) GetOrCreateSentinel ¶
func (*CommandHandler) GetSentinel ¶
func (h *CommandHandler) GetSentinel(key types.NamespacedName) (*corev1.PodList, *string, bool, error)
func (*CommandHandler) RemoveMonitor ¶
func (h *CommandHandler) RemoveMonitor(masterName string, index ...int) (bool, error)
func (*CommandHandler) ResizeStatefulSet ¶
Click to show internal directories.
Click to hide internal directories.