atlasdatafederation

Documentation

Index

• func AddCredentialsToConnectionURL(connURL, userName, password string) (string, error)
• type AtlasDataFederationReconciler
  • func NewAtlasDataFederationReconciler(c cluster.Cluster, predicates []predicate.Predicate, ...) *AtlasDataFederationReconciler
  • func (r *AtlasDataFederationReconciler) For() (client.Object, builder.Predicates)
  • func (r *AtlasDataFederationReconciler) Reconcile(context context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *AtlasDataFederationReconciler) SetupWithManager(mgr ctrl.Manager, skipNameValidation bool) error
• type PrivateEndpointReconciler
  • func (r *PrivateEndpointReconciler) Reconcile(ctx *workflow.Context) error

Functions

func AddCredentialsToConnectionURL

func AddCredentialsToConnectionURL(connURL, userName, password string) (string, error)

Types

type AtlasDataFederationReconciler

type AtlasDataFederationReconciler struct {
	Client                      client.Client
	Log                         *zap.SugaredLogger
	Scheme                      *runtime.Scheme
	GlobalPredicates            []predicate.Predicate
	EventRecorder               record.EventRecorder
	AtlasProvider               atlas.Provider
	ObjectDeletionProtection    bool
	SubObjectDeletionProtection bool
	GlobalSecretRef             client.ObjectKey
}

AtlasDataFederationReconciler reconciles an DataFederation object

func NewAtlasDataFederationReconciler

func NewAtlasDataFederationReconciler(
	c cluster.Cluster,
	predicates []predicate.Predicate,
	atlasProvider atlas.Provider,
	deletionProtection bool,
	logger *zap.Logger,
	globalSecretRef client.ObjectKey,
) *AtlasDataFederationReconciler

func (*AtlasDataFederationReconciler) For

func (r *AtlasDataFederationReconciler) For() (client.Object, builder.Predicates)

func (*AtlasDataFederationReconciler) Reconcile

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

func (*AtlasDataFederationReconciler) SetupWithManager

func (r *AtlasDataFederationReconciler) SetupWithManager(mgr ctrl.Manager, skipNameValidation bool) error

type PrivateEndpointReconciler

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

func (*PrivateEndpointReconciler) Reconcile

func (r *PrivateEndpointReconciler) Reconcile(ctx *workflow.Context) error