Added internal CPMap functions (#987)

Added internal CPMap functions
hazelcast · Dec 11, 2023 · f728b86 · f728b86
1 parent b0af758
commit f728b86
Show file tree

Hide file tree

Showing 3 changed files with 18 additions and 3 deletions.
diff --git a/.github/workflows/nightly_tests.yaml b/.github/workflows/nightly_tests.yaml
@@ -11,7 +11,7 @@ jobs:
     strategy:
         matrix:
             os: [ ubuntu-latest ]
-            go_version: [ 1.20, 1.21 ]
+            go_version: [ "1.20", "1.21" ]
         fail-fast: false
     steps:
 
@@ -22,7 +22,7 @@ jobs:
 
       - uses: actions/setup-go@v2
         with:
-          go-version: ${{ matrix.go_version }}
+          go-version: "${{ matrix.go_version }}"
 
       - name: Checkout code
         uses: actions/checkout@v2

diff --git a/client.go b/client.go
@@ -47,6 +47,7 @@ const (
 
 type AtomicLong = icp.AtomicLong
 type AtomicRef = icp.AtomicRef
+type CPMap = icp.Map
 type CPSubsystem = icp.Subsystem
 
 func NewLockContext(ctx context.Context) context.Context {

diff --git a/client_internals.go b/client_internals.go
@@ -194,7 +194,7 @@ func (ci *ClientInternal) PartitionCount() int32 {
 	return ci.client.ic.PartitionService.PartitionCount()
 }
 
-// Internal AtomicRef methods
+// Internal AtomicRef functions
 
 func AtomicRefGetData(ctx context.Context, ar *AtomicRef) (Data, error) {
 	return icp.AtomicRefGetData(ctx, ar)
@@ -204,6 +204,20 @@ func AtomicRefGetAndSetData(ctx context.Context, ar *AtomicRef, value Data) (Dat
 	return icp.AtomicRefGetAndSetData(ctx, ar, value)
 }
 
+// Internal CPMap functions
+
+func CPMapGetData(ctx context.Context, m *CPMap, key Data) (Data, error) {
+	return icp.CPMapGetData(ctx, m, key)
+}
+
+func CPMapPutData(ctx context.Context, m *CPMap, key, value Data) (Data, error) {
+	return icp.CPMapPutData(ctx, m, key, value)
+}
+
+func CPMapRemoveData(ctx context.Context, m *CPMap, key Data) (Data, error) {
+	return icp.CPMapRemoveData(ctx, m, key)
+}
+
 const (
 	TypeFieldOffset                      = proto.TypeFieldOffset
 	MessageTypeOffset                    = proto.MessageTypeOffset