clusteraccess

package

v0.2.1 Latest Latest Go to latest Published: Oct 23, 2025 License: Apache-2.0 Imports: 20 Imported by: 0

Documentation ¶

Index ¶

Variables
func BuildTargetClusterConfigFromTyped(ctx context.Context, clusterAccess v1alpha1.ClusterAccess, ...) (*rest.Config, string, error)
func NewClusterAccessReconciler(ctx context.Context, appCfg config.Config, opts reconciler.ReconcilerOpts, ...) (reconciler.CustomReconciler, error)
func NewGenerateSchemaSubroutineForTesting(reconciler *ClusterAccessReconciler) *generateSchemaSubroutine
func NewReconciler(opts reconciler.ReconcilerOpts, ioHandler workspacefile.IOHandler, ...) (reconciler.CustomReconciler, error)
type CRDStatus
- func CheckClusterAccessCRDStatus(ctx context.Context, k8sClient client.Client, log *logger.Logger) (CRDStatus, error)
type ClusterAccessReconciler

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	ErrCRDNotRegistered = errors.New("ClusterAccess CRD not registered")
	ErrCRDCheckFailed   = errors.New("failed to check ClusterAccess CRD status")
)

Functions ¶

func BuildTargetClusterConfigFromTyped ¶

func BuildTargetClusterConfigFromTyped(ctx context.Context, clusterAccess v1alpha1.ClusterAccess, k8sClient client.Client) (*rest.Config, string, error)

BuildTargetClusterConfigFromTyped extracts connection info from ClusterAccess and builds rest.Config

func NewClusterAccessReconciler ¶

func NewClusterAccessReconciler(
	ctx context.Context,
	appCfg config.Config,
	opts reconciler.ReconcilerOpts,
	ioHandler workspacefile.IOHandler,
	schemaResolver apischema.Resolver,
	log *logger.Logger,
) (reconciler.CustomReconciler, error)

func NewGenerateSchemaSubroutineForTesting ¶

func NewGenerateSchemaSubroutineForTesting(reconciler *ClusterAccessReconciler) *generateSchemaSubroutine

NewGenerateSchemaSubroutineForTesting creates a generateSchemaSubroutine for testing

func NewReconciler ¶

func NewReconciler(
	opts reconciler.ReconcilerOpts,
	ioHandler workspacefile.IOHandler,
	schemaResolver apischema.Resolver,
	log *logger.Logger,
) (reconciler.CustomReconciler, error)

Types ¶

type CRDStatus ¶

type CRDStatus int

const (
	CRDNotRegistered CRDStatus = iota
	CRDRegistered
)

func CheckClusterAccessCRDStatus ¶

func CheckClusterAccessCRDStatus(ctx context.Context, k8sClient client.Client, log *logger.Logger) (CRDStatus, error)

CheckClusterAccessCRDStatus checks the availability and usage of ClusterAccess CRD

type ClusterAccessReconciler ¶

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

ClusterAccessReconciler handles reconciliation for ClusterAccess resources

func (*ClusterAccessReconciler) GetManager ¶

func (r *ClusterAccessReconciler) GetManager() ctrl.Manager

func (*ClusterAccessReconciler) Reconcile ¶

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

func (*ClusterAccessReconciler) SetupWithManager ¶

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

Source Files ¶

View all Source files

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