controllers

package

v1.0.0-alpha.1 Latest Latest Go to latest Published: Oct 1, 2021 License: Apache-2.0 Imports: 34 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/k8ssandra/k8ssandra-operator

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func InitConfig()
type K8ssandraClusterReconciler
- func (r *K8ssandraClusterReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
- func (r *K8ssandraClusterReconciler) SetupWithManager(mgr ctrl.Manager, clusters []cluster.Cluster) error
type SecretSyncController
- func (s *SecretSyncController) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
- func (s *SecretSyncController) SetupWithManager(mgr ctrl.Manager, clusters []cluster.Cluster) error
type StargateReconciler
- func (r *StargateReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
- func (r *StargateReconciler) SetupWithManager(mgr ctrl.Manager) error

Constants ¶

View Source

const (
	RequeueDefaultDelayEnvVar = "REQUEUE_DEFAULT_DELAY"
	RequeueLongDelayEnvVar    = "REQUEUE_LONG_DELAY"
)

View Source

const (

	// OrphanResourceAnnotation when set to true prevents the deletion of secret from target clusters even if matching ReplicatedSecret is removed
	OrphanResourceAnnotation = "replicatedresource.k8ssandra.io/orphan"
)

Variables ¶

This section is empty.

Functions ¶

func InitConfig ¶

func InitConfig()

InitConfig is primarily a hook for integration tests. It provides a way to use shorter requeue delays which allows the tests to run much faster. Note that this code will likely be changed when we tackle https://github.com/k8ssandra/k8ssandra-operator/issues/63.

Types ¶

type K8ssandraClusterReconciler ¶

type K8ssandraClusterReconciler struct {
	client.Client
	Scheme        *runtime.Scheme
	ClientCache   *clientcache.ClientCache
	SeedsResolver cassandra.RemoteSeedsResolver
	ManagementApi cassandra.ManagementApiFactory
}

K8ssandraClusterReconciler reconciles a K8ssandraCluster object

func (*K8ssandraClusterReconciler) Reconcile ¶

func (r *K8ssandraClusterReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*K8ssandraClusterReconciler) SetupWithManager ¶

func (r *K8ssandraClusterReconciler) SetupWithManager(mgr ctrl.Manager, clusters []cluster.Cluster) error

SetupWithManager sets up the controller with the Manager.

type SecretSyncController ¶

type SecretSyncController struct {
	ClientCache *clientcache.ClientCache
	// TODO We need a better structure for empty selectors (match whole kind)
	WatchNamespaces []string
	// contains filtered or unexported fields
}

func (*SecretSyncController) Reconcile ¶

func (s *SecretSyncController) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*SecretSyncController) SetupWithManager ¶

func (s *SecretSyncController) SetupWithManager(mgr ctrl.Manager, clusters []cluster.Cluster) error

type StargateReconciler ¶

type StargateReconciler struct {
	client.Client
	Scheme *runtime.Scheme
}

StargateReconciler reconciles a Stargate object

func (*StargateReconciler) Reconcile ¶

func (r *StargateReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*StargateReconciler) SetupWithManager ¶

func (r *StargateReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

Source Files ¶

View all Source files

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