integration_tests

package
v0.0.0-...-7708c6a Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 30, 2025 License: Apache-2.0 Imports: 49 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	Clientset *kubernetes.Clientset
	Config    *restclient.Config
)
View Source
var Neo4jConfFile = fmt.Sprintf("neo4j/neo4j-%s.conf", model.Neo4jEdition)
View Source
var (
	TestRunIdentifier string
)

Functions

func AsCloseable

func AsCloseable(closeables []Closeable) Closeable

func CheckError

func CheckError(err error)

func CheckExecInPod

func CheckExecInPod(t *testing.T, releaseName model.ReleaseName) error

func CheckLogsFormat

func CheckLogsFormat(t *testing.T, releaseName model.ReleaseName) error

CheckLogsFormat checks whether the neo4j logs are in json format or not

func CheckNeo4jOperationsPod

func CheckNeo4jOperationsPod(t *testing.T, releaseName model.ReleaseName) error

CheckNeo4jOperationsPod checks whether the neo4j operations pod is executed or not

func CheckProbes

func CheckProbes(t *testing.T, releaseName model.ReleaseName) error

func CheckServiceAnnotations

func CheckServiceAnnotations(t *testing.T, releaseName model.ReleaseName, chart model.Neo4jHelmChartBuilder) (err error)

func ExecInPod

func ExecInPod(releaseName model.ReleaseName, cmd []string, podName string) (string, string, error)

func InstallBackupViaTempDir

func InstallBackupViaTempDir(t *testing.T, releaseName model.ReleaseName) error

InstallBackupViaTempDir installs backup cronjob with a custom aggregate backup tempdir

func InstallNeo4jBackupAWSCloudStorage

func InstallNeo4jBackupAWSCloudStorage(t *testing.T, releaseName model.ReleaseName) error

InstallNeo4jBackupAWSCloudStorage performs cloud backup to AWS S3 without consistency check

func InstallNeo4jBackupAWSHelmChart

func InstallNeo4jBackupAWSHelmChart(t *testing.T, standaloneReleaseName model.ReleaseName) error

func InstallNeo4jBackupAWSHelmChartViaS3

func InstallNeo4jBackupAWSHelmChartViaS3(t *testing.T, releaseName model.ReleaseName) error

func InstallNeo4jBackupAWSHelmChartViaS3TLS

func InstallNeo4jBackupAWSHelmChartViaS3TLS(t *testing.T, releaseName model.ReleaseName) error

func InstallNeo4jBackupAWSLocalWithConsistencyCheck

func InstallNeo4jBackupAWSLocalWithConsistencyCheck(t *testing.T, releaseName model.ReleaseName) error

InstallNeo4jBackupAWSLocalWithConsistencyCheck performs local backup with consistency check

func InstallNeo4jBackupAzureHelmChart

func InstallNeo4jBackupAzureHelmChart(t *testing.T, standaloneReleaseName model.ReleaseName) error

func InstallNeo4jBackupGCPHelmChart

func InstallNeo4jBackupGCPHelmChart(t *testing.T, standaloneReleaseName model.ReleaseName) error

func InstallNeo4jBackupGCPHelmChartWithInconsistencies

func InstallNeo4jBackupGCPHelmChartWithInconsistencies(t *testing.T, standaloneReleaseName model.ReleaseName) error

func InstallNeo4jBackupGCPHelmChartWithWorkloadIdentity

func InstallNeo4jBackupGCPHelmChartWithWorkloadIdentity(t *testing.T, standaloneReleaseName model.ReleaseName) error

func InstallNeo4jBackupGCPHelmChartWithWorkloadIdentityForCluster

func InstallNeo4jBackupGCPHelmChartWithWorkloadIdentityForCluster(t *testing.T, clusterReleaseName model.ReleaseName) error

func InstallNeo4jBackupWithFileCleanup

func InstallNeo4jBackupWithFileCleanup(t *testing.T, standaloneReleaseName model.ReleaseName) error

func InstallNeo4jInGcloud

func InstallNeo4jInGcloud(t *testing.T, zone gcloud.Zone, project gcloud.Project, releaseName model.ReleaseName, chart model.Neo4jHelmChartBuilder, extraHelmInstallArgs ...string) (Closeable, error)

func InstallReverseProxyHelmChart

func InstallReverseProxyHelmChart(t *testing.T, standaloneReleaseName model.ReleaseName) error

func ResourcesCleanup

func ResourcesCleanup(t *testing.T, releaseName model.ReleaseName) error

func ResourcesReinstall

func ResourcesReinstall(t *testing.T, releaseName model.ReleaseName, chart model.Neo4jHelmChartBuilder) error

func RunAsNonRoot

func RunAsNonRoot(t *testing.T, releaseName model.ReleaseName) error

func TestBackupCompressIntegration

func TestBackupCompressIntegration(t *testing.T, releaseName model.ReleaseName) error

func TestBackupLogStreamingIntegration

func TestBackupLogStreamingIntegration(t *testing.T, releaseName model.ReleaseName) error

func TestBackupMultipleEndpointsE2E

func TestBackupMultipleEndpointsE2E(t *testing.T)

func TestClusterProbeConfigurations

func TestClusterProbeConfigurations(t *testing.T)

func TestProbeConfigurations

func TestProbeConfigurations(t *testing.T)

Types

type HTTPGetAction

type HTTPGetAction struct {
	Path string `yaml:"path"`
	Port int32  `yaml:"port"`
}

type ProbeConfig

type ProbeConfig struct {
	HTTPGet             *HTTPGetAction   `yaml:"httpGet,omitempty"`
	TCPSocket           *TCPSocketAction `yaml:"tcpSocket,omitempty"`
	FailureThreshold    int32            `yaml:"failureThreshold"`
	TimeoutSeconds      int32            `yaml:"timeoutSeconds"`
	PeriodSeconds       int32            `yaml:"periodSeconds"`
	InitialDelaySeconds int32            `yaml:"initialDelaySeconds,omitempty"`
}

type SubTest

type SubTest struct {
	// contains filtered or unexported fields
}

type TCPSocketAction

type TCPSocketAction struct {
	Port int32 `yaml:"port"`
}

type ValuesYaml

type ValuesYaml struct {
	ReadinessProbe ProbeConfig `yaml:"readinessProbe"`
	LivenessProbe  ProbeConfig `yaml:"livenessProbe"`
	StartupProbe   ProbeConfig `yaml:"startupProbe"`
}

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL