Integrate V1 Protocol Support, and Near Caching

.coveragerc

@@ -4,3 +4,11 @@ omit =
   src/coherence/messages_pb2_grpc.py
   src/coherence/services_pb2.py
   src/coherence/services_pb2_grpc.py
+  src/coherence/cache_service_messages_v1_pb2.py
+  src/coherence/cache_service_messages_v1_pb2_grpc.py
+  src/coherence/common_messages_v1_pb2.py
+  src/coherence/common_messages_v1_pb2_grpc.py
+  src/coherence/proxy_service_messages_v1_pb2.py
+  src/coherence/proxy_service_messages_v1_pb2_grpc.py
+  src/coherence/proxy_service_v1_pb2.py
+  src/coherence/proxy_service_v1_pb2_grpc.py

.github/workflows/validate.yml

@@ -17,19 +17,19 @@ jobs:
     strategy:
       fail-fast: false
       matrix:
-        python-version: ["3.8.x", "3.9.x", "3.10.x", "3.11.x"]
-        poetry-version: ["1.5.0"]
+        python-version: ["3.9.x", "3.10.x", "3.11.x", "3.12.x", "3.13.x"]
+        poetry-version: ["1.8.4"]
         os: [ubuntu-latest]
         coherenceVersion:
-          - 24.03
+          - 24.09
           - 22.06.10
         base-image:
           - gcr.io/distroless/java17-debian11
         profile:
           - ",-jakarta,javax"
           - ",jakarta,-javax"
         exclude:
-          - coherenceVersion: 24.03
+          - coherenceVersion: 24.09
             profile: ",-jakarta,javax"
           - coherenceVersion: 22.06.10
             profile: ",jakarta,-javax"

.pre-commit-config.yaml

@@ -8,29 +8,29 @@ exclude: \w*(_pb2)\w*
 
 repos:
 -   repo: https://github.com/pre-commit/pre-commit-hooks
-    rev: v4.6.0
+    rev: cef0300fd0fc4d2a87a85fa2093c6b283ea36f4b  # frozen: v5.0.0
     hooks:
     -   id: trailing-whitespace
     -   id: end-of-file-fixer
     -   id: check-yaml
     -   id: check-added-large-files
 
 -   repo: https://github.com/PyCQA/flake8
-    rev: 7.1.1
+    rev: e43806be3607110919eff72939fda031776e885a  # frozen: 7.1.1
     hooks:
         - id: flake8
 
 -   repo: https://github.com/psf/black
-    rev: 24.8.0
+    rev: 1b2427a2b785cc4aac97c19bb4b9a0de063f9547  # frozen: 24.10.0
     hooks:
         - id: black
 
 -   repo: https://github.com/pre-commit/mirrors-mypy
-    rev: v1.11.2
+    rev: f56614daa94d5cd733d3b7004c5df9caad267b4a  # frozen: v1.13.0
     hooks:
         - id: mypy
 
 -   repo: https://github.com/PyCQA/isort
-    rev: 5.13.2
+    rev: c235f5e450b4b84e58d114ed4c589cbf454175a3  # frozen: 5.13.2
     hooks:
         - id: isort

Makefile

@@ -38,8 +38,8 @@ COHERENCE_WKA1 ?= server1
 COHERENCE_WKA2 ?= server1
 CLUSTER_PORT ?= 7574
 # Profiles to include for building
-PROFILES ?= ",-jakarta,javax"
-COHERENCE_BASE_IMAGE ?= gcr.io/distroless/java17-debian11
+PROFILES ?= ",jakarta,-javax"
+COHERENCE_BASE_IMAGE ?= gcr.io/distroless/java17-debian12
 
 # ----------------------------------------------------------------------------------------------------------------------
 # Set the location of various build tools
@@ -66,6 +66,27 @@ CURRDIR := $(shell pwd)
 COMPOSE:=$(shell type -p docker-compose || echo docker compose)
 $(info COMPOSE = $(COMPOSE))
 
+# ----------------------------------------------------------------------------------------------------------------------
+# List of unit tests
+# ----------------------------------------------------------------------------------------------------------------------
+UNIT_TESTS := tests/unit/test_cache_options.py \
+                tests/unit/test_local_cache.py \
+				tests/unit/test_environment.py \
+				tests/unit/test_serialization.py \
+				tests/unit/test_extractors.py
+
+# ----------------------------------------------------------------------------------------------------------------------
+# List of E2E tests
+# ----------------------------------------------------------------------------------------------------------------------
+E2E_TESTS := tests/e2e/test_session.py \
+				tests/e2e/test_client.py \
+				tests/e2e/test_events.py \
+				tests/e2e/test_filters.py \
+				tests/e2e/test_processors.py \
+				tests/e2e/test_aggregators.py \
+				tests/e2e/test_near_caching.py \
+#				tests/e2e/test_ai.py \
+
 # ----------------------------------------------------------------------------------------------------------------------
 # Clean-up all of the build artifacts
 # ----------------------------------------------------------------------------------------------------------------------
@@ -116,21 +137,53 @@ generate-proto:  ## Generate Proto Files
 	sed -e 's/import messages_pb2 as messages__pb2/import coherence.messages_pb2 as messages__pb2/' \
 		< $(CURRDIR)/src/coherence/services_pb2_grpc.py > $(CURRDIR)/src/coherence/services_pb2_grpc.py.out
 	mv $(CURRDIR)/src/coherence/services_pb2_grpc.py.out $(CURRDIR)/src/coherence/services_pb2_grpc.py
+	curl -o $(PROTO_DIR)/proxy_service_v1.proto \
+			https://raw.githubusercontent.com/oracle/coherence/$(COHERENCE_VERSION)/prj/coherence-grpc/src/main/proto/proxy_service_v1.proto
+		curl -o $(PROTO_DIR)/proxy_service_messages_v1.proto \
+			https://raw.githubusercontent.com/oracle/coherence/$(COHERENCE_VERSION)/prj/coherence-grpc/src/main/proto/proxy_service_messages_v1.proto
+		curl -o $(PROTO_DIR)/common_messages_v1.proto \
+			https://raw.githubusercontent.com/oracle/coherence/$(COHERENCE_VERSION)/prj/coherence-grpc/src/main/proto/common_messages_v1.proto
+		curl -o $(PROTO_DIR)/cache_service_messages_v1.proto \
+			https://raw.githubusercontent.com/oracle/coherence/$(COHERENCE_VERSION)/prj/coherence-grpc/src/main/proto/cache_service_messages_v1.proto
+		python -m grpc_tools.protoc --proto_path=$(CURRDIR)/etc/proto --pyi_out=$(CURRDIR)/src/coherence --python_out=$(CURRDIR)/src/coherence \
+				--grpc_python_out=$(CURRDIR)/src/coherence \
+				$(CURRDIR)/etc/proto/proxy_service_v1.proto \
+				$(CURRDIR)/etc/proto/proxy_service_messages_v1.proto \
+				$(CURRDIR)/etc/proto/common_messages_v1.proto \
+				$(CURRDIR)/etc/proto/cache_service_messages_v1.proto
+		sed -e 's/import proxy_service_messages_v1_pb2 as proxy__service__messages__v1__pb2/import coherence.proxy_service_messages_v1_pb2 as proxy__service__messages__v1__pb2/' \
+			< $(CURRDIR)/src/coherence/proxy_service_v1_pb2.py > $(CURRDIR)/src/coherence/proxy_service_v1_pb2.py.out
+		mv $(CURRDIR)/src/coherence/proxy_service_v1_pb2.py.out $(CURRDIR)/src/coherence/proxy_service_v1_pb2.py
+		sed -e 's/import common_messages_v1_pb2 as common__messages__v1__pb2/import coherence.common_messages_v1_pb2 as common__messages__v1__pb2/' \
+			< $(CURRDIR)/src/coherence/proxy_service_messages_v1_pb2.py > $(CURRDIR)/src/coherence/proxy_service_messages_v1_pb2.py.out
+		mv $(CURRDIR)/src/coherence/proxy_service_messages_v1_pb2.py.out $(CURRDIR)/src/coherence/proxy_service_messages_v1_pb2.py
+		sed -e 's/import proxy_service_messages_v1_pb2 as proxy__service__messages__v1__pb2/import coherence.proxy_service_messages_v1_pb2 as proxy__service__messages__v1__pb2/' \
+			< $(CURRDIR)/src/coherence/proxy_service_v1_pb2_grpc.py > $(CURRDIR)/src/coherence/proxy_service_v1_pb2_grpc.py.out
+		mv $(CURRDIR)/src/coherence/proxy_service_v1_pb2_grpc.py.out $(CURRDIR)/src/coherence/proxy_service_v1_pb2_grpc.py
+		sed -e 's/import common_messages_v1_pb2 as common__messages__v1__pb2/import coherence.common_messages_v1_pb2 as common__messages__v1__pb2/' \
+			< $(CURRDIR)/src/coherence/cache_service_messages_v1_pb2.py > $(CURRDIR)/src/coherence/cache_service_messages_v1_pb2.py.out
+		mv $(CURRDIR)/src/coherence/cache_service_messages_v1_pb2.py.out $(CURRDIR)/src/coherence/cache_service_messages_v1_pb2.py
 
 # ----------------------------------------------------------------------------------------------------------------------
 # Run tests with code coverage
 # ----------------------------------------------------------------------------------------------------------------------
 .PHONY: test
 test:  ##
-	pytest -W error --cov src/coherence --cov-report=term --cov-report=html \
-		tests/test_serialization.py \
-		tests/test_extractors.py \
-		tests/test_session.py \
-		tests/test_client.py \
-		tests/test_events.py \
-		tests/test_filters.py \
-		tests/test_processors.py \
-		tests/test_aggregators.py \
+	pytest -W error --cov src/coherence --cov-report=term --cov-report=html $(UNIT_TESTS) $(E2E_TESTS)
+
+# ----------------------------------------------------------------------------------------------------------------------
+# Run unit tests with code coverage
+# ----------------------------------------------------------------------------------------------------------------------
+.PHONY: test-unit
+test-unit:  ##
+	pytest -W error --cov src/coherence --cov-report=term --cov-report=html $(UNIT_TESTS)
+
+# ----------------------------------------------------------------------------------------------------------------------
+# Run e2e tests with code coverage
+# ----------------------------------------------------------------------------------------------------------------------
+.PHONY: test-e2e
+test-e2e:  ##
+	pytest -W error --cov src/coherence --cov-report=term --cov-report=html $(E2E_TESTS)
 
 # ----------------------------------------------------------------------------------------------------------------------
 # Run standards validation across project

docs/api_reference.rst

@@ -11,6 +11,18 @@ Aggregators
 .. autoclass:: coherence.Aggregators
     :members:
 
+CacheOptions
+------------
+.. autoclass:: coherence.CacheOptions
+    :members:
+
+    .. automethod:: __init__
+
+CacheStats
+------------
+.. autoclass:: coherence.CacheStats
+    :members:
+
 Comparator
 ----------
 .. autoclass:: coherence.Comparator
@@ -58,6 +70,13 @@ NamedMap
     :show-inheritance:
     :members:
 
+NearCacheOptions
+----------------
+.. autoclass:: coherence.NearCacheOptions
+    :members:
+
+    .. automethod:: __init__
+
 Options
 -------
 .. autoclass:: coherence.Options