scylladbcluster

package
v1.18.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 30, 2025 License: Apache-2.0 Imports: 50 Imported by: 0

Documentation

Index

Constants

View Source
const (
	ControllerName = "ScyllaDBClusterController"
)

Variables

This section is empty.

Functions

func MakeRemoteConfigMaps added in v1.17.0

func MakeRemoteConfigMaps(sc *scyllav1alpha1.ScyllaDBCluster, dc *scyllav1alpha1.ScyllaDBClusterDatacenter, remoteNamespace *corev1.Namespace, remoteController metav1.Object, localConfigMapLister corev1listers.ConfigMapLister, managingClusterDomain string) ([]metav1.Condition, []*corev1.ConfigMap, error)

func MakeRemoteEndpointSlices

func MakeRemoteEndpointSlices(sc *scyllav1alpha1.ScyllaDBCluster, dc *scyllav1alpha1.ScyllaDBClusterDatacenter, remoteNamespace *corev1.Namespace, remoteController metav1.Object, remoteNamespaces map[string]*corev1.Namespace, remoteServiceLister remotelister.GenericClusterLister[corev1listers.ServiceLister], remotePodLister remotelister.GenericClusterLister[corev1listers.PodLister], managingClusterDomain string) ([]metav1.Condition, []*discoveryv1.EndpointSlice, error)

func MakeRemoteKindControllerDatacenterConditionFunc added in v1.17.0

func MakeRemoteKindControllerDatacenterConditionFunc(kind, conditionType string) func(dcName string) string

MakeRemoteKindControllerDatacenterConditionFunc returns a format string for a remote kind controller datacenter condition.

func MakeRemoteNamespaces

func MakeRemoteNamespaces(sc *scyllav1alpha1.ScyllaDBCluster, dc *scyllav1alpha1.ScyllaDBClusterDatacenter, managingClusterDomain string) ([]*corev1.Namespace, error)

func MakeRemoteRemoteOwners

func MakeRemoteRemoteOwners(sc *scyllav1alpha1.ScyllaDBCluster, dc *scyllav1alpha1.ScyllaDBClusterDatacenter, remoteNamespace *corev1.Namespace, managingClusterDomain string) ([]*scyllav1alpha1.RemoteOwner, error)

func MakeRemoteScyllaDBDatacenters

func MakeRemoteScyllaDBDatacenters(sc *scyllav1alpha1.ScyllaDBCluster, dc *scyllav1alpha1.ScyllaDBClusterDatacenter, remoteScyllaDBDatacenters map[string]map[string]*scyllav1alpha1.ScyllaDBDatacenter, remoteNamespace *corev1.Namespace, remoteController metav1.Object, managingClusterDomain string) (*scyllav1alpha1.ScyllaDBDatacenter, error)

func MakeRemoteSecrets added in v1.17.0

func MakeRemoteSecrets(sc *scyllav1alpha1.ScyllaDBCluster, dc *scyllav1alpha1.ScyllaDBClusterDatacenter, remoteNamespace *corev1.Namespace, remoteController metav1.Object, localSecretLister corev1listers.SecretLister, managingClusterDomain string) ([]metav1.Condition, []*corev1.Secret, error)

func MakeRemoteServices

func MakeRemoteServices(sc *scyllav1alpha1.ScyllaDBCluster, dc *scyllav1alpha1.ScyllaDBClusterDatacenter, remoteNamespace *corev1.Namespace, remoteController metav1.Object, managingClusterDomain string) []*corev1.Service

Types

type Controller

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

func NewController

func NewController(
	kubeClient kubernetes.Interface,
	scyllaClient scyllaclient.Interface,
	kubeRemoteClient remoteclient.ClusterClientInterface[kubernetes.Interface],
	scyllaRemoteClient remoteclient.ClusterClientInterface[scyllaclient.Interface],
	scyllaDBClusterInformer scyllav1alpha1informers.ScyllaDBClusterInformer,
	scyllaOperatorConfigInformer scyllav1alpha1informers.ScyllaOperatorConfigInformer,
	configMapInformer corev1informers.ConfigMapInformer,
	secretInformer corev1informers.SecretInformer,
	serviceInformer corev1informers.ServiceInformer,
	endpointSliceInformer discoveryv1informers.EndpointSliceInformer,
	endpointsInformer corev1informers.EndpointsInformer,
	remoteRemoteOwnerInformer remoteinformers.GenericClusterInformer,
	remoteScyllaDBDatacenterInformer remoteinformers.GenericClusterInformer,
	remoteNamespaceInformer remoteinformers.GenericClusterInformer,
	remoteServiceInformer remoteinformers.GenericClusterInformer,
	remoteEndpointSliceInformer remoteinformers.GenericClusterInformer,
	remoteEndpointsInformer remoteinformers.GenericClusterInformer,
	remotePodInformer remoteinformers.GenericClusterInformer,
	remoteConfigMapInformer remoteinformers.GenericClusterInformer,
	remoteSecretInformer remoteinformers.GenericClusterInformer,
) (*Controller, error)

func (*Controller) Run

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL