Versions in this module Expand all Collapse all v1 v1.0.0 Jun 23, 2026 Changes in this version + const KafkaKnativeEventingDeliveryOrder + const KafkaKnativeEventingDeliveryOrderOrdered + func CheckKSinkInjected(name, namespace string) (bool, error) + func CleanupOutdatedRevisions(ctx context.Context, cfg *rest.Config, workflow *operatorapi.SonataFlow, ...) error + func GetBrokerClass(broker *eventingv1.Broker) string + func GetKnativeEventingClient(cfg *rest.Config) (clienteventingv1.EventingV1Interface, error) + func GetKnativeServingClient(cfg *rest.Config) (clientservingv1.ServingV1Interface, error) + func GetRemotePlatform(pl *operatorapi.SonataFlowPlatform) (*operatorapi.SonataFlowPlatform, error) + func GetSinkBindingSinkURI(name, namespace string) (*apis.URL, error) + func GetSinkURI(destination duckv1.Destination) (*apis.URL, error) + func GetWorkflowSink(workflow *operatorapi.SonataFlow, pl *operatorapi.SonataFlowPlatform) (*duckv1.Destination, error) + func IsKafkaBroker(brokerClass string) bool + func IsKnativeBroker(kRef *duckv1.KReference) bool + func MapTriggerToPlatformRequests(ctx context.Context, object client.Object) []reconcile.Request + func NewKnativeEventingClient(cfg *rest.Config) (*clienteventingv1.EventingV1Client, error) + func NewKnativeServingClient(cfg *rest.Config) (*clientservingv1.ServingV1Client, error) + func RestoreKnativeVolumeAndVolumeMount(podSpec *corev1.PodSpec) + func SaveKnativeData(dest *corev1.PodSpec, source *corev1.PodSpec) + func ValidateBroker(name, namespace string) (*eventingv1.Broker, error) + type Availability struct + Eventing bool + Serving bool + func GetKnativeAvailability(cfg *rest.Config) (*Availability, error) + type CreationTimestamp []servingv1.Revision + func (a CreationTimestamp) Len() int + func (a CreationTimestamp) Less(i, j int) bool + func (a CreationTimestamp) Swap(i, j int)
Go to main page