controllerhelpers

Documentation

Index

• func EnsureNodeConfigCondition(status *scyllav1alpha1.NodeConfigStatus, ...)
• func FindNodeConfigCondition(conditions []scyllav1alpha1.NodeConfigCondition, ...) *scyllav1alpha1.NodeConfigCondition
• func FindNodeStatus(nodeStatuses []scyllav1alpha1.NodeConfigNodeStatus, nodeName string) *scyllav1alpha1.NodeConfigNodeStatus
• func FindScyllaContainerStatus(pod *corev1.Pod) *corev1.ContainerStatus
• 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 GetScyllaContainerID(pod *corev1.Pod) (string, error)
• func GetScyllaHost(statefulsetName string, ordinal int32, services map[string]*corev1.Service) (string, error)
• func GetScyllaIPFromService(svc *corev1.Service) (string, error)
• func IsDaemonSetRolledOut(ds *appsv1.DaemonSet) (bool, error)
• func IsNodeConfigSelectingNode(nc *scyllav1alpha1.NodeConfig, node *corev1.Node) (bool, error)
• func IsNodeTuned(ncnss []scyllav1alpha1.NodeConfigNodeStatus, nodeName string) bool
• func IsNodeTunedForContainer(nc *scyllav1alpha1.NodeConfig, nodeName string, containerID string) bool
• 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 IsScyllaContainerRunning(pod *corev1.Pod) bool
• 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 SetNodeStatus(nodeStatuses []scyllav1alpha1.NodeConfigNodeStatus, ...) []scyllav1alpha1.NodeConfigNodeStatus
• func SetRackCondition(rackStatus *scyllav1.RackStatus, newCondition scyllav1.RackConditionType)
• type RequeueError
  • func NewRequeueError(reasons ...string) *RequeueError
  • func (e *RequeueError) Error() string

Functions

func EnsureNodeConfigCondition

func EnsureNodeConfigCondition(status *scyllav1alpha1.NodeConfigStatus, cond *scyllav1alpha1.NodeConfigCondition)

func FindNodeConfigCondition

func FindNodeConfigCondition(conditions []scyllav1alpha1.NodeConfigCondition, t scyllav1alpha1.NodeConfigConditionType) *scyllav1alpha1.NodeConfigCondition

func FindNodeStatus

func FindNodeStatus(nodeStatuses []scyllav1alpha1.NodeConfigNodeStatus, nodeName string) *scyllav1alpha1.NodeConfigNodeStatus

func FindScyllaContainerStatus

func FindScyllaContainerStatus(pod *corev1.Pod) *corev1.ContainerStatus

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 GetScyllaContainerID

func GetScyllaContainerID(pod *corev1.Pod) (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 IsDaemonSetRolledOut

func IsDaemonSetRolledOut(ds *appsv1.DaemonSet) (bool, error)

func IsNodeConfigSelectingNode

func IsNodeConfigSelectingNode(nc *scyllav1alpha1.NodeConfig, node *corev1.Node) (bool, error)

func IsNodeTuned

func IsNodeTuned(ncnss []scyllav1alpha1.NodeConfigNodeStatus, nodeName string) bool

func IsNodeTunedForContainer

func IsNodeTunedForContainer(nc *scyllav1alpha1.NodeConfig, nodeName string, containerID string) bool

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 IsScyllaContainerRunning

func IsScyllaContainerRunning(pod *corev1.Pod) bool

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 SetNodeStatus

func SetNodeStatus(nodeStatuses []scyllav1alpha1.NodeConfigNodeStatus, status *scyllav1alpha1.NodeConfigNodeStatus) []scyllav1alpha1.NodeConfigNodeStatus

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