pullsubscription

package
v0.23.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 25, 2021 License: Apache-2.0 Imports: 27 Imported by: 2

Documentation

Overview

Package pullsubscription implements the Pub/Sub PullSubscription controllers.

Index

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 (r *Base) UpdateFromLoggingConfigMap(cfg *corev1.ConfigMap)

func (*Base) UpdateFromMetricsConfigMap

func (r *Base) UpdateFromMetricsConfigMap(cfg *corev1.ConfigMap)

func (*Base) UpdateFromTracingConfigMap

func (r *Base) UpdateFromTracingConfigMap(cfg *corev1.ConfigMap)

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL