org.apache.beam.it.neo4j

Class Neo4jResourceManager

java.lang.Object

org.apache.beam.it.testcontainers.TestContainerResourceManager<Neo4jContainer<?>>

org.apache.beam.it.neo4j.Neo4jResourceManager

All Implemented Interfaces:

org.apache.beam.it.common.ResourceManager

public class Neo4jResourceManager
extends TestContainerResourceManager<Neo4jContainer<?>>
implements org.apache.beam.it.common.ResourceManager

Client for managing Neo4j resources.

The database name is formed using testId. The database name will be "{testId}-{ISO8601 time, microsecond precision}", with additional formatting.

The class is thread-safe.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	Neo4jResourceManager.Builder Builder for Neo4jResourceManager.

Field Summary

Fields inherited from class org.apache.beam.it.testcontainers.TestContainerResourceManager

HOST_IP, port

Method Summary

Modifier and Type	Method and Description
static Neo4jResourceManager.Builder	builder(java.lang.String testId)
void	cleanupAll() Deletes all created resources (VM's, etc.) and stops the container, making the manager object unusable.
java.lang.String	getAdminPassword()
java.lang.String	getDatabaseName() Returns the name of the Database that this Neo4j manager will operate in.
java.lang.String	getUri() Returns the URI connection string to the Neo4j Database.
java.util.List<java.util.Map<java.lang.String,java.lang.Object>>	run(java.lang.String query)
java.util.List<java.util.Map<java.lang.String,java.lang.Object>>	run(java.lang.String query, java.util.Map<java.lang.String,java.lang.Object> parameters)

Methods inherited from class org.apache.beam.it.testcontainers.TestContainerResourceManager

getDockerImageName, getHost, getPort

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

builder

public static Neo4jResourceManager.Builder builder(java.lang.String testId)

getUri

public java.lang.String getUri()

Returns the URI connection string to the Neo4j Database.

run

public java.util.List<java.util.Map<java.lang.String,java.lang.Object>> run(java.lang.String query)

run

public java.util.List<java.util.Map<java.lang.String,java.lang.Object>> run(java.lang.String query,
                                                                            java.util.Map<java.lang.String,java.lang.Object> parameters)

getDatabaseName

public java.lang.String getDatabaseName()

Returns the name of the Database that this Neo4j manager will operate in.

Returns:

the name of the Neo4j Database.

cleanupAll

public void cleanupAll()

Description copied from class: TestContainerResourceManager

Deletes all created resources (VM's, etc.) and stops the container, making the manager object unusable.

Specified by:

cleanupAll in interface org.apache.beam.it.common.ResourceManager

Overrides:

cleanupAll in class TestContainerResourceManager<Neo4jContainer<?>>

getAdminPassword

public java.lang.String getAdminPassword()