Merge branch 'main' into feature/fix-create-node

Author: bootjp

.github/workflows/docker-image.yml

@@ -1,4 +1,7 @@
 name: Docker Image CI
+permissions:
+  contents: read
+  packages: write
 
 on:
   push:
@@ -14,7 +17,7 @@ jobs:
     runs-on: ubuntu-latest
 
     steps:
-      - uses: actions/checkout@v4
+      - uses: actions/checkout@v6
         with:
           submodules: true
 #      - name: Set up QEMU

.github/workflows/go-mod-fix.yaml

@@ -6,10 +6,12 @@ on:
 
 jobs:
   go-mod-fix:
+    permissions:
+      contents: write
     runs-on: ubuntu-latest
     steps:
       - name: checkout
-        uses: actions/checkout@v4
+        uses: actions/checkout@v6
         with:
           fetch-depth: 2
       - name: fix

.github/workflows/go-test.yml

@@ -8,15 +8,17 @@ concurrency:
 #  cancel-in-progress: true
 
 name: Test
+permissions:
+  contents: read
 jobs:
   test:
     strategy:
       matrix:
         os: [ [ubuntu-latest] ]
     runs-on: ${{ matrix.os }}
     steps:
-      - uses: actions/checkout@v4
-      - uses: actions/setup-go@v5
+      - uses: actions/checkout@v6
+      - uses: actions/setup-go@v6
         with:
           go-version-file: 'go.mod'
       - run: go test -race ./...

.github/workflows/golangci-lint.yml

@@ -11,10 +11,13 @@ concurrency:
 jobs:
   golangci-lint:
     name: golangci-lint
+    permissions:
+      contents: read
+      pull-requests: write
     runs-on: ubuntu-latest
     steps:
       - name: Check out code into the Go module directory
-        uses: actions/checkout@v4
+        uses: actions/checkout@v6
       - name: golangci-lint
         uses: reviewdog/action-golangci-lint@v2
         with:

.github/workflows/jepsen-test.yml

@@ -0,0 +1,28 @@
+on: [ push ]
+
+concurrency:
+  group: ${{ github.workflow }}-${{ github.ref }}-jepsen-test
+
+name: Jepsen Test
+permissions:
+  contents: read
+jobs:
+  test:
+    runs-on: ubuntu-latest
+    env:
+      RUN_JEPSEN: 'true'
+    steps:
+      - uses: actions/checkout@v6
+      - uses: actions/setup-java@v5
+        with:
+          distribution: temurin
+          java-version: '21'
+      - name: Install Leiningen
+        run: |
+          curl -L https://raw.githubusercontent.com/technomancy/leiningen/stable/bin/lein > ~/lein
+          chmod +x ~/lein
+          ~/lein version
+      - name: Run Jepsen tests
+        if: env.RUN_JEPSEN == 'true'
+        working-directory: jepsen
+        run: ~/lein test

.gitignore

@@ -19,3 +19,11 @@
 
 # Go workspace file
 go.work
+
+# Built binary
+/elastickv
+
+# Clojure/Leiningen build artifacts
+jepsen/target/
+jepsen/.lein-*
+jepsen/.nrepl-port

README.md

@@ -71,6 +71,21 @@ quit
 
 ### Development
 
+### Running Jepsen tests
+
+Jepsen tests live in `jepsen/`. Install Leiningen and run tests locally:
+
+```bash
+curl -L https://raw.githubusercontent.com/technomancy/leiningen/stable/bin/lein > ~/lein
+chmod +x ~/lein
+(cd jepsen && ~/lein test)
+```
+
+These Jepsen tests execute concurrent read and write operations while a nemesis
+injects random network partitions. Jepsen's linearizability checker verifies the
+history.
+
+
 
 ### Setup pre-commit hooks
 ```bash

adapter/distribution_server.go

@@ -0,0 +1,43 @@
+package adapter
+
+import (
+	"context"
+
+	"github.com/bootjp/elastickv/distribution"
+	pb "github.com/bootjp/elastickv/proto"
+)
+
+// DistributionServer serves distribution related gRPC APIs.
+type DistributionServer struct {
+	engine *distribution.Engine
+	pb.UnimplementedDistributionServer
+}
+
+// NewDistributionServer creates a new server.
+func NewDistributionServer(e *distribution.Engine) *DistributionServer {
+	return &DistributionServer{engine: e}
+}
+
+// UpdateRoute allows updating route information.
+func (s *DistributionServer) UpdateRoute(start, end []byte, group uint64) {
+	s.engine.UpdateRoute(start, end, group)
+}
+
+// GetRoute returns route for a key.
+func (s *DistributionServer) GetRoute(ctx context.Context, req *pb.GetRouteRequest) (*pb.GetRouteResponse, error) {
+	r, ok := s.engine.GetRoute(req.Key)
+	if !ok {
+		return &pb.GetRouteResponse{}, nil
+	}
+	return &pb.GetRouteResponse{
+		Start:       r.Start,
+		End:         r.End,
+		RaftGroupId: r.GroupID,
+	}, nil
+}
+
+// GetTimestamp returns monotonically increasing timestamp.
+func (s *DistributionServer) GetTimestamp(ctx context.Context, req *pb.GetTimestampRequest) (*pb.GetTimestampResponse, error) {
+	ts := s.engine.NextTimestamp()
+	return &pb.GetTimestampResponse{Timestamp: ts}, nil
+}