helpers

Documentation

Index

• func GenerateMergePatch(original runtime.Object, modified runtime.Object) ([]byte, error)
• func GetNodePointerArrayFromArray(nodes []corev1.Node) []*corev1.Node
• func GetPodCondition(conditions []corev1.PodCondition, conditionType corev1.PodConditionType) *corev1.PodCondition
• func GetRequiredScyllaHosts(sc *scyllav1.ScyllaCluster, services map[string]*corev1.Service) ([]string, error)
• func GetScyllaHost(statefulsetName string, ordinal int32, services map[string]*corev1.Service) (string, error)
• func GetScyllaIPFromService(svc *corev1.Service) (string, error)
• func IsOrphanedPV(pv *corev1.PersistentVolume, nodes []*corev1.Node) (bool, error)
• func IsPodReady(pod *corev1.Pod) bool
• func IsPodReadyWithPositiveLiveCheck(ctx context.Context, client corev1client.PodsGetter, pod *corev1.Pod) (bool, *corev1.Pod, error)
• func IsStatefulSetRolledOut(sts *appsv1.StatefulSet) (bool, error)
• func NewScyllaClientFromSecret(secret *corev1.Secret, hosts []string) (*scyllaclient.Client, error)
• func NewScyllaClientFromToken(hosts []string, authToken string) (*scyllaclient.Client, error)
• func SetRackCondition(rackStatus *scyllav1.RackStatus, newCondition scyllav1.RackConditionType)
• type RequeueError
  • func NewRequeueError(reasons ...string) *RequeueError
  • func (e *RequeueError) Error() string

Functions

func GenerateMergePatch

func GenerateMergePatch(original runtime.Object, modified runtime.Object) ([]byte, error)

func GetNodePointerArrayFromArray

func GetNodePointerArrayFromArray(nodes []corev1.Node) []*corev1.Node

func GetPodCondition

func GetPodCondition(conditions []corev1.PodCondition, conditionType corev1.PodConditionType) *corev1.PodCondition

func GetRequiredScyllaHosts

func GetRequiredScyllaHosts(sc *scyllav1.ScyllaCluster, services map[string]*corev1.Service) ([]string, error)

func GetScyllaHost

func GetScyllaHost(statefulsetName string, ordinal int32, services map[string]*corev1.Service) (string, error)

func GetScyllaIPFromService

func GetScyllaIPFromService(svc *corev1.Service) (string, error)

func IsOrphanedPV

func IsOrphanedPV(pv *corev1.PersistentVolume, nodes []*corev1.Node) (bool, error)

func IsPodReady

func IsPodReady(pod *corev1.Pod) bool

func IsPodReadyWithPositiveLiveCheck

func IsPodReadyWithPositiveLiveCheck(ctx context.Context, client corev1client.PodsGetter, pod *corev1.Pod) (bool, *corev1.Pod, error)

func IsStatefulSetRolledOut

func IsStatefulSetRolledOut(sts *appsv1.StatefulSet) (bool, error)

func NewScyllaClientFromSecret

func NewScyllaClientFromSecret(secret *corev1.Secret, hosts []string) (*scyllaclient.Client, error)

func NewScyllaClientFromToken

func NewScyllaClientFromToken(hosts []string, authToken string) (*scyllaclient.Client, error)

func SetRackCondition

func SetRackCondition(rackStatus *scyllav1.RackStatus, newCondition scyllav1.RackConditionType)

Types

type RequeueError

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

func NewRequeueError

func NewRequeueError(reasons ...string) *RequeueError

func (*RequeueError) Error

func (e *RequeueError) Error() string