knative

Documentation

Index

• Constants
• func CheckKSinkInjected(name, namespace string) (bool, error)
• func GetBrokerClass(broker *eventingv1.Broker) string
• func GetKnativeEventingClient(cfg *rest.Config) (clienteventingv1.EventingV1Interface, error)
• func GetKnativeServingClient(cfg *rest.Config) (clientservingv1.ServingV1Interface, 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
  • func GetKnativeAvailability(cfg *rest.Config) (*Availability, error)

Constants

const (
	KafkaKnativeEventingDeliveryOrder        = "kafka.eventing.knative.dev/delivery.order"
	KafkaKnativeEventingDeliveryOrderOrdered = "ordered"
)

Functions

func CheckKSinkInjected

func CheckKSinkInjected(name, namespace string) (bool, error)

Does the sinkbinding completed K_SINK injection?

func GetBrokerClass

func GetBrokerClass(broker *eventingv1.Broker) string

GetBrokerClass returns the broker class for a Knative Eventing Broker.

func GetKnativeEventingClient

func GetKnativeEventingClient(cfg *rest.Config) (clienteventingv1.EventingV1Interface, error)

func GetKnativeServingClient

func GetKnativeServingClient(cfg *rest.Config) (clientservingv1.ServingV1Interface, error)

func GetWorkflowSink

func GetWorkflowSink(workflow *operatorapi.SonataFlow, pl *operatorapi.SonataFlowPlatform) (*duckv1.Destination, error)

func IsKafkaBroker

func IsKafkaBroker(brokerClass string) bool

IsKafkaBroker returns true if the class for a Knative Eventing Broker corresponds to a Kafka broker.

func IsKnativeBroker

func IsKnativeBroker(kRef *duckv1.KReference) bool

func MapTriggerToPlatformRequests

func MapTriggerToPlatformRequests(ctx context.Context, object client.Object) []reconcile.Request

if a trigger is changed and it has namespace different from the platform is changed, reconcile the parent SonataFlowPlatform in the cluster.

func NewKnativeEventingClient

func NewKnativeEventingClient(cfg *rest.Config) (*clienteventingv1.EventingV1Client, error)

func NewKnativeServingClient

func NewKnativeServingClient(cfg *rest.Config) (*clientservingv1.ServingV1Client, error)

func RestoreKnativeVolumeAndVolumeMount

func RestoreKnativeVolumeAndVolumeMount(podSpec *corev1.PodSpec)

Knative Sinkbinding injects K_SINK env, a volume and volume mount. The volume and volume mount must be in the end of the array to avoid repeadly restarting of the workflow pod

func SaveKnativeData

func SaveKnativeData(dest *corev1.PodSpec, source *corev1.PodSpec)

func ValidateBroker

func ValidateBroker(name, namespace string) (*eventingv1.Broker, error)

Types

type Availability

type Availability struct {
	Eventing bool
	Serving  bool
}

func GetKnativeAvailability

func GetKnativeAvailability(cfg *rest.Config) (*Availability, error)