nats

Documentation

Index

• Constants
• type Reconciler
  • func NewReconciler(client client.Client, kubeClient k8s.Client, chartRenderer chart.Renderer, ...) *Reconciler
  • func (r *Reconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *Reconciler) SetupWithManager(mgr ctrl.Manager) error

Constants

const (
	NATSFinalizerName   = "nats.operator.kyma-project.io/finalizer"
	ControllerName      = "nats-manager"
	ManagedByLabelKey   = "app.kubernetes.io/managed-by"
	ManagedByLabelValue = ControllerName
)

const (
	StreamExistsErrorMsg   = "Cannot delete NATS cluster as customer stream exists"
	ConsumerExistsErrorMsg = "Cannot delete NATS cluster as stream consumer exists"

	InstanceLabelKey = "app.kubernetes.io/instance"
	SapStreamName    = "sap"
)

const RequeueTimeForStatusCheck = 10

Types

type Reconciler

type Reconciler struct {
	client.Client
	// contains filtered or unexported fields
}

Reconciler reconciles a Nats object.

func NewReconciler

func NewReconciler(
	client client.Client,
	kubeClient k8s.Client,
	chartRenderer chart.Renderer,
	scheme *runtime.Scheme,
	logger *zap.SugaredLogger,
	recorder record.EventRecorder,
	natsManager manager.Manager,
	allowedNATSCR *natsv1alpha1.NATS,
) *Reconciler

func (*Reconciler) Reconcile

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

func (*Reconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.