jetstream

Documentation

Index

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

Types

type Reconciler

type Reconciler struct {
	client.Client

	Backend jetstream.Backend
	// contains filtered or unexported fields
}

func NewReconciler

func NewReconciler(ctx context.Context, client client.Client, jsBackend jetstream.Backend,
	logger *logger.Logger, recorder record.EventRecorder, cleaner cleaner.Cleaner,
	defaultSinkValidator sink.Validator, 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 ctrl.Request) (ctrl.Result, error)

func (*Reconciler) SetupUnmanaged

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

SetupUnmanaged creates a controller under the client control.