controller

Documentation

Index

• type SubscriptionReconciler
  • func (r *SubscriptionReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *SubscriptionReconciler) SetupWithManager(mgr ctrl.Manager) error
• type TopicReconciler
  • func (r *TopicReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *TopicReconciler) SetupWithManager(mgr ctrl.Manager) error

Types

type SubscriptionReconciler

type SubscriptionReconciler struct {
	crclient.Client
	Scheme    *runtime.Scheme
	NewClient newPubSubClientFunc
	Recorder  record.EventRecorder
	Clock     clock.PassiveClock
}

SubscriptionReconciler reconciles a Subscription object

func (*SubscriptionReconciler) Reconcile

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

func (*SubscriptionReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

type TopicReconciler

type TopicReconciler struct {
	crclient.Client
	Scheme    *runtime.Scheme
	NewClient newPubSubClientFunc
	Recorder  record.EventRecorder
	Clock     clock.PassiveClock
}

TopicReconciler reconciles a Topic object

func (*TopicReconciler) Reconcile

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

func (*TopicReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.