jetstream

Documentation

Index

• type Reconciler
  • func NewReconciler(client client.Client, jsBackend jetstream.Backend, logger *logger.Logger, ...) *Reconciler
  • func (r *Reconciler) HandleNatsConnClose(_ *nats.Conn)
  • func (r *Reconciler) Reconcile(ctx context.Context, req kctrl.Request) (kctrl.Result, error)
  • func (r *Reconciler) SetupUnmanaged(ctx context.Context, mgr kctrl.Manager) error

Types

type Reconciler

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

func NewReconciler

func NewReconciler(client client.Client, jsBackend jetstream.Backend,
	logger *logger.Logger, recorder record.EventRecorder, cleaner cleaner.Cleaner,
	subscriptionValidator validator.SubscriptionValidator, collector *metrics.Collector,
) *Reconciler

func (*Reconciler) HandleNatsConnClose

func (r *Reconciler) HandleNatsConnClose(_ *nats.Conn)

HandleNatsConnClose is called by NATS when the connection to the NATS server is closed. When it is called, the reconnect-attempts have exceeded the defined value. It forces reconciling the subscription to make sure the subscription is marked as not ready, until it is possible to connect to the NATS server again.

func (*Reconciler) Reconcile

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

func (*Reconciler) SetupUnmanaged

func (r *Reconciler) SetupUnmanaged(ctx context.Context, mgr kctrl.Manager) error

SetupUnmanaged creates a controller under the client control.