scylladbdatacenter

Documentation

Index

• Constants
• func IdentityService(sdc *scyllav1alpha1.ScyllaDBDatacenter) (*corev1.Service, error)
• func ImageForCluster(c *scyllav1.ScyllaCluster) string
• func MakeAgentAuthTokenSecret(sdc *scyllav1alpha1.ScyllaDBDatacenter, authToken string) (*corev1.Secret, error)
• func MakeIngresses(sdc *scyllav1alpha1.ScyllaDBDatacenter, services map[string]*corev1.Service) []*networkingv1.Ingress
• func MakeJobs(sdc *scyllav1alpha1.ScyllaDBDatacenter, services map[string]*corev1.Service, ...) ([]*batchv1.Job, []metav1.Condition, error)
• func MakeManagedScyllaDBConfig(sdc *scyllav1alpha1.ScyllaDBDatacenter) (*corev1.ConfigMap, error)
• func MakePodDisruptionBudget(sdc *scyllav1alpha1.ScyllaDBDatacenter) *policyv1.PodDisruptionBudget
• func MakeRoleBinding(sdc *scyllav1alpha1.ScyllaDBDatacenter) *rbacv1.RoleBinding
• func MakeServiceAccount(sdc *scyllav1alpha1.ScyllaDBDatacenter) *corev1.ServiceAccount
• func MakeUpgradeContextConfigMap(sdc *scyllav1alpha1.ScyllaDBDatacenter, ...) (*corev1.ConfigMap, error)
• func MemberService(sdc *scyllav1alpha1.ScyllaDBDatacenter, rackName, name string, ...) (*corev1.Service, error)
• func StatefulSetForRack(rack scyllav1alpha1.RackSpec, sdc *scyllav1alpha1.ScyllaDBDatacenter, ...) (*appsv1.StatefulSet, error)
• type Controller
  • func NewController(kubeClient kubernetes.Interface, ...) (*Controller, error)
  • func (sdcc *Controller) Run(ctx context.Context, workers int)

Constants

const (
	ControllerName = "ScyllaDBDatacenterController"
)

Functions

func IdentityService

func IdentityService(sdc *scyllav1alpha1.ScyllaDBDatacenter) (*corev1.Service, error)

func ImageForCluster

func ImageForCluster(c *scyllav1.ScyllaCluster) string

func MakeAgentAuthTokenSecret

func MakeAgentAuthTokenSecret(sdc *scyllav1alpha1.ScyllaDBDatacenter, authToken string) (*corev1.Secret, error)

func MakeIngresses

func MakeIngresses(sdc *scyllav1alpha1.ScyllaDBDatacenter, services map[string]*corev1.Service) []*networkingv1.Ingress

func MakeJobs

func MakeJobs(sdc *scyllav1alpha1.ScyllaDBDatacenter, services map[string]*corev1.Service, image string) ([]*batchv1.Job, []metav1.Condition, error)

func MakeManagedScyllaDBConfig

func MakeManagedScyllaDBConfig(sdc *scyllav1alpha1.ScyllaDBDatacenter) (*corev1.ConfigMap, error)

func MakePodDisruptionBudget

func MakePodDisruptionBudget(sdc *scyllav1alpha1.ScyllaDBDatacenter) *policyv1.PodDisruptionBudget

func MakeRoleBinding

func MakeRoleBinding(sdc *scyllav1alpha1.ScyllaDBDatacenter) *rbacv1.RoleBinding

func MakeServiceAccount

func MakeServiceAccount(sdc *scyllav1alpha1.ScyllaDBDatacenter) *corev1.ServiceAccount

func MakeUpgradeContextConfigMap

func MakeUpgradeContextConfigMap(sdc *scyllav1alpha1.ScyllaDBDatacenter, uc *internalapi.DatacenterUpgradeContext) (*corev1.ConfigMap, error)

func MemberService

func MemberService(sdc *scyllav1alpha1.ScyllaDBDatacenter, rackName, name string, oldService *corev1.Service, jobs map[string]*batchv1.Job) (*corev1.Service, error)

func StatefulSetForRack

func StatefulSetForRack(rack scyllav1alpha1.RackSpec, sdc *scyllav1alpha1.ScyllaDBDatacenter, 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 scyllav1alpha1client.ScyllaV1alpha1Interface,
	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,
	scyllaDBDatacenterInformer scyllav1alpha1informers.ScyllaDBDatacenterInformer,
	operatorImage string,
	cqlsIngressPort int,
	keyGetter crypto.RSAKeyGetter,
) (*Controller, error)

func (*Controller) Run

func (sdcc *Controller) Run(ctx context.Context, workers int)