Versions in this module Expand all Collapse all v1 v1.0.0 Jun 23, 2026 Changes in this version + const CommonImageRegistryAccount + const CommonImageTag + const DBMigrationSonataFlowPlatform + const SonataFlowGreetingsDataInputSchemaConfig + const SonataFlowGreetingsStaticFilesConfig + const SonataFlowGreetingsWithDataInputSchemaCR + const SonataFlowGreetingsWithStaticResourcesCR + const SonataFlowSimpleOpsYamlCR + const SonataFlowVetWithEventCR + func CreateFakeKnativeAndMonitoringDiscoveryClient() discovery.DiscoveryInterface + func GetBaseClusterPlatformInReadyPhase(namespace string) *operatorapi.SonataFlowClusterPlatform + func GetBasePlatform() *operatorapi.SonataFlowPlatform + func GetBasePlatformInReadyPhase(namespace string) *operatorapi.SonataFlowPlatform + func GetBasePlatformWithBaseImageInReadyPhase(namespace string) *operatorapi.SonataFlowPlatform + func GetBasePlatformWithBroker() *operatorapi.SonataFlowPlatform + func GetBasePlatformWithBrokerInReadyPhase(namespace string) *operatorapi.SonataFlowPlatform + func GetBasePlatformWithDevBaseImageInReadyPhase(namespace string) *operatorapi.SonataFlowPlatform + func GetBaseSonataFlow(namespace string) *operatorapi.SonataFlow + func GetBaseSonataFlowPlatformInReadyPhase(namespace string) *operatorapi.SonataFlowPlatform + func GetBaseSonataFlowWithDevProfile(namespace string) *operatorapi.SonataFlow + func GetBaseSonataFlowWithGitopsProfile(namespace string) *operatorapi.SonataFlow + func GetBaseSonataFlowWithPreviewProfile(namespace string) *operatorapi.SonataFlow + func GetBaseSonataFlowWithProdProfile(namespace string) *operatorapi.SonataFlow + func GetDefaultBroker(namespace string) *eventingv1.Broker + func GetKubernetesResource(testFile string, resource client.Object) + func GetLocalSucceedSonataFlowBuild(name, namespace string) *operatorapi.SonataFlowBuild + func GetNewEmptySonataFlowBuild(name, namespace string) *operatorapi.SonataFlowBuild + func GetPathFromDataDirectory(join ...string) string + func GetPathFromE2EDirectory(join ...string) string + func GetSonataFlow(testFile, namespace string) *operatorapi.SonataFlow + func GetSonataFlowBuilderConfig(namespace string) *corev1.ConfigMap + func GetSonataFlowClusterPlatformInReadyPhase(path string, namespace string) *operatorapi.SonataFlowClusterPlatform + func GetSonataFlowPlatformInReadyPhase(path string, namespace string) *operatorapi.SonataFlowPlatform + func GetVetEventSonataFlow(namespace string) *operatorapi.SonataFlow + func MustGetBuild(t *testing.T, client ctrl.WithWatch, name types.NamespacedName) *operatorapi.SonataFlowBuild + func MustGetConfigMap(t *testing.T, client ctrl.WithWatch, workflow *operatorapi.SonataFlow) *v1.ConfigMap + func MustGetDeployment(t *testing.T, client ctrl.WithWatch, workflow *operatorapi.SonataFlow) *appsv1.Deployment + func MustGetService(t *testing.T, client ctrl.WithWatch, workflow *operatorapi.SonataFlow) *v1.Service + func MustGetWorkflow(t *testing.T, client ctrl.WithWatch, name types.NamespacedName) *operatorapi.SonataFlow + func NewFakeRecorder() record.EventRecorder + func NewSonataFlow(filePath string, namespace string, options ...func(*operatorapi.SonataFlow)) *operatorapi.SonataFlow + func RestoreControllersConfig(t *testing.T) + func SetDevProfile(workflow *operatorapi.SonataFlow) + func SetGitopsProfile(workflow *operatorapi.SonataFlow) + func SetPreviewProfile(workflow *operatorapi.SonataFlow) + type MockPlatformService struct + Client clientv1.Client + CreateFunc func(ctx context.Context, obj clientv1.Object, opts ...clientv1.CreateOption) error + DeleteAllOfFunc func(ctx context.Context, obj clientv1.Object, opts ...clientv1.DeleteAllOfOption) error + DeleteFunc func(ctx context.Context, obj clientv1.Object, opts ...clientv1.DeleteOption) error + GetCachedFunc func(ctx context.Context, key clientv1.ObjectKey, obj clientv1.Object) error + GetFunc func(ctx context.Context, key clientv1.ObjectKey, obj clientv1.Object) error + GetSchemeFunc func() *runtime.Scheme + ListFunc func(ctx context.Context, list clientv1.ObjectList, opts ...clientv1.ListOption) error + PatchFunc func(ctx context.Context, obj clientv1.Object, patch clientv1.Patch, ...) error + StatusFunc func() clientv1.StatusWriter + UpdateFunc func(ctx context.Context, obj clientv1.Object, opts ...clientv1.UpdateOption) error + func (service *MockPlatformService) Create(ctx context.Context, obj clientv1.Object, opts ...clientv1.CreateOption) error + func (service *MockPlatformService) Delete(ctx context.Context, obj clientv1.Object, opts ...clientv1.DeleteOption) error + func (service *MockPlatformService) DeleteAllOf(ctx context.Context, obj clientv1.Object, opts ...clientv1.DeleteAllOfOption) error + func (service *MockPlatformService) Get(ctx context.Context, key clientv1.ObjectKey, obj clientv1.Object) error + func (service *MockPlatformService) GetCached(ctx context.Context, key clientv1.ObjectKey, obj clientv1.Object) error + func (service *MockPlatformService) GetScheme() *runtime.Scheme + func (service *MockPlatformService) IsMockService() bool + func (service *MockPlatformService) List(ctx context.Context, list clientv1.ObjectList, opts ...clientv1.ListOption) error + func (service *MockPlatformService) Patch(ctx context.Context, obj clientv1.Object, patch clientv1.Patch, ...) error + func (service *MockPlatformService) Status() clientv1.StatusWriter + func (service *MockPlatformService) Update(ctx context.Context, obj clientv1.Object, opts ...clientv1.UpdateOption) error + type SonataFlowClientBuilder struct + func NewKogitoClientBuilderWithOpenShift() *SonataFlowClientBuilder + func NewSonataFlowClientBuilder() *SonataFlowClientBuilder + func NewSonataFlowClientBuilderWithKnative() *SonataFlowClientBuilder + func (s *SonataFlowClientBuilder) Build() ctrl.WithWatch + func (s *SonataFlowClientBuilder) WithRuntimeObjects(initRuntimeObjs ...runtime.Object) *SonataFlowClientBuilder + func (s *SonataFlowClientBuilder) WithStatusSubresource(o ...ctrl.Object) *SonataFlowClientBuilder