util

Documentation

Index

• 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

Functions

func CanServeService

func CanServeService(endpoints *apiv1.Endpoints) bool

func CreateKubeResource

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

func GetMasterIPByName

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

func GetSeedMasterIP

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

func GetSlaveCount

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

func InClusterConfig

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

func InPodPhase

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

func IsPodReady

func IsPodReady(pod *apiv1.Pod) bool

func NewSentinelRedisClient

func NewSentinelRedisClient(name string) *redis.Client

func ResourceAlreadyExistError

func ResourceAlreadyExistError(err error) bool

func ResourceNotFoundError

func ResourceNotFoundError(err error) bool

func WaitForResourceToBeEstablished

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