controllers

package
v0.9.5 Latest Latest
Warning

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

 Go to latest Published: Feb 24, 2025 License: Apache-2.0 Imports: 28 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	EventReasonAccountSucceed           = "AccountSucceed"
	EventReasonAccountFailed            = "AccountFailed"
	EventReasonAccountSychronized       = "AccountSychronized"
	EventReasonAccountSychronizedFailed = "AccountSychronizedFailed"
)
View Source 
const (
	EventReasonGatewaySucceeded    = "GatewaySucceeded"
	EventReasonGatewaySynchronized = "GatewaySynchronized"
	EventReasonGatewayFailed       = "GatewayFailed"
)
View Source 
const ACCOUNT_TEMPLATE = `` /* 129-byte string literal not displayed */
View Source 
const (
	EventRecorderLabel = "natz-controller"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type EventReason added in v0.9.0 

type EventReason string
const (
	EventReasonAccountSecretCreateSucceeded EventReason = "AccountSecretCreateSucceeded"
	EventReasonAccountSecretCreateFailed    EventReason = "AccountSecretCreateFailed"
	EventReasonAccountAccessGranted         EventReason = "AccountAccessGranted"
	EventReasonAccountAccessDeleted         EventReason = "AccountAccessDeleted"
	EventReasonAccountAccessFailed          EventReason = "AccountAccessFailed"
)
const (
	EventReasonActivationSynchronized EventReason = "ActivationSyncronized"
	EventReasonActivationFailed       EventReason = "ActivationFailed"
)
const (
	EventReasonConfigSynchronizeFailed EventReason = "ConfigSynchronizeFailed"
	EventReasonConfigSynchronized      EventReason = "ConfigSynchronized"
)
const (
	EventReasonKeyFailed       EventReason = "Failed"
	EventReasonKeySynchronized EventReason = "Synchronized"
	EventReasonStatusPaused    EventReason = "Paused"
)
const (
	EventReasonOperatorCreateFailed          EventReason = "OperatorCreateFailed"
	EventReasonOperatorUpdateFailed          EventReason = "OperatorUpdateFailed"
	EventReasonOperatorDeleteFailed          EventReason = "OperatorDeleteFailed"
	EventReasonOperatorSecretCreateSucceeded EventReason = "OperatorSecretCreateSucceeded"
	EventReasonOperatorSecretCreateFailed    EventReason = "OperatorSecretCreateFailed"
	EventReasonOperatorSynchronized          EventReason = "OperatorSynchronized"
	EventReasonOperatorFailed                EventReason = "OperatorFailed"
	EventReasonOperatorSynchronizeFailed     EventReason = "OperatorSynchronizeFailed"
)
const (
	EventReasonUserSecretCreateSucceeded EventReason = "UserSecretCreateSucceeded"
	EventReasonUserSecretCreateFailed    EventReason = "UserSecretCreateFailed"
	EventReasonUserSynchronizeFailed     EventReason = "UserSynchronizeFailed"
	EventReasonUserSynchronized          EventReason = "UserSynchronized"
)

type NatsAccountReconciler 

type NatsAccountReconciler struct {
	client.Client
	Scheme   *runtime.Scheme
	Recorder record.EventRecorder
}

NatsAccountReconciler ...

func NewNatsAccountReconciler 

func NewNatsAccountReconciler(mgr ctrl.Manager) *NatsAccountReconciler

NewNatsAccountReconciler ...

func (*NatsAccountReconciler) IsCreating added in v0.9.3 

func (r *NatsAccountReconciler) IsCreating(obj *natsv1alpha1.NatsAccount) bool

IsCreating ...

func (*NatsAccountReconciler) IsSynchronized added in v0.9.3 

func (r *NatsAccountReconciler) IsSynchronized(obj *natsv1alpha1.NatsAccount) bool

IsSynchronized ...

func (*NatsAccountReconciler) ManageError added in v0.9.3 

func (r *NatsAccountReconciler) ManageError(ctx context.Context, obj *natsv1alpha1.NatsAccount, err error) (ctrl.Result, error)

ManageError ...

func (*NatsAccountReconciler) ManageSuccess added in v0.9.3 

func (r *NatsAccountReconciler) ManageSuccess(ctx context.Context, obj *natsv1alpha1.NatsAccount) (ctrl.Result, error)

ManageSuccess ...

func (*NatsAccountReconciler) Reconcile 

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

Reconcile ... nolint:gocyclo

func (*NatsAccountReconciler) SetupWithManager 

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

SetupWithManager sets up the controller with the Manager.

type NatsAccountServer added in v0.0.3 

type NatsAccountServer struct {
	client.Client
	Scheme *runtime.Scheme

	Recorder record.EventRecorder
	// contains filtered or unexported fields
}

NatsAccountServer takes NatsAccount and serves them to a nats server (cluster)

func NewNatsAccountServer added in v0.0.3 

func NewNatsAccountServer(mgr ctrl.Manager, nc *nats.Conn) *NatsAccountServer

NewNatsAccountServer ...

func (*NatsAccountServer) GetJWT added in v0.0.6 

func (r *NatsAccountServer) GetJWT(publicKey string) (string, bool)

GetJWT ...

func (*NatsAccountServer) IsCreating added in v0.9.3 

func (r *NatsAccountServer) IsCreating(obj *natsv1alpha1.NatsAccount) bool

IsCreating ...

func (*NatsAccountServer) IsSynchronized added in v0.9.3 

func (r *NatsAccountServer) IsSynchronized(obj *natsv1alpha1.NatsAccount) bool

IsSynchronized ...

func (*NatsAccountServer) ManageError added in v0.9.3 

func (r *NatsAccountServer) ManageError(ctx context.Context, obj *natsv1alpha1.NatsAccount, err error) (ctrl.Result, error)

ManageError ...

func (*NatsAccountServer) ManageSuccess added in v0.9.3 

func (r *NatsAccountServer) ManageSuccess(ctx context.Context, obj *natsv1alpha1.NatsAccount) (ctrl.Result, error)

ManageSuccess ...

func (*NatsAccountServer) Reconcile added in v0.0.3 

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

Reconcile ...

func (*NatsAccountServer) SetupWithManager added in v0.0.3 

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

SetupWithManager sets up the controller with the Manager.

type NatsActivationReconciler added in v0.9.3 

type NatsActivationReconciler struct {
	client.Client
	Scheme   *runtime.Scheme
	Recorder record.EventRecorder
}

NatsActivationReconciler ...

func NewNatsActivationReconciler added in v0.9.3 

func NewNatsActivationReconciler(mgr ctrl.Manager) *NatsActivationReconciler

NewNatsActivationReconciler ...

func (*NatsActivationReconciler) IsCreating added in v0.9.3 

func (r *NatsActivationReconciler) IsCreating(obj *natsv1alpha1.NatsActivation) bool

IsCreating ...

func (*NatsActivationReconciler) IsSynchronized added in v0.9.3 

func (r *NatsActivationReconciler) IsSynchronized(obj *natsv1alpha1.NatsActivation) bool

IsSynchronized ...

func (*NatsActivationReconciler) ManageError added in v0.9.3 

func (r *NatsActivationReconciler) ManageError(ctx context.Context, obj *natsv1alpha1.NatsActivation, err error) (ctrl.Result, error)

ManageError ...

func (*NatsActivationReconciler) ManageSuccess added in v0.9.3 

func (r *NatsActivationReconciler) ManageSuccess(ctx context.Context, obj *natsv1alpha1.NatsActivation) (ctrl.Result, error)

ManageSuccess ...

func (*NatsActivationReconciler) Reconcile added in v0.9.3 

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

Reconcile ... nolint:gocyclo

func (*NatsActivationReconciler) SetupWithManager added in v0.9.3 

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

SetupWithManager sets up the controller with the Manager.

type NatsConfigReconciler added in v0.9.3 

type NatsConfigReconciler struct {
	client.Client
	Scheme   *runtime.Scheme
	Recorder record.EventRecorder
}

NatsConfigReconciler reconciles a Natsconfig object

func NewNatsConfigReconciler added in v0.9.3 

func NewNatsConfigReconciler(mgr ctrl.Manager) *NatsConfigReconciler

NewNatsConfigReconciler ...

func (*NatsConfigReconciler) IsCreating added in v0.9.3 

func (r *NatsConfigReconciler) IsCreating(obj *natsv1alpha1.NatsConfig) bool

IsCreating ...

func (*NatsConfigReconciler) IsSynchronized added in v0.9.3 

func (r *NatsConfigReconciler) IsSynchronized(obj *natsv1alpha1.NatsConfig) bool

IsSynchronized ...

func (*NatsConfigReconciler) ManageError added in v0.9.3 

func (r *NatsConfigReconciler) ManageError(ctx context.Context, obj *natsv1alpha1.NatsConfig, err error) (ctrl.Result, error)

ManageError ...

func (*NatsConfigReconciler) ManageSuccess added in v0.9.3 

func (r *NatsConfigReconciler) ManageSuccess(ctx context.Context, obj *natsv1alpha1.NatsConfig) (ctrl.Result, error)

ManageSuccess ...

func (*NatsConfigReconciler) Reconcile added in v0.9.3 

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

Reconcile ...

func (*NatsConfigReconciler) SetupWithManager added in v0.9.3 

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

SetupWithManager sets up the controller with the Manager.

type NatsGatewayReconciler added in v0.9.1 

type NatsGatewayReconciler struct {
	client.Client
	Scheme   *runtime.Scheme
	Recorder record.EventRecorder
}

NatsGatewayReconciler ...

func NewNatsGatewayReconciler added in v0.9.1 

func NewNatsGatewayReconciler(mgr ctrl.Manager) *NatsGatewayReconciler

NewNatsGatewayReconciler ...

func (*NatsGatewayReconciler) IsCreating added in v0.9.3 

func (r *NatsGatewayReconciler) IsCreating(obj *natsv1alpha1.NatsGateway) bool

IsCreating ...

func (*NatsGatewayReconciler) IsSynchronized added in v0.9.3 

func (r *NatsGatewayReconciler) IsSynchronized(obj *natsv1alpha1.NatsGateway) bool

IsSynchronized ...

func (*NatsGatewayReconciler) ManageError added in v0.9.3 

func (r *NatsGatewayReconciler) ManageError(ctx context.Context, obj *natsv1alpha1.NatsGateway, err error) (ctrl.Result, error)

ManageError ...

func (*NatsGatewayReconciler) ManageSuccess added in v0.9.3 

func (r *NatsGatewayReconciler) ManageSuccess(ctx context.Context, obj *natsv1alpha1.NatsGateway) (ctrl.Result, error)

ManageSuccess ...

func (*NatsGatewayReconciler) Reconcile added in v0.9.1 

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

Reconcile ...

func (*NatsGatewayReconciler) SetupWithManager added in v0.9.1 

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

SetupWithManager sets up the controller with the Manager.

type NatsOperatorReconciler 

type NatsOperatorReconciler struct {
	client.Client
	Scheme   *runtime.Scheme
	Recorder record.EventRecorder
}

NatsOperatorReconciler ...

func NewNatsOperatorReconciler 

func NewNatsOperatorReconciler(mgr ctrl.Manager) *NatsOperatorReconciler

NewNatsOperatorReconciler ...

func (*NatsOperatorReconciler) IsControlPaused added in v0.9.3 

func (r *NatsOperatorReconciler) IsControlPaused(obj *natsv1alpha1.NatsOperator) bool

IsControlPaused ...

func (*NatsOperatorReconciler) IsCreating added in v0.9.3 

func (r *NatsOperatorReconciler) IsCreating(obj *natsv1alpha1.NatsOperator) bool

IsCreating ...

func (*NatsOperatorReconciler) IsPaused added in v0.9.3 

func (r *NatsOperatorReconciler) IsPaused(obj *natsv1alpha1.NatsOperator) bool

IsPaused ...

func (*NatsOperatorReconciler) IsSynchronized added in v0.9.3 

func (r *NatsOperatorReconciler) IsSynchronized(obj *natsv1alpha1.NatsOperator) bool

IsSynchronized ...

func (*NatsOperatorReconciler) ManageError added in v0.9.3 

func (r *NatsOperatorReconciler) ManageError(ctx context.Context, obj *natsv1alpha1.NatsOperator, err error) (ctrl.Result, error)

ManageError ...

func (*NatsOperatorReconciler) ManageSuccess added in v0.9.3 

func (r *NatsOperatorReconciler) ManageSuccess(ctx context.Context, obj *natsv1alpha1.NatsOperator) (ctrl.Result, error)

ManageSuccess ...

func (*NatsOperatorReconciler) Reconcile 

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

Reconcile ... nolint:gocyclo

func (*NatsOperatorReconciler) SetupWithManager 

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

SetupWithManager sets up the controller with the Manager.

type NatsPrivateKeyReconciler added in v0.9.3 

type NatsPrivateKeyReconciler struct {
	client.Client
	Scheme   *runtime.Scheme
	Recorder record.EventRecorder
}

NatsPrivateKeyReconciler ...

func NewNatsKeyReconciler added in v0.9.3 

func NewNatsKeyReconciler(mgr ctrl.Manager) *NatsPrivateKeyReconciler

NewNatsKeyReconciler ...

func (*NatsPrivateKeyReconciler) IsControlPaused added in v0.9.3 

func (r *NatsPrivateKeyReconciler) IsControlPaused(obj *natsv1alpha1.NatsKey) bool

IsControlPaused ...

func (*NatsPrivateKeyReconciler) IsCreating added in v0.9.3 

func (r *NatsPrivateKeyReconciler) IsCreating(obj *natsv1alpha1.NatsKey) bool

IsCreating ...

func (*NatsPrivateKeyReconciler) IsSynchronized added in v0.9.3 

func (r *NatsPrivateKeyReconciler) IsSynchronized(obj *natsv1alpha1.NatsKey) bool

IsSynchronized ...

func (*NatsPrivateKeyReconciler) ManageError added in v0.9.3 

func (r *NatsPrivateKeyReconciler) ManageError(ctx context.Context, obj *natsv1alpha1.NatsKey, err error) (ctrl.Result, error)

ManageError ...

func (*NatsPrivateKeyReconciler) ManageSuccess added in v0.9.3 

func (r *NatsPrivateKeyReconciler) ManageSuccess(ctx context.Context, obj *natsv1alpha1.NatsKey) (ctrl.Result, error)

ManageSuccess ...

func (*NatsPrivateKeyReconciler) Reconcile added in v0.9.3 

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

Reconcile is the main reconciliation loop for the operator. nolint:gocyclo

func (*NatsPrivateKeyReconciler) SetupWithManager added in v0.9.3 

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

SetupWithManager sets up the controller with the Manager.

type NatsUserReconciler 

type NatsUserReconciler struct {
	client.Client
	Scheme   *runtime.Scheme
	Recorder record.EventRecorder
}

NatsUserReconciler reconciles a NatsUser object

func NewNatsUserReconciler 

func NewNatsUserReconciler(mgr ctrl.Manager) *NatsUserReconciler

NewNatsUserReconciler ...

func (*NatsUserReconciler) IsCreating added in v0.9.3 

func (r *NatsUserReconciler) IsCreating(obj *natsv1alpha1.NatsUser) bool

IsCreating ...

func (*NatsUserReconciler) IsSynchronized added in v0.9.3 

func (r *NatsUserReconciler) IsSynchronized(obj *natsv1alpha1.NatsUser) bool

IsSynchronized ...

func (*NatsUserReconciler) ManageError added in v0.9.3 

func (r *NatsUserReconciler) ManageError(ctx context.Context, obj *natsv1alpha1.NatsUser, err error) (ctrl.Result, error)

ManageError ...

func (*NatsUserReconciler) ManageSuccess added in v0.9.3 

func (r *NatsUserReconciler) ManageSuccess(ctx context.Context, obj *natsv1alpha1.NatsUser) (ctrl.Result, error)

ManageSuccess ...

func (*NatsUserReconciler) Reconcile 

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

Reconcile ...

func (*NatsUserReconciler) SetupWithManager 

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

SetupWithManager sets up the controller with the Manager.

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.