This project contains an API for Java Virtual Machine based languages to access Apache Geode/Pivotal GemFire/Pivotal Cloud Cache (PCC) based data grid/cache instances. It builds on top of the of the core Apache Geode APIs. It provides a simpler configuration than Spring Data GemFire or Spring Data Geode (with no additional dependencies).

Simple Configuration

This API is cloud-native friendly. Many of the configurations such as the GemFire LOCATORS connection host[port] can be set using environment variables and or JVM Properties. It requires no XML or Java property files to configure the GemFire connection.

Easy Security

It provides out of box security credential login support. The username and password can be set using an environment variable or JVM property. Password encrypted/decryption is also supported. It supports loading keystore/trustores from the application CLASSPATH for SSL/TLS communication with the GemFire cluster.

This implement is based on the Apache Geode/GemFire Enterprise Data Integration framework open source implementation.

Note that this API is available in the Maven Repository.

<dependency> <groupId>io.pivotal.services.dataTx</groupId> <artifactId>dataTx-geode-extensions-core</artifactId> <version>${VERSION}</version> </dependency> 

Setup Environment Single locator

export LOCATOR_HOST=localhost export LOCATOR_PORT=10334 

or for multiple locators

export LOCATORS=host1[10334],host2[10334] 

Setup Environment Multiple locators

Format: host[port](,host[port])*

Sample:

export LOCATORS=host1[port],host2[port],host2[port] 

Optional Settings

With defaults

export PDX_SERIALIZER_CLASS_NM=... (default org.apache.geode.pdx.ReflectionBasedAutoSerializer) export POOL_PR_SINGLE_HOP_ENABLED=false export PDX_CLASS_PATTERN=.* export USE_CACHING_PROXY=false export PDX_READ_SERIALIZED=false 

If authentication is enabled

export SECURITY_USERNAME=user export SECURITY_PASSWORD=password 

If you need to set PDX read serialize to true (default false).

export PDX_READ_SERIALIZED=true 

Cloud Foundry/ Pivotal Cloud Cache (PCC) Friendly

Pivotal Cloud Cache PCC is Pivotal's 12-factor backing service implementation of GemFire. GeodeClient.connect method supports automatically wiring the locators hosts, ports and security credential when the PCC service is binded a Cloud Foundry application that using this API.

See https://docs.pivotal.io/p-cloud-cache/using-pcc.html#bind-service

cf bind-service [appNAme] [pcc-service] 

SSL key/trust store management

If you need SSL keystore/truststores loading via CLASSPATH for 12 factor cloud native applications such as cloud foundry Spring Boot application see the properties below.

export SSL_KEYSTORE_PASSWORD=... export SSL_PROTOCOLS=TLSv1.2 export SSL_TRUSTSTORE_PASSWORD=... export SSL_KEYSTORE_TYPE=jks export SSL_CIPHERS=TLS_RSA_WITH_AES_128_GCM_SHA256 export SSL_ENABLED_COMPONENTS=gateway,server,locator,jmx export SSL_REQUIRE_AUTHENTICATION=true export SSL_TRUSTSTORE_CLASSPATH_FILE=truststore.jks export SSL_KEYSTORE_CLASSPATH_FILE=keystore.jks 

Get a Apache Geode/GemFire Connection

GeodeClient geodeClient = GeodeClient.connect() 

Get the Apache Geode/GemFire client cache

ClientCache cache = geodeClient.getClientCache(); 

Get a Region

//Does not require a client.xml or pre-registration of the region on the client //But, the region must exist on the server Region<String,PdxInstance> region = geodeClient.getRegion("Test")) 

Execute a Query

Collection<Object> collection = geodeClient.select("select * from /myregion"); 

Get a queue continuous query matches

Queue<Object> queue = registerCq("myQueryName","select * from /myregion")	//get first record	Object object = queue.poll(); //non blocking	//blocking	BlockingQueue<Object> queue = client.registerCq("testCq", "select * from /test"); Object take = queue.take(); 

Register simple java.util.Consumer listeners for region puts/delete events

Consumer<EntryEvent<String, Object>> customer = e -> System.out.println("Put event"+e);	client.registerAfterPut("testEventRegion", putConsumer);	client.getRegion("testEventRegion"); 

The following will extract a single statistic type with the name "CachePerfStats"

`java io.pivotal.services.dataTx.geode.stats.GfStatsReader /stats/stats.gfs CachePerfStats /Projects/stats/CachePerfStats.csv` 

To export all statistics with a file name pattern <name>.gfs.<type>.csv in the same directory as the stat file.

`java io.pivotal.services.dataTx.geode.operations.stats.GfStatsReader /Projects/analysis/DigitIT/stats/stats.gfs` 

See the following for instruction to down the GemFire artifacts.

https://gemfire.docs.pivotal.io/gemfire/getting_started/installation/obtain_gemfire_maven.html