Add Aeron transport stubs

Author: cuihairu

cpp/CMakeLists.txt

@@ -1,7 +1,7 @@
 cmake_minimum_required(VERSION 3.20)
 project(epoch_cpp VERSION 0.1.0 LANGUAGES CXX)
 
-add_library(epoch_cpp src/epoch.cpp src/engine.cpp src/actor_id.cpp)
+add_library(epoch_cpp src/epoch.cpp src/engine.cpp src/actor_id.cpp src/aeron_transport.cpp)
 
 target_include_directories(epoch_cpp PUBLIC ${CMAKE_CURRENT_SOURCE_DIR}/include)
 

cpp/include/epoch/aeron_transport.h

@@ -0,0 +1,28 @@
+#pragma once
+
+#include "epoch/transport.h"
+
+#include <string>
+
+namespace epoch {
+
+struct AeronConfig {
+    std::string channel;
+    std::int32_t stream_id;
+    std::string aeron_directory;
+};
+
+class AeronTransport final : public Transport {
+public:
+    explicit AeronTransport(AeronConfig config);
+
+    void send(const Message &message) override;
+    std::vector<Message> poll(std::size_t max) override;
+    void close() override;
+
+private:
+    AeronConfig config_;
+    bool closed_ = false;
+};
+
+} // namespace epoch

cpp/src/aeron_transport.cpp

@@ -0,0 +1,24 @@
+#include "epoch/aeron_transport.h"
+
+#include <stdexcept>
+
+namespace epoch {
+
+AeronTransport::AeronTransport(AeronConfig config) : config_(std::move(config)) {}
+
+void AeronTransport::send(const Message &)
+{
+    throw std::runtime_error("Aeron transport not linked");
+}
+
+std::vector<Message> AeronTransport::poll(std::size_t)
+{
+    throw std::runtime_error("Aeron transport not linked");
+}
+
+void AeronTransport::close()
+{
+    closed_ = true;
+}
+
+} // namespace epoch

docs/guide/protocol.md

@@ -32,6 +32,12 @@
 ## Aeron 集成
 - 设计说明见：`docs/guide/transport-aeron.md`
 
+## QoS 分级建议
+- `240-255`: 系统/运维命令（如诊断、状态查询）
+- `128-239`: 关键控制类消息
+- `1-127`: 普通业务消息
+- `0`: 默认
+
 ## 测试向量
 - 必须提供“输入明细 + 期望 stateHash”的测试向量
 - 所有语言实现都需复用该向量

dotnet/AeronTransport.cs

@@ -0,0 +1,27 @@
+namespace Epoch;
+
+public sealed class AeronTransport : ITransport
+{
+    public sealed record AeronConfig(string Channel, int StreamId, string AeronDirectory);
+
+    public AeronTransport(AeronConfig config)
+    {
+        Config = config;
+    }
+
+    public AeronConfig Config { get; }
+
+    public void Send(Message message)
+    {
+        throw new NotSupportedException("Aeron transport not linked");
+    }
+
+    public List<Message> Poll(int max)
+    {
+        throw new NotSupportedException("Aeron transport not linked");
+    }
+
+    public void Close()
+    {
+    }
+}

go/aeron_transport.go

@@ -0,0 +1,28 @@
+package epoch
+
+import "fmt"
+
+type AeronConfig struct {
+	Channel        string
+	StreamID       int
+	AeronDirectory string
+}
+
+type AeronTransport struct {
+	config AeronConfig
+}
+
+func NewAeronTransport(config AeronConfig) *AeronTransport {
+	return &AeronTransport{config: config}
+}
+
+func (t *AeronTransport) Send(message Message) {
+	panic(fmt.Errorf("Aeron transport not linked"))
+}
+
+func (t *AeronTransport) Poll(max int) []Message {
+	panic(fmt.Errorf("Aeron transport not linked"))
+}
+
+func (t *AeronTransport) Close() {
+}

java/src/main/java/io/epoch/AeronTransport.java

@@ -0,0 +1,33 @@
+package io.epoch;
+
+import java.util.List;
+
+public final class AeronTransport implements Transport {
+    public record AeronConfig(String channel, int streamId, String aeronDirectory) {
+    }
+
+    private final AeronConfig config;
+
+    public AeronTransport(AeronConfig config) {
+        this.config = config;
+    }
+
+    @Override
+    public void send(Engine.Message message) {
+        throw new UnsupportedOperationException("Aeron transport not linked");
+    }
+
+    @Override
+    public List<Engine.Message> poll(int max) {
+        throw new UnsupportedOperationException("Aeron transport not linked");
+    }
+
+    @Override
+    public void close() {
+        // no-op for stub
+    }
+
+    public AeronConfig config() {
+        return config;
+    }
+}

node/index.js

@@ -81,11 +81,28 @@ class InMemoryTransport {
   }
 }
 
+class AeronTransport {
+  constructor(config) {
+    this.config = config;
+  }
+
+  send() {
+    throw new Error("Aeron transport not linked");
+  }
+
+  poll() {
+    throw new Error("Aeron transport not linked");
+  }
+
+  close() {}
+}
+
 module.exports = {
   version,
   fnv1a64Hex,
   processMessages,
   InMemoryTransport,
+  AeronTransport,
   defaultActorIdCodec: actorId.defaultActorIdCodec,
   encodeActorId: actorId.encodeActorId,
   decodeActorId: actorId.decodeActorId

python/epoch/__init__.py

@@ -5,6 +5,7 @@
     default_actor_id_codec,
     encode_actor_id,
 )
+from .aeron_transport import AeronConfig, AeronTransport
 from .engine import EpochResult, Message, fnv1a64_hex, process_messages
 from .transport import InMemoryTransport, Transport
 
@@ -21,6 +22,8 @@
     "process_messages",
     "Transport",
     "InMemoryTransport",
+    "AeronConfig",
+    "AeronTransport",
 ]
 
 

python/epoch/aeron_transport.py

@@ -0,0 +1,32 @@
+from __future__ import annotations
+
+from dataclasses import dataclass
+from typing import List
+
+from .engine import Message
+from .transport import Transport
+
+
+@dataclass(frozen=True)
+class AeronConfig:
+    channel: str
+    stream_id: int
+    aeron_directory: str
+
+
+class AeronTransport(Transport):
+    def __init__(self, config: AeronConfig) -> None:
+        self._config = config
+
+    @property
+    def config(self) -> AeronConfig:
+        return self._config
+
+    def send(self, message: Message) -> None:
+        raise NotImplementedError("Aeron transport not linked")
+
+    def poll(self, max_items: int) -> List[Message]:
+        raise NotImplementedError("Aeron transport not linked")
+
+    def close(self) -> None:
+        return None