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 MakeJobs(sc *scyllav1.ScyllaCluster, services map[string]*corev1.Service, image string) ([]*batchv1.Job, []metav1.Condition)
- func MakeManagedScyllaDBConfig(sc *scyllav1.ScyllaCluster) (*corev1.ConfigMap, error)
- 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, error)
- 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 MakeManagedScyllaDBConfig ¶ added in v1.12.0
func MakeManagedScyllaDBConfig(sc *scyllav1.ScyllaCluster) (*corev1.ConfigMap, error)
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, rackOrdinal int, inputsHash 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, jobInformer batchv1informers.JobInformer, scyllaClusterInformer scyllav1informers.ScyllaClusterInformer, operatorImage string, cqlsIngressPort int, keyGetter crypto.RSAKeyGetter, ) (*Controller, error)
type UpgradePhase ¶
type UpgradePhase string
const ( PreHooksUpgradePhase UpgradePhase = "PreHooks" RolloutInitUpgradePhase UpgradePhase = "RolloutInit" RolloutRunUpgradePhase UpgradePhase = "RolloutRun" PostHooksUpgradePhase UpgradePhase = "PostHooks" )
Source Files
Click to show internal directories.
Click to hide internal directories.