reconciler

Documentation

Index

• Variables
• func GetConnectionConfig(ctx context.Context, k8sClient client.Client, ...) (*atlas.ConnectionConfig, error)
• type AtlasReconciler
  • func (r *AtlasReconciler) Invalidate(typeName string, invalid workflow.Result) (ctrl.Result, error)
  • func (r *AtlasReconciler) ResolveConnectionConfig(ctx context.Context, referrer project.ProjectReferrerObject) (*atlas.ConnectionConfig, error)
  • func (r *AtlasReconciler) ResolveProject(ctx context.Context, sdkClient *admin.APIClient, ...) (*project.Project, error)
  • func (r *AtlasReconciler) Skip(ctx context.Context, typeName string, resource api.AtlasCustomResource, ...) (ctrl.Result, error)
  • func (r *AtlasReconciler) Unsupport(ctx *workflow.Context, typeName string) (ctrl.Result, error)

Variables

var (
	ErrMissingKubeProject = errors.New("missing Kubernetes Atlas Project")
)

Functions

func GetConnectionConfig

func GetConnectionConfig(ctx context.Context, k8sClient client.Client, secretRef, fallbackRef *client.ObjectKey) (*atlas.ConnectionConfig, error)

Types

type AtlasReconciler

type AtlasReconciler struct {
	Client          client.Client
	Log             *zap.SugaredLogger
	GlobalSecretRef client.ObjectKey
}

func (*AtlasReconciler) Invalidate

func (r *AtlasReconciler) Invalidate(typeName string, invalid workflow.Result) (ctrl.Result, error)

func (*AtlasReconciler) ResolveConnectionConfig

func (r *AtlasReconciler) ResolveConnectionConfig(ctx context.Context, referrer project.ProjectReferrerObject) (*atlas.ConnectionConfig, error)

func (*AtlasReconciler) ResolveProject

func (r *AtlasReconciler) ResolveProject(ctx context.Context, sdkClient *admin.APIClient, pro project.ProjectReferrerObject) (*project.Project, error)

func (*AtlasReconciler) Skip

func (r *AtlasReconciler) Skip(ctx context.Context, typeName string, resource api.AtlasCustomResource, spec any) (ctrl.Result, error)

func (*AtlasReconciler) Unsupport

func (r *AtlasReconciler) Unsupport(ctx *workflow.Context, typeName string) (ctrl.Result, error)