Documentation ¶
Index ¶
- Constants
- func IdentityService(c *scyllav1.ScyllaCluster) *corev1.Service
- func ImageForCluster(c *scyllav1.ScyllaCluster) string
- func MakeAgentAuthTokenSecret(c *scyllav1.ScyllaCluster, authToken string) (*corev1.Secret, error)
- func MakeIngresses(c *scyllav1.ScyllaCluster, services map[string]*corev1.Service) []*networkingv1.Ingress
- func MakePodDisruptionBudget(c *scyllav1.ScyllaCluster) *policyv1.PodDisruptionBudget
- func MakeRoleBinding(sc *scyllav1.ScyllaCluster) *rbacv1.RoleBinding
- func MakeServiceAccount(sc *scyllav1.ScyllaCluster) *corev1.ServiceAccount
- func MemberService(sc *scyllav1.ScyllaCluster, rackName, name string, oldService *corev1.Service) *corev1.Service
- func StatefulSetForRack(r scyllav1.RackSpec, c *scyllav1.ScyllaCluster, ...) (*appsv1.StatefulSet, error)
- type Controller
- type UpgradePhase
Constants ¶
View Source
const (
ControllerName = "ScyllaClusterController"
)
Variables ¶
This section is empty.
Functions ¶
func IdentityService ¶ added in v1.8.0
func IdentityService(c *scyllav1.ScyllaCluster) *corev1.Service
func ImageForCluster ¶ added in v1.6.0
func ImageForCluster(c *scyllav1.ScyllaCluster) string
func MakeAgentAuthTokenSecret ¶ added in v1.6.0
func MakeIngresses ¶ added in v1.8.0
func MakeIngresses(c *scyllav1.ScyllaCluster, services map[string]*corev1.Service) []*networkingv1.Ingress
func MakePodDisruptionBudget ¶ added in v1.6.0
func MakePodDisruptionBudget(c *scyllav1.ScyllaCluster) *policyv1.PodDisruptionBudget
func MakeRoleBinding ¶ added in v1.8.0
func MakeRoleBinding(sc *scyllav1.ScyllaCluster) *rbacv1.RoleBinding
func MakeServiceAccount ¶ added in v1.8.0
func MakeServiceAccount(sc *scyllav1.ScyllaCluster) *corev1.ServiceAccount
func MemberService ¶ added in v1.6.0
func StatefulSetForRack ¶ added in v1.6.0
func StatefulSetForRack(r scyllav1.RackSpec, c *scyllav1.ScyllaCluster, existingSts *appsv1.StatefulSet, sidecarImage string) (*appsv1.StatefulSet, error)
StatefulSetForRack make a StatefulSet for the rack. existingSts may be nil if it doesn't exist yet.
Types ¶
type Controller ¶
type Controller struct {
// contains filtered or unexported fields
}
func NewController ¶
func NewController( kubeClient kubernetes.Interface, scyllaClient scyllav1client.ScyllaV1Interface, podInformer corev1informers.PodInformer, serviceInformer corev1informers.ServiceInformer, secretInformer corev1informers.SecretInformer, configMapInformer corev1informers.ConfigMapInformer, serviceAccountInformer corev1informers.ServiceAccountInformer, roleBindingInformer rbacv1informers.RoleBindingInformer, statefulSetInformer appsv1informers.StatefulSetInformer, pdbInformer policyv1informers.PodDisruptionBudgetInformer, ingressInformer networkingv1informers.IngressInformer, scyllaClusterInformer scyllav1informers.ScyllaClusterInformer, operatorImage string, cqlsIngressPort int, ) (*Controller, error)
type UpgradePhase ¶
type UpgradePhase string
const ( PreHooksUpgradePhase UpgradePhase = "PreHooks" RolloutInitUpgradePhase UpgradePhase = "RolloutInit" RolloutRunUpgradePhase UpgradePhase = "RolloutRun" PostHooksUpgradePhase UpgradePhase = "PostHooks" )
Click to show internal directories.
Click to hide internal directories.