common

package

v1.5.3 Latest Latest Go to latest Published: Oct 26, 2023 License: Apache-2.0 Imports: 27 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/triggermesh/triggermesh-core

Links

Open Source Insights

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 ¶

View Source

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

View Source

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

View Source

const (

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

View Source

const (
	ConfigSecretKey = "config"
)

Variables ¶

This section is empty.

Functions ¶

func AppAnnotationValue ¶

func AppAnnotationValue(or kmeta.OwnerRefable) string

func GetBrokerConfigMapName ¶ added in v1.5.3

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 ...resources.DeploymentOption) (*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 ¶ added in v1.5.3

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

func NewConfigMapReconciler ¶ added in v1.5.3

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

Source Files ¶

View all Source files

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