Versions in this module Expand all Collapse all v0 v0.0.2 Mar 2, 2021 Changes in this version + var CommunityCatalog = operatorCatalog + var KogitoOperatorDependencies = []string + var KogitoOperatorMongoDBDependency = infrastructure.MongoDBKind + var OperatorHubCatalog = operatorCatalog + func BumpEvents(namespace string) error + func CheckCliBinaryExist() (bool, error) + func CheckPodHasImagePullSecretWithPrefix(pod *corev1.Pod, imagePullSecretPrefix string) bool + func CheckPodsAreReady(pods *corev1.PodList) bool + func CheckPodsByDeploymentConfigInError(namespace string, dcName string) func() (bool, error) + func CheckPodsByDeploymentInError(namespace string, dName string) func() (bool, error) + func CheckPodsWithLabelInError(namespace, labelName, labelValue string) func() (bool, error) + func CheckSetup() error + func ClearNamespaceHistory() + func CompleteTask(...) (err error) + func CompleteTaskByUser(...) (err error) + func CreateFile(folder, fileName, fileContent string) error + func CreateFolder(folder string) error + func CreateInfinispanSecret(namespace, name string, credentialsMap map[string]string) error + func CreateKogitoOperatorCatalogSource() (*olmapiv1alpha1.CatalogSource, error) + func CreateMongoDBSecret(namespace, name, password string) error + func CreateNamespace(namespace string) error + func CreateNamespacedSubscriptionIfNotExist(namespace string, subscriptionName string, operatorName string, ...) (*olmapiv1alpha1.Subscription, error) + func CreateObject(o kubernetes.ResourceObject) error + func CreateOperatorGroupIfNotExists(namespace, operatorGroupName string) (*olmapiv1.OperatorGroup, error) + func CreateSecret(namespace, name string, secretContent map[string]string) error + func CreateTemporaryFile(filePattern, fileContent string) (string, error) + func CreateTemporaryFolder(folderPrefix string) (string, error) + func CreateTrigger(namespace, name, brokerName, serviceName string) error + func DeleteFile(folder, fileName string) error + func DeleteFolder(folder string) error + func DeleteKogitoOperatorCatalogSource() error + func DeleteNamespace(namespace string) error + func DeleteObject(o kubernetes.ResourceObject) error + func DeleteSubscription(subscription *olmapiv1alpha1.Subscription) error + func DeployBroker(namespace, name string) error + func DeployClusterWideKogitoOperatorFromYaml(deploymentNamespace string) error + func DeployClusterWideKogitoOperatorUsingOlm() error + func DeployGrafanaInstance(namespace, labelName, labelValue string) error + func DeployInfinispanInstance(namespace string, infinispan *infinispan.Infinispan) error + func DeployKafkaInstance(namespace string, kafka *kafkabetav1.Kafka) error + func DeployKafkaTopic(namespace, kafkaTopicName, kafkaInstanceName string) error + func DeployKeycloakClient(namespace, clientName string) error + func DeployKeycloakInstance(namespace string) error + func DeployKeycloakRealm(namespace, realmName string) error + func DeployKeycloakUser(namespace, userName, password string) error + func DeployKogitoBuild(namespace string, installerType InstallerType, ...) error + func DeployMongoDBInstance(namespace string, instance *mongodb.MongoDB) error + func DeployMongoDBOperatorFromYaml(namespace string) error + func DeployNamespacedKogitoOperatorUsingOlm(deploymentNamespace string) error + func DeployPrometheusInstance(namespace, labelName, labelValue string) error + func DeployRuntimeService(namespace string, installerType InstallerType, ...) error + func DeployService(serviceHolder *bddtypes.KogitoServiceHolder, installerType InstallerType) error + func DoesHTTPResponseContain(namespace string, requestInfo HTTPRequestInfo, responseContent string) (bool, error) + func ExecuteCliCommand(namespace string, args ...string) (string, error) + func ExecuteCliCommandInNamespace(namespace string, args ...string) (string, error) + func ExecuteGraphQLRequestWithLogging(namespace, uri, path, query, bearerToken string, response interface{}) error + func ExecuteGraphQLRequestWithLoggingOption(namespace, uri, path, query, bearerToken string, response interface{}, ...) error + func ExecuteHTTPRequest(namespace string, requestInfo HTTPRequestInfo) (*http.Response, error) + func ExecuteHTTPRequestC(client *http.Client, namespace string, requestInfo HTTPRequestInfo) (*http.Response, error) + func ExecuteHTTPRequestWithStringResponse(namespace string, requestInfo HTTPRequestInfo) (string, error) + func ExecuteHTTPRequestWithUnmarshalledResponse(namespace string, requestInfo HTTPRequestInfo, response interface{}) error + func ExposeServiceOnKubernetes(namespace string, service api.KogitoService) error + func FlushAllRemainingLoggers() + func FlushLogger(namespace string) error + func GenerateNamespaceName(prefix string) string + func GetAccessTokenFromKeycloak(namespace, server, userName, password, realm, clientName string) (string, error) + func GetActiveReplicaSetByDeployment(namespace string, dName string) (*apps.ReplicaSet, error) + func GetBuildImage(imageName string) string + func GetClusterWideTestSubscriptions() (*olmapiv1alpha1.SubscriptionList, error) + func GetContainerLog(namespace, podName, containerName string) (string, error) + func GetDeployment(namespace, deploymentName string) (*apps.Deployment, error) + func GetDeploymentConfig(namespace, dcName string) (*ocapps.DeploymentConfig, error) + func GetInfinispanStub(namespace, name, secretName string) *infinispan.Infinispan + func GetIngressURI(namespace, serviceName string) (string, error) + func GetKogitoBuild(namespace, buildName string) (*v1beta1.KogitoBuild, error) + func GetKogitoBuildStub(namespace, runtimeType, name string) *v1beta1.KogitoBuild + func GetKogitoDataIndexResourceStub(namespace string, replicas int) *v1beta1.KogitoSupportingService + func GetKogitoExplainabilityResourceStub(namespace string, replicas int) *v1beta1.KogitoSupportingService + func GetKogitoInfraResourceStub(namespace, name, targetResourceType string) (*v1beta1.KogitoInfra, error) + func GetKogitoJobsService(namespace string) (*v1beta1.KogitoSupportingService, error) + func GetKogitoJobsServiceResourceStub(namespace string, replicas int) *v1beta1.KogitoSupportingService + func GetKogitoManagementConsoleResourceStub(namespace string, replicas int) *v1beta1.KogitoSupportingService + func GetKogitoRuntimeStub(namespace, runtimeType, name, imageTag string) *v1beta1.KogitoRuntime + func GetKogitoTaskConsoleResourceStub(namespace string, replicas int) *v1beta1.KogitoSupportingService + func GetKogitoTrustyResourceStub(namespace string, replicas int) *v1beta1.KogitoSupportingService + func GetKogitoTrustyUIResourceStub(namespace string, replicas int) *v1beta1.KogitoSupportingService + func GetKubernetesDurationFromTimeInMin(timeoutInMin int) time.Duration + func GetLogFolder() string + func GetMongoDBSecret(namespace, secretName, password string) *corev1.Secret + func GetMongoDBStub(openshift bool, namespace, name string, users []MongoDBUserCred) *mongodb.MongoDB + func GetNamespacesInHistory() []string + func GetOpenshiftDurationFromTimeInMin(timeoutInMin int) time.Duration + func GetPods(namespace string) (*corev1.PodList, error) + func GetPodsByDeployment(namespace string, dName string) (pods []corev1.Pod, err error) + func GetPodsByDeploymentConfig(namespace string, dcName string) (*corev1.PodList, error) + func GetPodsWithLabels(namespace string, labels map[string]string) (*corev1.PodList, error) + func GetProcessInstances(namespace, routeURI, processName string) (foundProcessInstances []map[string]interface{}, err error) + func GetRoute(namespace, routeName string) (*routev1.Route, error) + func GetRouteURI(namespace, serviceName string) (string, error) + func GetService(namespace, name string) (*corev1.Service, error) + func InitKubeClient() error + func InstallClusterWideOperator(subscriptionName, channel string, catalog operatorCatalog) error + func InstallKogitoDataIndexService(namespace string, installerType InstallerType, ...) error + func InstallKogitoExplainabilityService(namespace string, installerType InstallerType, ...) error + func InstallKogitoInfraComponent(namespace string, installerType InstallerType, infra *v1beta1.KogitoInfra) error + func InstallKogitoJobsService(installerType InstallerType, jobsService *bddtypes.KogitoServiceHolder) error + func InstallKogitoManagementConsole(installerType InstallerType, managementConsole *bddtypes.KogitoServiceHolder) error + func InstallKogitoOperatorDependency(namespace, dependentOperator string, catalog operatorCatalog) error + func InstallKogitoTaskConsole(installerType InstallerType, taskConsole *bddtypes.KogitoServiceHolder) error + func InstallKogitoTrustyService(namespace string, installerType InstallerType, ...) error + func InstallKogitoTrustyUI(installerType InstallerType, trustyUI *bddtypes.KogitoServiceHolder) error + func InstallOperator(namespace, subscriptionName, channel string, catalog operatorCatalog) error + func InstallService(serviceHolder *bddtypes.KogitoServiceHolder, installerType InstallerType, ...) error + func IsCrdAvailable(crdName string) (bool, error) + func IsGraphQLRequestSuccessful(namespace, uri, path, query, bearerToken string, response interface{}) (bool, error) + func IsHTTPRequestFailed(namespace string, requestInfo HTTPRequestInfo) (bool, error) + func IsHTTPRequestForbidden(namespace string, requestInfo HTTPRequestInfo) (bool, error) + func IsHTTPRequestSuccessful(namespace string, requestInfo HTTPRequestInfo) (bool, error) + func IsHTTPResponseArraySize(namespace string, requestInfo HTTPRequestInfo, arraySize int) (bool, error) + func IsKogitoOperatorRunning(namespace string) (bool, error) + func IsNamespace(namespace string) (bool, error) + func IsOpenshift() bool + func IsOperatorRunning(namespace, operatorPackageName string, catalog operatorCatalog) (bool, error) + func IsPodRunning(pod *corev1.Pod) bool + func IsPodStatusConditionReady(pod *corev1.Pod) bool + func KogitoOperatorExists(namespace string) (bool, error) + func LogKubernetesObjects(namespace string, runtimeObjects ...runtime.Object) error + func NewImageOrDefault(fullImage string, defaultImageName string) string + func NewKogitoServiceSpec(replicas int32, fullImage string, defaultImageName string) v1beta1.KogitoServiceSpec + func NewKogitoServiceStatus() v1beta1.KogitoServiceStatus + func NewObjectMetadata(namespace string, name string) metav1.ObjectMeta + func OnKogitoServiceDeployed(namespace string, service api.KogitoService) error + func OperateOnNamespaceIfExists(namespace string, operate func(namespace string) error) error + func OperatorExistsUsingSubscription(namespace, operatorPackageName, operatorSource string) (bool, error) + func PrintDataMap(keys []string, dataMaps []map[string]string, writer io.StringWriter) error + func ReadFromURI(uri string) (string, error) + func RenameLogFolder(namespace, newLogFolderName string) error + func ReportPerformanceMetric(metric, value, unit string) + func RetrieveKeycloakEndpointURI(namespace string) (string, error) + func SetInfinispanReplicas(namespace, name string, nbPods int) error + func SetKogitoJobsServiceReplicas(namespace string, nbPods int32) error + func SetKogitoRuntimeReplicas(namespace, name string, nbPods int) error + func SetLogSubFolder(subFolders ...string) + func SetupKogitoBuildImageStreams(kogitoBuild *v1beta1.KogitoBuild) + func StartPodLogCollector(namespace string) error + func StartProcess(namespace, routeURI, processName, bodyFormat, bodyContent string) (err error) + func StopPodLogCollector(namespace string) error + func ToResourceRequirements(requests string, limits string) corev1.ResourceRequirements + func WaitAndRetrieveEndpointURI(namespace, serviceName string) (string, error) + func WaitFor(namespace, display string, timeout time.Duration, ...) error + func WaitForAllPodsByDeploymentConfigToContainTextInLog(namespace, dcName, logText string, timeoutInMin int) error + func WaitForAllPodsByDeploymentToContainTextInLog(namespace, dName, logText string, timeoutInMin int) error + func WaitForAnyPodsByDeploymentToContainTextInLog(namespace, dName, logText string, timeoutInMin int) error + func WaitForBrokerResource(namespace, name string, timeoutInMin int) error + func WaitForBuildComplete(namespace, buildName string, timeoutInMin int) error + func WaitForBuildConfigCreated(namespace, buildConfigName string, timeoutInMin int) error + func WaitForBuildConfigCreatedWithWebhooks(namespace, buildConfigName string, expectedWebhooks []v1beta1.WebHookSecret, ...) error + func WaitForBuildConfigToHaveResources(namespace, buildConfigName string, expected v1.ResourceRequirements, ...) error + func WaitForClusterWideKogitoOperatorRunningUsingOlm() error + func WaitForClusterWideOperatorRunning(operatorPackageName string, catalog operatorCatalog, timeoutInMin int) error + func WaitForDeploymentConfigRunning(namespace, dcName string, podNb int, timeoutInMin int) error + func WaitForDeploymentRunning(namespace, dName string, podNb int, timeoutInMin int) error + func WaitForFailedHTTPRequest(namespace string, requestInfo HTTPRequestInfo, timeoutInMin int) error + func WaitForForbiddenHTTPRequest(namespace string, requestInfo HTTPRequestInfo, timeoutInMin int) error + func WaitForInfinispanPodsToBeRunningWithConfig(namespace string, expectedConfig infinispan.InfinispanContainerSpec, ...) error + func WaitForKogitoDataIndexService(namespace string, replicas int, timeoutInMin int) error + func WaitForKogitoExplainabilityService(namespace string, replicas int, timeoutInMin int) error + func WaitForKogitoInfraResource(namespace, name string, timeoutInMin int) error + func WaitForKogitoJobsService(namespace string, replicas int, timeoutInMin int) error + func WaitForKogitoJobsServiceLogContainsTextWithinMinutes(namespace, logText string, timeoutInMin int) error + func WaitForKogitoManagementConsoleService(namespace string, replicas int, timeoutInMin int) error + func WaitForKogitoOperatorCatalogSourceReady() error + func WaitForKogitoOperatorDependencyRunning(namespace, dependentOperator string, catalog operatorCatalog) error + func WaitForKogitoOperatorRunning(namespace string) error + func WaitForKogitoOperatorRunningWithDependencies(namespace string) error + func WaitForKogitoTaskConsoleService(namespace string, replicas int, timeoutInMin int) error + func WaitForKogitoTrustyService(namespace string, replicas int, timeoutInMin int) error + func WaitForKogitoTrustyUIService(namespace string, replicas int, timeoutInMin int) error + func WaitForMongoDBOperatorRunning(namespace string) error + func WaitForOnKubernetes(namespace, display string, timeoutInMin int, condition func() (bool, error)) error + func WaitForOnOpenshift(namespace, display string, timeoutInMin int, condition func() (bool, error), ...) error + func WaitForOperatorRunning(namespace, operatorPackageName string, catalog operatorCatalog, ...) error + func WaitForPodsByDeploymentConfigToHaveResources(namespace, dcName string, expected v1.ResourceRequirements, timeoutInMin int) error + func WaitForPodsByDeploymentToHaveResources(namespace, dName string, expected v1.ResourceRequirements, timeoutInMin int) error + func WaitForPodsWithLabel(namespace, labelName, labelValue string, numberOfPods, timeoutInMin int) error + func WaitForRoute(namespace, routeName string, timeoutInMin int) error + func WaitForService(namespace string, serviceName string, replicas int, timeoutInMin int) error + func WaitForSuccessfulGraphQLRequest(namespace, uri, path, query string, timeoutInMin int, response interface{}, ...) error + func WaitForSuccessfulGraphQLRequestUsingAccessToken(namespace, uri, path, query, accessToken string, timeoutInMin int, ...) error + func WaitForSuccessfulGraphQLRequestUsingPagination(namespace, uri, path, query string, timeoutInMin, pageSize, totalSize int, ...) error + func WaitForSuccessfulHTTPRequest(namespace string, requestInfo HTTPRequestInfo, timeoutInMin int) error + func WaitForTrigger(namespace, name string, timeoutInMin int) error + type Command interface + Execute func() (string, error) + InDirectory func(directory string) Command + Sync func(syncID string) Command + WithLoggerContext func(loggerContext string) Command + WithRetry func(opts ...RetryOption) Command + func CreateCommand(commandName string, args ...string) Command + type ContainerEngine interface + BuildImage func(projectLocation, imageTag string) ContainerEngine + GetError func() error + PullImage func(imageTag string) ContainerEngine + PushImage func(imageTag string) ContainerEngine + func GetContainerEngine(namespace string) ContainerEngine + type DecisionsResponse struct + Saliences []Salience + Status string + func GetKogitoTrustyDecisionsByExecutionName(namespace, executionName string, timeoutInMin int) (*DecisionsResponse, error) + type HTTPRequestInfo struct + BodyContent string + BodyFormat string + HTTPMethod string + Headers map[string]string + Path string + Token string + URI string + Unsecure bool + func NewGETHTTPRequestInfo(uri, path string) HTTPRequestInfo + func NewPOSTHTTPRequestInfo(uri, path, bodyFormat, bodyContent string) HTTPRequestInfo + func NewPOSTHTTPRequestInfoWithHeaders(uri, path string, headers map[string]string, bodyFormat, bodyContent string) HTTPRequestInfo + type HTTPRequestResult string + const HTTPRequestResultError + const HTTPRequestResultSuccess + func ExecuteHTTPRequestsInThreads(namespace string, requestCount, threadCount int, requestInfo HTTPRequestInfo) ([]HTTPRequestResult, error) + type InstallerType string + var CLIInstallerType InstallerType = cliInstallerKey + var CRInstallerType InstallerType = crInstallerKey + func GetDefaultInstallerType() InstallerType + type KogitoApplicationDockerfileProvider interface + GetDockerfileContent func() (string, error) + func GetKogitoApplicationDockerfileProvider(projectLocation string) KogitoApplicationDockerfileProvider + type Logger struct + func GetLogger(namespace string) Logger + func GetMainLogger() Logger + func (l Logger) Debug(message string, keysAndValues ...interface{}) + func (l Logger) Warn(message string, keysAndValues ...interface{}) + type MavenCommand interface + Execute func(targets ...string) (string, error) + Options func(options ...string) MavenCommand + Profiles func(profiles ...string) MavenCommand + SkipTests func() MavenCommand + UpdateArtifacts func() MavenCommand + WithLoggerContext func(loggerContext string) MavenCommand + func CreateMavenCommand(directory string) MavenCommand + type MongoDBUserCred struct + AuthDatabase string + Databases []string + Name string + SecretName string + type Opts struct + Output io.Writer + Verbose bool + type RetryOption func(*commandStruct) + func NumberOfRetries(retries int) RetryOption + func RetryDelay(delay time.Duration) RetryOption + type Salience struct + OutcomeName string + type Task struct + ID string + Name string + func GetTasks(namespace, routeURI, processName, processInstanceID string) (foundTasks []Task, err error) + func GetTasksByUser(namespace, routeURI, processName, processInstanceID, user string) (foundTasks []Task, err error)
Go to main page