Initial near cache prototype (#71)

* Initial near cache prototype
* Fix tests
* Add example

Author: Tim Middleton

.github/workflows/build-compatability-2206.yaml

@@ -23,13 +23,13 @@ jobs:
       fail-fast: false
       matrix:
         coherenceVersion:
-          - 22.06.6
           - 22.06.7
           - 22.06.8-SNAPSHOT
         go-version:
           - 1.19.x
           - 1.20.x
           - 1.21.x
+          - 1.22.x
 
 #   Checkout the source, we need a depth of zero to fetch all of the history otherwise
 #   the copyright check cannot work out the date of the files from Git.

.github/workflows/build-compatability.yaml

@@ -25,11 +25,11 @@ jobs:
         coherenceVersion:
           - 23.09.3-SNAPSHOT
           - 23.09.2
-          - 23.09.1
         go-version:
           - 1.19.x
           - 1.20.x
           - 1.21.x
+          - 1.22.x
 
 #   Checkout the source, we need a depth of zero to fetch all of the history otherwise
 #   the copyright check cannot work out the date of the files from Git.

.github/workflows/build.yaml

@@ -16,12 +16,14 @@ on:
 jobs:
   build:
     runs-on: ubuntu-latest
+    timeout-minutes: 60
     strategy:
       matrix:
         go-version:
           - 1.19.x
           - 1.20.x
           - 1.21.x
+          - 1.22.x
 
 #   Checkout the source, we need a depth of zero to fetch all of the history otherwise
 #   the copyright check cannot work out the date of the files from Git.
@@ -105,6 +107,7 @@ jobs:
           COHERENCE_TLS_CLIENT_KEY=`pwd`/test/utils/certs/star-lord.key \
           COHERENCE_VERSION=22.06.7 PROFILES=,secure,-jakarta,javax make clean certs generate-proto build-test-images test-e2e-standalone
 
+
     - name: E2E Local Tests SSL (options)
       shell: bash
       run: |

.github/workflows/discovery-compatability-tests.yaml

@@ -20,16 +20,15 @@ jobs:
       fail-fast: false
       matrix:
         coherenceVersion:
-          - 22.06.6
           - 22.06.7
           - 22.06.8-SNAPSHOT
-          - 23.09.1
           - 23.09.2
           - 23.09.3-SNAPSHOT
         go-version:
           - 1.19.x
           - 1.20.x
           - 1.21.x
+          - 1.22.x
 
 #   Checkout the source, we need a depth of zero to fetch all of the history otherwise
 #   the copyright check cannot work out the date of the files from Git.

.github/workflows/discovery-snapshot-tests-22.06.yaml

@@ -28,6 +28,7 @@ jobs:
           - 1.19.x
           - 1.20.x
           - 1.21.x
+          - 1.22.x
 
 #   Checkout the source, we need a depth of zero to fetch all of the history otherwise
 #   the copyright check cannot work out the date of the files from Git.

.github/workflows/examples-jakarta.yaml

@@ -20,13 +20,13 @@ jobs:
       fail-fast: false
       matrix:
         coherenceVersion:
-          - 23.09.1
           - 23.09.2
           - 23.09.3-SNAPSHOT
         go-version:
           - 1.19.x
           - 1.20.x
           - 1.21.x
+          - 1.22.x
 
 #   Checkout the source, we need a depth of zero to fetch all of the history otherwise
 #   the copyright check cannot work out the date of the files from Git.

.github/workflows/examples.yaml

@@ -21,12 +21,12 @@ jobs:
       matrix:
         coherenceVersion:
           - 22.06.8-SNAPSHOT
-          - 22.06.6
           - 22.06.7
         go-version:
           - 1.19.x
           - 1.20.x
           - 1.21.x
+          - 1.22.x
 
 #   Checkout the source, we need a depth of zero to fetch all of the history otherwise
 #   the copyright check cannot work out the date of the files from Git.

Makefile

@@ -8,7 +8,7 @@
 # ----------------------------------------------------------------------------------------------------------------------
 
 # This is the version of the coherence-go-client
-VERSION ?=1.0.3
+VERSION ?=1.1.0
 CURRDIR := $(shell pwd)
 USER_ID := $(shell echo "`id -u`:`id -g`")
 

README.md

@@ -23,7 +23,8 @@ to a Coherence Cluster using gRPC for the network transport.
   * mutations such as insert, update and delete on Maps
   * map lifecycle events such as truncated, released or destroyed
   * session lifecycle events such as connected, disconnected, reconnected and closed 
-* Support for storing Go structs as JSON as well as the ability to serialize to Java objects on the server for access from other Coherence language API's
+* Support for storing Go structs as JSON as well as the ability to serialize to Java objects on the server for access from other Coherence language API's 
+* Near cache support to cache frequently accessed data in the Go client to avoid sending requests across the network
 * Full support for Go generics in all Coherence API's
 
 #### Requirements
@@ -38,7 +39,7 @@ For local development, we recommend using the Coherence CE Docker image; it cont
 everything necessary for the client to operate correctly.
 
 ```bash
-docker run -d -p 1408:1408 -p 30000:30000 ghcr.io/oracle/coherence-ce:23.09.1
+docker run -d -p 1408:1408 -p 30000:30000 ghcr.io/oracle/coherence-ce:23.09.2
 ```
 
 ## Installation

coherence/cache.go

@@ -1,5 +1,5 @@
 /*
- * Copyright (c) 2022, 2023 Oracle and/or its affiliates.
+ * Copyright (c) 2022, 2024 Oracle and/or its affiliates.
  * Licensed under the Universal Permissive License v 1.0 as shown at
  * https://oss.oracle.com/licenses/upl.
  */
@@ -159,15 +159,15 @@ type NamedMap[K comparable, V any] interface {
 	RemoveListener(ctx context.Context, listener MapListener[K, V]) error
 
 	// RemoveMapping removes the entry for the specified key only if it is currently
-	// mapped to the specified value.
+	// mapped to the specified value. Returns true if the value was removed.
 	RemoveMapping(ctx context.Context, key K, value V) (bool, error)
 
 	// Replace replaces the entry for the specified key only if it is
 	// currently mapped to some value.
 	Replace(ctx context.Context, key K, value V) (*V, error)
 
 	// ReplaceMapping replaces the entry for the specified key only if it is
-	// currently mapped to some value. Returns true if the value was replaced
+	// currently mapped to the value. Returns true if the value was replaced.
 	ReplaceMapping(ctx context.Context, key K, prevValue V, newValue V) (bool, error)
 
 	// Size returns the number of mappings contained within the NamedMap.
@@ -176,7 +176,7 @@ type NamedMap[K comparable, V any] interface {
 	// GetSession returns the Session associated with the NamedMap.
 	GetSession() *Session
 
-	// ValuesFilter return a view of filtered values contained in the NamedMap.
+	// ValuesFilter returns a view of filtered values contained in the NamedMap.
 	// The returned channel will be asynchronously filled with values in the
 	// NamedMap that satisfy the filter.
 	ValuesFilter(ctx context.Context, filter filters.Filter) <-chan *StreamedValue[V]
@@ -194,6 +194,10 @@ type NamedMap[K comparable, V any] interface {
 	// storage-enabled members.
 	// If it is not supported by the gRPC proxy, an error will be returned.
 	IsReady(ctx context.Context) (bool, error)
+
+	// GetNearCacheStats returns the [CacheStats] for a near cache for a [NamedMap] or [NamedCache].
+	// If no near cache is defined, nil is returned.
+	GetNearCacheStats() CacheStats
 }
 
 // NamedCache is syntactically identical in behaviour to a NamedMap, but additionally implements