util

func CanServeService(endpoints *apiv1.Endpoints) bool

func CreateKubeResource(kubeClient kubernetes.Interface, namespace string, obj runtime.Object) (err error)

func GetMasterIPByName(client *redis.Client, name string) (string, error)

func GetSeedMasterIP(podLister v1lister.PodLister, namespace, name string) (string, error)

func GetSlaveCount(client *redis.Client, name string) int

func InClusterConfig() (*rest.Config, error)

func InPodPhase(phase apiv1.PodPhase, pod *apiv1.Pod) bool

func IsPodReady(pod *apiv1.Pod) bool

func NewSentinelRedisClient(name string) *redis.Client

func ResourceAlreadyExistError(err error) bool

func ResourceNotFoundError(err error) bool

func WaitForResourceToBeEstablished(retries int, resourceFunc func() (bool, error)) error