using System;

namespace Aivfo.OperationLog
{
    /// <summary>
    /// 操作日志传输抽象。默认 Kafka 实现；离线/测试可换其它实现（如写文件再转发）。
    /// </summary>
    public interface IOplogTransport : IDisposable
    {
        /// <summary>发送一条 JSON 消息到目标（同步阻塞由后台线程调用，不在业务线程上）。</summary>
        void Send(string json);

        /// <summary>flush 缓冲，确保已发出（用于退出/测试）。</summary>
        void Flush(TimeSpan timeout);
    }
}