using System;
|
using System.Threading;
|
using System.Threading.Tasks;
|
|
namespace Aging.Infrastructure.Drivers
|
{
|
/// <summary>
|
/// CAN 驱动传输后端抽象：屏蔽 Local(TCP 直连模拟器) 与 Broker(命名管道委托宿主) 差异。
|
/// 上层 <see cref="CanDeviceDriver"/> 只与本接口交互，命令串语义原样透传。
|
/// </summary>
|
internal interface ICanTransport : IDisposable
|
{
|
/// <summary>后端是否处于可用连接态</summary>
|
bool IsConnected { get; }
|
|
/// <summary>建立通道（TCP 连接 + HELLO 挂载 / Broker CONNECT 注册物理会话）</summary>
|
Task ConnectAsync(string busName, int nodeIndex, CancellationToken ct);
|
|
/// <summary>断开当前节点挂载（TCP DISCONNECT / Broker DISCONNECT）</summary>
|
Task DisconnectAsync();
|
|
/// <summary>
|
/// 发送一行命令并等待响应行。line 为完整命令串（SEND:… 或 QUERY:…）。
|
/// 返回响应文本（含 OK:/ERR: 前缀，由上层解析）；超时/断线抛异常。
|
/// </summary>
|
Task<string> TransceiveAsync(string line, CancellationToken ct);
|
|
/// <summary>服务端推送的 EV:RECV 行到达（NodeChannel 为 TCP 直推；BrokerRpc 为随响应捎带）</summary>
|
event Action<string> FramePushed;
|
|
/// <summary>通道断裂事件（触发上层重连/状态更新）</summary>
|
event Action TransportBroken;
|
}
|
}
|
