Documentation
¶
Overview ¶
Package pullsubscription implements the Pub/Sub PullSubscription controllers.
Index ¶
- type Base
- func (r *Base) FinalizeKind(ctx context.Context, ps *v1.PullSubscription) pkgreconciler.Event
- func (r *Base) GetOrCreateReceiveAdapter(ctx context.Context, desired *appsv1.Deployment, ps *v1.PullSubscription) (*appsv1.Deployment, error)
- func (r *Base) ReconcileKind(ctx context.Context, ps *v1.PullSubscription) pkgreconciler.Event
- func (r *Base) UpdateFromLoggingConfigMap(cfg *corev1.ConfigMap)
- func (r *Base) UpdateFromMetricsConfigMap(cfg *corev1.ConfigMap)
- func (r *Base) UpdateFromTracingConfigMap(cfg *corev1.ConfigMap)
- type ReconcileDataPlaneFunc
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Base ¶
type Base struct { *reconciler.Base // identity reconciler for reconciling workload identity. *identity.Identity // DeploymentLister index properties about deployments. DeploymentLister appsv1listers.DeploymentLister // PullSubscriptionLister index properties about pullsubscriptions. PullSubscriptionLister listers.PullSubscriptionLister // serviceAccountLister for reading serviceAccounts. ServiceAccountLister corev1listers.ServiceAccountLister UriResolver *resolver.URIResolver ReceiveAdapterImage string ControllerAgentName string ResourceGroup string LoggingConfig *logging.Config MetricsConfig *metrics.ExporterOptions TracingConfig *tracingconfig.Config // CreateClientFn is the function used to create the Pub/Sub client that interacts with Pub/Sub. // This is needed so that we can inject a mock client for UTs purposes. CreateClientFn reconcilerutilspubsub.CreateFn // ReconcileDataPlaneFn is the function used to reconcile the data plane resources. ReconcileDataPlaneFn ReconcileDataPlaneFunc }
Base implements the core controller logic for pullsubscription.
func (*Base) FinalizeKind ¶
func (r *Base) FinalizeKind(ctx context.Context, ps *v1.PullSubscription) pkgreconciler.Event
func (*Base) GetOrCreateReceiveAdapter ¶
func (r *Base) GetOrCreateReceiveAdapter(ctx context.Context, desired *appsv1.Deployment, ps *v1.PullSubscription) (*appsv1.Deployment, error)
func (*Base) ReconcileKind ¶
func (r *Base) ReconcileKind(ctx context.Context, ps *v1.PullSubscription) pkgreconciler.Event
func (*Base) UpdateFromLoggingConfigMap ¶
func (*Base) UpdateFromMetricsConfigMap ¶
func (*Base) UpdateFromTracingConfigMap ¶
type ReconcileDataPlaneFunc ¶
type ReconcileDataPlaneFunc func(ctx context.Context, d *appsv1.Deployment, ps *v1.PullSubscription) error
ReconcileDataPlaneFunc is used to reconcile the data plane component(s).
Directories
¶
Path | Synopsis |
---|---|
Package keda implements the Pub/Sub PullSubscription controller for Keda-based PullSubscriptions.
|
Package keda implements the Pub/Sub PullSubscription controller for Keda-based PullSubscriptions. |
Package static implements the Pub/Sub PullSubscription controller for non-scalable PullSubscriptions.
|
Package static implements the Pub/Sub PullSubscription controller for non-scalable PullSubscriptions. |
Click to show internal directories.
Click to hide internal directories.