controller

package
v0.7.2 Latest Latest
Warning

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

 Go to latest Published: Jun 29, 2026 License: Apache-2.0 Imports: 34 Imported by: 0

Documentation

Index

Constants

View Source 
const GroupNameInline = "inline"

Variables

This section is empty.

Functions

This section is empty.

Types

type AccountExportReconciler added in v0.7.0 

type AccountExportReconciler struct {
	Scheme *runtime.Scheme
	// contains filtered or unexported fields
}

AccountExportReconciler reconciles an AccountExport object.

func NewAccountExportReconciler added in v0.7.0 

func NewAccountExportReconciler(k8sClient client.Client, scheme *runtime.Scheme, manager inbound.AccountExportManager) *AccountExportReconciler

func (*AccountExportReconciler) Reconcile added in v0.7.0 

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

func (*AccountExportReconciler) SetupWithManager added in v0.7.0 

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

type AccountImportReconciler added in v0.7.0 

type AccountImportReconciler struct {
	Scheme *runtime.Scheme
	// contains filtered or unexported fields
}

AccountImportReconciler reconciles an AccountImport object.

func NewAccountImportReconciler added in v0.7.0 

func NewAccountImportReconciler(k8sClient client.Client, scheme *runtime.Scheme, manager inbound.AccountImportManager) *AccountImportReconciler

func (*AccountImportReconciler) Reconcile added in v0.7.0 

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

func (*AccountImportReconciler) SetupWithManager added in v0.7.0 

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

type AccountReconciler 

type AccountReconciler struct {
	Scheme *runtime.Scheme
	// contains filtered or unexported fields
}

AccountReconciler reconciles an Account object

func NewAccountReconciler 

func NewAccountReconciler(
	k8sClient client.Client,
	scheme *runtime.Scheme,
	manager inbound.AccountManager,
	clusterManager inbound.ClusterManager,
	accountReader k8s.AccountReader,
	recorder events.EventRecorder,
) *AccountReconciler

func (*AccountReconciler) Reconcile 

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

Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state.

For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.20.4/pkg/reconcile

func (*AccountReconciler) SetupWithManager 

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

SetupWithManager sets up the controller with the Manager.

type AccountSigningKeyReconciler added in v0.7.2 

type AccountSigningKeyReconciler struct {
	client.Client
	Scheme *runtime.Scheme
	// contains filtered or unexported fields
}

AccountSigningKeyReconciler reconciles AccountSigningKey resources.

func NewAccountSigningKeyReconciler added in v0.7.2 

func NewAccountSigningKeyReconciler(k8sClient client.Client, scheme *runtime.Scheme, manager inbound.AccountSigningKeyManager) *AccountSigningKeyReconciler

func (*AccountSigningKeyReconciler) Reconcile added in v0.7.2 

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

func (*AccountSigningKeyReconciler) SetupWithManager added in v0.7.2 

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

SetupWithManager registers the controller and its predicates with the manager.

type ClusterResolver added in v0.7.0 

type ClusterResolver interface {
	ResolveClusterTarget(ctx context.Context, cluster *v1alpha1.NatsCluster) (*nauth.ClusterTarget, error)
}

type NatsClusterReconciler 

type NatsClusterReconciler struct {
	client.Client
	Scheme *runtime.Scheme
	// contains filtered or unexported fields
}

func NewNatsClusterReconciler 

func NewNatsClusterReconciler(
	k8sClient client.Client,
	scheme *runtime.Scheme,
	manager inbound.ClusterManager,
	resolver ClusterResolver,
	recorder events.EventRecorder,
) *NatsClusterReconciler

func (*NatsClusterReconciler) Reconcile 

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

func (*NatsClusterReconciler) SetupWithManager 

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

type Object 

type Object interface {
	metav1.Object
	runtime.Object
	GetConditions() *[]metav1.Condition
}

type ResolveAccountIDFn added in v0.7.0 

type ResolveAccountIDFn func(accountRef domain.NamespacedName) (accountID nauth.AccountID, err error)

type UserReconciler 

type UserReconciler struct {
	client.Client
	Scheme *runtime.Scheme
	// contains filtered or unexported fields
}

UserReconciler reconciles a User object

func NewUserReconciler 

func NewUserReconciler(k8sClient client.Client, scheme *runtime.Scheme, manager inbound.UserManager, recorder events.EventRecorder) *UserReconciler

func (*UserReconciler) Reconcile 

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

Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state.

For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.20.4/pkg/reconcile

func (*UserReconciler) SetupWithManager 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.