Documentation
¶
Overview ¶
Package reconciler contains constants shared by reconcilers.
Index ¶
- Constants
- func CeResponseAttributes(src targets.EventSource) []duckv1.CloudEventAttributes
- func GetStatefulBridgeID(object metav1.Object) string
- func MakeAdapterLabels(adapterName, name string) labels.Set
- func MakeObsEnv(cfg source.ConfigAccessor) []corev1.EnvVar
- func MakeServiceEnv(name, namespace string) []corev1.EnvVar
- type DeploymentReconciler
- type KServiceReconciler
- type ServiceReconciler
- type ValueGetter
Constants ¶
const ( LabelBridgeUsedByPrefix = "flow.triggermesh.io/used-by." LabelValueBridgeDominant = "dominant" // Bridge identifier for stateful flows EnvBridgeID = "EVENTS_BRIDGE_IDENTIFIER" )
Stateful events related
Variables ¶
This section is empty.
Functions ¶
func CeResponseAttributes ¶
func CeResponseAttributes(src targets.EventSource) []duckv1.CloudEventAttributes
CeResponseAttributes returns the CloudEvent attributes of responses returned by the target.
func GetStatefulBridgeID ¶
GetStatefulBridgeID returns the BridgeID based on an object metadata.
All bridge components controlled by Triggerflow have labels informing their relation with the bridges they are part of. A component can only have one dominant bridge, which is the one it synchronizes with. This function uses that label to retrieve the bridge name and use it as unique ID.
func MakeAdapterLabels ¶
MakeAdapterLabels adds generic label generation
func MakeObsEnv ¶
func MakeObsEnv(cfg source.ConfigAccessor) []corev1.EnvVar
MakeObsEnv adds support for observability configs
func MakeServiceEnv ¶
MakeServiceEnv Adds default environment variables
Types ¶
type DeploymentReconciler ¶
type DeploymentReconciler interface {
ReconcileDeployment(context.Context, kmeta.OwnerRefableAccessor, *appsv1.Deployment) (*appsv1.Deployment, error)
}
DeploymentReconciler performs reconciliation for Deployments
func NewDeploymentReconciler ¶
func NewDeploymentReconciler(appsClientSet appsv1client.AppsV1Interface, deploymentLister appsv1listers.DeploymentLister) DeploymentReconciler
NewDeploymentReconciler creates the default implementation for Deployment reconciler.
type KServiceReconciler ¶
type KServiceReconciler interface {
ReconcileKService(context.Context, kmeta.OwnerRefable, *servingv1.Service) (*servingv1.Service, pkgreconciler.Event)
}
KServiceReconciler performs reconciliation for Knative services
func NewKServiceReconciler ¶
func NewKServiceReconciler(servingClientSet servingclientset.Interface, servingLister servinglisters.ServiceLister) KServiceReconciler
NewKServiceReconciler creates the default implementation of KService reconciler.
type ServiceReconciler ¶
type ServiceReconciler interface {
ReconcileService(context.Context, kmeta.OwnerRefableAccessor, *corev1.Service) (*corev1.Service, pkgreconciler.Event)
}
ServiceReconciler performs reconciliation for Services
func NewServiceReconciler ¶
func NewServiceReconciler(coreClientSet corev1client.CoreV1Interface, serviceLister corev1listers.ServiceLister) ServiceReconciler
NewServiceReconciler creates the default implementation for Service reconciler.
type ValueGetter ¶
type ValueGetter interface {
FromSecret(context.Context, string, *corev1.SecretKeySelector) (string, error)
FromConfig(context.Context, string, *corev1.ConfigMapKeySelector) (string, error)
}
ValueGetter groups kubernetes value retrieval functions
func NewValueGetter ¶
func NewValueGetter(kubeClientSet kubernetes.Interface) ValueGetter
NewValueGetter returns the default implementation of ValueGetter
Source Files
¶
Directories
¶
| Path | Synopsis |
|---|---|
|
Package event contains functions for generating Kubernetes API events.
|
Package event contains functions for generating Kubernetes API events. |
|
Package hasuratarget contains the reconciliation logic for the event target.
|
Package hasuratarget contains the reconciliation logic for the event target. |
|
Package splunktarget contains the reconciliation logic for the event target.
|
Package splunktarget contains the reconciliation logic for the event target. |
|
Package testing contains test helpers for reconcilers.
|
Package testing contains test helpers for reconcilers. |