common

Documentation

Index

• Constants
• func AppAnnotationValue(or kmeta.OwnerRefable) string
• func GetBrokerConfigMapName(b eventingv1alpha1.ReconcilableBroker) string
• type BrokerReconciler
  • func NewBrokerReconciler(ctx context.Context, deploymentLister appsv1listers.DeploymentLister, ...) BrokerReconciler
• type ConfigMapReconciler
  • func NewConfigMapReconciler(ctx context.Context, configMapLister corev1listers.ConfigMapLister) ConfigMapReconciler
• type SecretReconciler
  • func NewSecretReconciler(ctx context.Context, secretLister corev1listers.SecretLister, ...) SecretReconciler
• type ServiceAccountReconciler
  • func NewServiceAccountReconciler(ctx context.Context, serviceAccountLister corev1listers.ServiceAccountLister, ...) ServiceAccountReconciler

Constants

const (
	ReasonDeploymentCreate       = "CreateDeployment"
	ReasonDeploymentUpdate       = "UpdateDeployment"
	ReasonFailedDeploymentGet    = "FailedDeploymentGet"
	ReasonFailedDeploymentCreate = "FailedDeploymentCreate"
	ReasonFailedDeploymentUpdate = "FailedDeploymentUpdate"

	ReasonFailedSecretCompose = "FailedSecretCompose"
	ReasonFailedSecretGet     = "FailedSecretGet"
	ReasonFailedSecretCreate  = "FailedSecretCreate"
	ReasonFailedSecretUpdate  = "FailedSecretUpdate"

	ReasonStatusConfigMapGetFailed    = "FailedConfigMapGet"
	ReasonStatusConfigMapDoesNotExist = "FailedConfigMapDoesNotExist"
	ReasonStatusConfigMapCreateFailed = "FailedConfigMapCreate"
	ReasonStatusConfigMapReadFailed   = "FailedConfigMapRead"
	ReasonStatusSubscriptionFailed    = "SubscriptionFailed"
	ReasonStatusSubscriptionCompleted = "SubscriptionCompleted"
	ReasonStatusSubscriptionUnknown   = "SubscriptionUnknown"
	ReasonStatusSubscriptionReady     = "SubscriptionReady"
	ReasonStatusSubscriptionRunning   = "SubscriptionRunning"

	ReasonFailedServiceAccountGet    = "FailedServiceAccountGet"
	ReasonFailedServiceAccountCreate = "FailedServiceAccountCreate"
	ReasonFailedRoleBindingGet       = "FailedRoleBindingGet"
	ReasonFailedRoleBindingCreate    = "FailedRoleBindingCreate"

	ReasonServiceCreate       = "CreateService"
	ReasonServiceUpdate       = "UpdateService"
	ReasonFailedServiceGet    = "FailedServiceGet"
	ReasonFailedServiceCreate = "FailedServiceCreate"
	ReasonFailedServiceUpdate = "FailedServiceUpdate"

	ReasonFailedTriggerList     = "FailedTriggerList"
	ReasonFailedConfigSerialize = "FailedConfigSerialize"

	ReasonUnavailableEndpoints = "UnavailableEndpoints"
	ReasonFailedEndpointsGet   = "FailedEndpointsGet"

	ReasonBrokerDoesNotExist = "BrokerDoesNotExist"
	ReasonFailedBrokerGet    = "FailedBrokerGet"

	ReasonFailedResolveReference = "FailedResolveReference"
)

Reasons for API Events

const (
	// Broker ClusterRole that was created as part of Typhoon core installation.
	BrokerDeploymentRole = "typhoon-broker"
)

const (

	// Name of the status key inside the Status ConfigMap
	ConfigMapStatusKey = "status"
)

const (
	ConfigSecretKey = "config"
)

Functions

func AppAnnotationValue

func AppAnnotationValue(or kmeta.OwnerRefable) string

func GetBrokerConfigMapName

func GetBrokerConfigMapName(b eventingv1alpha1.ReconcilableBroker) string

Types

type BrokerReconciler

type BrokerReconciler interface {
	Reconcile(ctx context.Context, rb eventingv1alpha1.ReconcilableBroker, sa *corev1.ServiceAccount, secret *corev1.Secret, configMap *corev1.ConfigMap, do ...resource.ObjectOption) (*appsv1.Deployment, *corev1.Service, error)
}

func NewBrokerReconciler

func NewBrokerReconciler(ctx context.Context,
	deploymentLister appsv1listers.DeploymentLister,
	serviceLister corev1listers.ServiceLister,
	endpointsLister corev1listers.EndpointsLister,
	image string,
	pullPolicy corev1.PullPolicy,
) BrokerReconciler

type ConfigMapReconciler

type ConfigMapReconciler interface {
	Reconcile(ctx context.Context, rb eventingv1alpha1.ReconcilableBroker) (*corev1.ConfigMap, error)
}

func NewConfigMapReconciler

func NewConfigMapReconciler(ctx context.Context, configMapLister corev1listers.ConfigMapLister) ConfigMapReconciler

type SecretReconciler

type SecretReconciler interface {
	Reconcile(ctx context.Context, rb eventingv1alpha1.ReconcilableBroker) (*corev1.Secret, error)
}

func NewSecretReconciler

func NewSecretReconciler(ctx context.Context, secretLister corev1listers.SecretLister, triggerLister eventingv1alpha1listers.TriggerLister) SecretReconciler

type ServiceAccountReconciler

type ServiceAccountReconciler interface {
	Reconcile(ctx context.Context, rb eventingv1alpha1.ReconcilableBroker) (*corev1.ServiceAccount, *rbacv1.RoleBinding, error)
}

func NewServiceAccountReconciler

func NewServiceAccountReconciler(ctx context.Context, serviceAccountLister corev1listers.ServiceAccountLister, roleBindingLister rbacv1listers.RoleBindingLister) ServiceAccountReconciler