package tech.powerjob.server.remote.transporter;

import tech.powerjob.common.PowerSerializable;
import tech.powerjob.remote.framework.base.RemotingException;
import tech.powerjob.remote.framework.base.URL;

import java.util.Map;
import java.util.concurrent.CompletionStage;

/**
 * server 数据传输服务
 *
 * @author tjq
 * @since 2023/1/21
 */
public interface TransportService {

    /**
     * 自用地址，用于维护 server -> appId 和 server 间通讯
     * 4.3.0 前为 ActorSystem Address（ip:10086）
     * 4.3.0 后 PowerJob 将主协议切换为自由协议，默认使用 HTTP address （ip:10010）
     * @return 自用地址
     */
    ProtocolInfo defaultProtocol();

    /**
     * 当前支持的全部协议
     * @return allProtocols
     */
    Map<String, ProtocolInfo> allProtocols();

    void tell(String protocol, URL url, PowerSerializable request);

    <T> CompletionStage<T> ask(String protocol, URL url, PowerSerializable request, Class<T> clz) throws RemotingException;

}