Documentation ¶
Index ¶
- Constants
- func GetBasePlatform() *operatorapi.SonataFlowPlatform
- func GetBasePlatformInReadyPhase(namespace string) *operatorapi.SonataFlowPlatform
- func GetBasePlatformWithBaseImageInReadyPhase(namespace string) *operatorapi.SonataFlowPlatform
- func GetBasePlatformWithDevBaseImageInReadyPhase(namespace string) *operatorapi.SonataFlowPlatform
- func GetBaseSonataFlow(namespace string) *operatorapi.SonataFlow
- func GetBaseSonataFlowWithDevProfile(namespace string) *operatorapi.SonataFlow
- func GetBaseSonataFlowWithProdProfile(namespace string) *operatorapi.SonataFlow
- func GetLocalSucceedSonataFlowBuild(name, namespace string) *operatorapi.SonataFlowBuild
- func GetNewEmptySonataFlowBuild(name, namespace string) *operatorapi.SonataFlowBuild
- func GetPathForSamples(path string) string
- func GetPlatformMinikubeE2eTest() string
- func GetPlatformOpenshiftE2eTest() string
- func GetSonataFlow(path string, namespace string) *operatorapi.SonataFlow
- func GetSonataFlowBuilderConfig(path, namespace string) *corev1.ConfigMap
- func GetSonataFlowE2eOrderProcessingFolder() string
- func GetSonataFlowPlatform(path string) *operatorapi.SonataFlowPlatform
- func GetSonataFlowPlatformInReadyPhase(path string, namespace string) *operatorapi.SonataFlowPlatform
- 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 NewKogitoClientBuilder() *fake.ClientBuilder
- func NewKogitoClientBuilderWithOpenShift() *fake.ClientBuilder
- type MockPlatformService
- 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
Constants ¶
View Source
const ( SonataFlowSampleYamlCR = "sonataflow.org_v1alpha08_sonataflow.yaml" SonataFlowGreetingsWithDataInputSchemaCR = "sonataflow.org_v1alpha08_sonataflow_greetings_datainput.yaml" SonataFlowGreetingsDataInputSchemaConfig = "v1_configmap_greetings_datainput.yaml" )
Variables ¶
This section is empty.
Functions ¶
func GetBasePlatform ¶ added in v1.40.0
func GetBasePlatform() *operatorapi.SonataFlowPlatform
func GetBasePlatformInReadyPhase ¶ added in v1.40.0
func GetBasePlatformInReadyPhase(namespace string) *operatorapi.SonataFlowPlatform
func GetBasePlatformWithBaseImageInReadyPhase ¶ added in v1.40.0
func GetBasePlatformWithBaseImageInReadyPhase(namespace string) *operatorapi.SonataFlowPlatform
func GetBasePlatformWithDevBaseImageInReadyPhase ¶ added in v1.40.0
func GetBasePlatformWithDevBaseImageInReadyPhase(namespace string) *operatorapi.SonataFlowPlatform
func GetBaseSonataFlow ¶ added in v1.40.0
func GetBaseSonataFlow(namespace string) *operatorapi.SonataFlow
func GetBaseSonataFlowWithDevProfile ¶ added in v1.40.0
func GetBaseSonataFlowWithDevProfile(namespace string) *operatorapi.SonataFlow
func GetBaseSonataFlowWithProdProfile ¶ added in v1.40.0
func GetBaseSonataFlowWithProdProfile(namespace string) *operatorapi.SonataFlow
func GetLocalSucceedSonataFlowBuild ¶ added in v1.43.0
func GetLocalSucceedSonataFlowBuild(name, namespace string) *operatorapi.SonataFlowBuild
GetLocalSucceedSonataFlowBuild gets a local (testdata dir ref to caller) SonataFlowBuild with Succeed status equals to true.
func GetNewEmptySonataFlowBuild ¶ added in v1.40.0
func GetNewEmptySonataFlowBuild(name, namespace string) *operatorapi.SonataFlowBuild
func GetPathForSamples ¶ added in v1.40.0
func GetPlatformMinikubeE2eTest ¶ added in v1.40.0
func GetPlatformMinikubeE2eTest() string
func GetPlatformOpenshiftE2eTest ¶ added in v1.40.0
func GetPlatformOpenshiftE2eTest() string
func GetSonataFlow ¶ added in v1.40.0
func GetSonataFlow(path string, namespace string) *operatorapi.SonataFlow
func GetSonataFlowBuilderConfig ¶ added in v1.40.0
func GetSonataFlowE2eOrderProcessingFolder ¶ added in v1.40.0
func GetSonataFlowE2eOrderProcessingFolder() string
func GetSonataFlowPlatform ¶ added in v1.40.0
func GetSonataFlowPlatform(path string) *operatorapi.SonataFlowPlatform
func GetSonataFlowPlatformInReadyPhase ¶ added in v1.40.0
func GetSonataFlowPlatformInReadyPhase(path string, namespace string) *operatorapi.SonataFlowPlatform
func MustGetConfigMap ¶ added in v1.35.0
func MustGetConfigMap(t *testing.T, client ctrl.WithWatch, workflow *operatorapi.SonataFlow) *v1.ConfigMap
func MustGetDeployment ¶ added in v1.35.0
func MustGetDeployment(t *testing.T, client ctrl.WithWatch, workflow *operatorapi.SonataFlow) *appsv1.Deployment
func MustGetService ¶ added in v1.35.0
func MustGetService(t *testing.T, client ctrl.WithWatch, workflow *operatorapi.SonataFlow) *v1.Service
func MustGetWorkflow ¶ added in v1.35.0
func MustGetWorkflow(t *testing.T, client ctrl.WithWatch, name types.NamespacedName) *operatorapi.SonataFlow
func NewKogitoClientBuilder ¶ added in v1.35.0
func NewKogitoClientBuilder() *fake.ClientBuilder
NewKogitoClientBuilder creates a new fake.ClientBuilder with the right scheme references
func NewKogitoClientBuilderWithOpenShift ¶ added in v1.40.0
func NewKogitoClientBuilderWithOpenShift() *fake.ClientBuilder
NewKogitoClientBuilderWithOpenShift creates a new fake client with OpenShift schemas. If your object is not present, just add in the list below.
Types ¶
type MockPlatformService ¶
type MockPlatformService struct { Client clientv1.Client CreateFunc func(ctx context.Context, obj clientv1.Object, opts ...clientv1.CreateOption) error DeleteFunc func(ctx context.Context, obj clientv1.Object, opts ...clientv1.DeleteOption) error GetFunc func(ctx context.Context, key clientv1.ObjectKey, obj clientv1.Object) error ListFunc func(ctx context.Context, list clientv1.ObjectList, opts ...clientv1.ListOption) error UpdateFunc func(ctx context.Context, obj clientv1.Object, opts ...clientv1.UpdateOption) error PatchFunc func(ctx context.Context, obj clientv1.Object, patch clientv1.Patch, opts ...clientv1.PatchOption) error DeleteAllOfFunc func(ctx context.Context, obj clientv1.Object, opts ...clientv1.DeleteAllOfOption) error GetCachedFunc func(ctx context.Context, key clientv1.ObjectKey, obj clientv1.Object) error GetSchemeFunc func() *runtime.Scheme StatusFunc func() clientv1.StatusWriter // contains filtered or unexported fields }
func MockService ¶
func MockService() *MockPlatformService
func MockServiceWithExtraScheme ¶
func MockServiceWithExtraScheme(objs ...runtime.Object) *MockPlatformService
func (*MockPlatformService) Create ¶
func (service *MockPlatformService) Create(ctx context.Context, obj clientv1.Object, opts ...clientv1.CreateOption) error
func (*MockPlatformService) Delete ¶
func (service *MockPlatformService) Delete(ctx context.Context, obj clientv1.Object, opts ...clientv1.DeleteOption) error
func (*MockPlatformService) DeleteAllOf ¶
func (service *MockPlatformService) DeleteAllOf(ctx context.Context, obj clientv1.Object, opts ...clientv1.DeleteAllOfOption) error
func (*MockPlatformService) GetScheme ¶
func (service *MockPlatformService) GetScheme() *runtime.Scheme
func (*MockPlatformService) IsMockService ¶
func (service *MockPlatformService) IsMockService() bool
func (*MockPlatformService) List ¶
func (service *MockPlatformService) List(ctx context.Context, list clientv1.ObjectList, opts ...clientv1.ListOption) error
func (*MockPlatformService) Patch ¶
func (service *MockPlatformService) Patch(ctx context.Context, obj clientv1.Object, patch clientv1.Patch, opts ...clientv1.PatchOption) error
func (*MockPlatformService) Status ¶
func (service *MockPlatformService) Status() clientv1.StatusWriter
func (*MockPlatformService) Update ¶
func (service *MockPlatformService) Update(ctx context.Context, obj clientv1.Object, opts ...clientv1.UpdateOption) error
Click to show internal directories.
Click to hide internal directories.