knative

Documentation

Index

• func CheckKSinkInjected(name, namespace string) (bool, error)
• 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 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) error
• type Availability
  • func GetKnativeAvailability(cfg *rest.Config) (*Availability, error)

Functions

func CheckKSinkInjected

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

Does the sinkbinding completed K_SINK injection?

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 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) error

Types

type Availability

type Availability struct {
	Eventing bool
	Serving  bool
}

func GetKnativeAvailability

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