workflowdef

Documentation

Index

• Constants
• func CreateNewConfigMap(workflow *operatorapi.SonataFlow) (*corev1.ConfigMap, error)
• func ExternalResCMsToVolumesAndMount(configMaps []operatorapi.ConfigMapWorkflowResource, baseMountPath string) ([]corev1.Volume, []corev1.VolumeMount)
• func FetchExternalResourcesConfigMapsRef(client client.Client, workflow *operatorapi.SonataFlow) ([]operatorapi.ConfigMapWorkflowResource, error)
• func GetDefaultImageTag(imgTag string) string
• func GetDefaultWorkflowBuilderImageTag() string
• func GetDefaultWorkflowDevModeImageTag() string
• func GetJSONWorkflow(workflowCR *operatorapi.SonataFlow, ctx context.Context) ([]byte, error)
• func GetWorkflowAppImageNameTag(w *v1alpha08.SonataFlow) string

Constants

const KogitoWorkflowJSONFileExt = ".sw.json"

Functions

func CreateNewConfigMap

func CreateNewConfigMap(workflow *operatorapi.SonataFlow) (*corev1.ConfigMap, error)

CreateNewConfigMap creates a new configMap object instance with the workflow definition based on the given SonataFlow custom resource. It does not persist the CM into the Kubernetes storage. The name and namespace are the same of the given CR.

func ExternalResCMsToVolumesAndMount

func ExternalResCMsToVolumesAndMount(configMaps []operatorapi.ConfigMapWorkflowResource, baseMountPath string) ([]corev1.Volume, []corev1.VolumeMount)

ExternalResCMsToVolumesAndMount creates volume mounts for ExtResType ConfigMaps references. See FetchExternalResourcesConfigMapsRef that should return the maps needed as input for this function. `baseMountPath` is a string with the base mount path to join with the given relative path in the configMap reference.

func FetchExternalResourcesConfigMapsRef

func FetchExternalResourcesConfigMapsRef(client client.Client, workflow *operatorapi.SonataFlow) ([]operatorapi.ConfigMapWorkflowResource, error)

FetchExternalResourcesConfigMapsRef fetches the Resource ConfigMaps into a LocalObjectReference that a client can mount to the workflow application. The map format is map[<resource_type>]<ConfigMap_reference>. For example map["resource-openapi"]{MyOpenApisConfigMap}

func GetDefaultImageTag

func GetDefaultImageTag(imgTag string) string

func GetDefaultWorkflowBuilderImageTag

func GetDefaultWorkflowBuilderImageTag() string

func GetDefaultWorkflowDevModeImageTag

func GetDefaultWorkflowDevModeImageTag() string

func GetJSONWorkflow

func GetJSONWorkflow(workflowCR *operatorapi.SonataFlow, ctx context.Context) ([]byte, error)

GetJSONWorkflow return a Kogito compliant JSON format workflow as bytearray give a specific workflow CR

func GetWorkflowAppImageNameTag

func GetWorkflowAppImageNameTag(w *v1alpha08.SonataFlow) string

GetWorkflowAppImageNameTag retrieve the tag for the image based on the Workflow based annotation, <workflowid>:latest otherwise