refactor(forest): 优化 url 书写
This commit is contained in:
@@ -13,38 +13,38 @@ import org.eclipse.collections.api.map.ImmutableMap;
|
|||||||
* @author lanyuanxiaoyao
|
* @author lanyuanxiaoyao
|
||||||
* @date 2023-05-05
|
* @date 2023-05-05
|
||||||
*/
|
*/
|
||||||
@BaseRequest(baseURL = "http://service-flink-query")
|
@BaseRequest(baseURL = "http://service-flink-query/flink")
|
||||||
public interface FlinkService {
|
public interface FlinkService {
|
||||||
@Get("/flink/overview")
|
@Get("/overview")
|
||||||
FlinkOverview overview(@Query("url") String url);
|
FlinkOverview overview(@Query("url") String url);
|
||||||
|
|
||||||
@Get("/flink/config")
|
@Get("/config")
|
||||||
FlinkConfig config(@Query("url") String url);
|
FlinkConfig config(@Query("url") String url);
|
||||||
|
|
||||||
@Get("/flink/job_manager_config")
|
@Get("/job_manager_config")
|
||||||
ImmutableList<FlinkKeyValue> jobManagerConfig(@Query("url") String url);
|
ImmutableList<FlinkKeyValue> jobManagerConfig(@Query("url") String url);
|
||||||
|
|
||||||
@Get("/flink/vertex_overview")
|
@Get("/vertex_overview")
|
||||||
FlinkVertexOverview vertexOverview(@Query("url") String url);
|
FlinkVertexOverview vertexOverview(@Query("url") String url);
|
||||||
|
|
||||||
@Get("/flink/vertex")
|
@Get("/vertex")
|
||||||
FlinkVertex vertex(@Query("url") String url, @Query("vertex_id") String vertexId);
|
FlinkVertex vertex(@Query("url") String url, @Query("vertex_id") String vertexId);
|
||||||
|
|
||||||
@Get("/flink/vertex_config")
|
@Get("/vertex_config")
|
||||||
FlinkVertexConfig vertexConfig(@Query("url") String url, @Query("vertex_id") String vertexId);
|
FlinkVertexConfig vertexConfig(@Query("url") String url, @Query("vertex_id") String vertexId);
|
||||||
|
|
||||||
@Get("/flink/checkpoint_overview")
|
@Get("/checkpoint_overview")
|
||||||
FlinkCheckpointOverview checkpointOverview(@Query("url") String url, @Query("vertex_id") String vertexId);
|
FlinkCheckpointOverview checkpointOverview(@Query("url") String url, @Query("vertex_id") String vertexId);
|
||||||
|
|
||||||
@Get("/flink/checkpoint")
|
@Get("/checkpoint")
|
||||||
FlinkCheckpoint checkpoint(@Query("url") String url, @Query("vertex_id") String vertexId, @Query("checkpoint_id") Long checkpointId);
|
FlinkCheckpoint checkpoint(@Query("url") String url, @Query("vertex_id") String vertexId, @Query("checkpoint_id") Long checkpointId);
|
||||||
|
|
||||||
@Get("/flink/checkpoint_config")
|
@Get("/checkpoint_config")
|
||||||
FlinkCheckpointConfig checkpointConfig(@Query("url") String url, @Query("vertex_id") String vertexId);
|
FlinkCheckpointConfig checkpointConfig(@Query("url") String url, @Query("vertex_id") String vertexId);
|
||||||
|
|
||||||
@Get("/flink/task_manager_overview")
|
@Get("/task_manager_overview")
|
||||||
FlinkTaskManagerOverview taskManagerOverview(@Query("url") String url);
|
FlinkTaskManagerOverview taskManagerOverview(@Query("url") String url);
|
||||||
|
|
||||||
@Get("/flink/task_manager")
|
@Get("/task_manager")
|
||||||
FlinkTaskManager taskManager(@Query("url") String url, @Query("task_manager_id") String taskManagerId);
|
FlinkTaskManager taskManager(@Query("url") String url, @Query("task_manager_id") String taskManagerId);
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -18,29 +18,29 @@ import org.eclipse.collections.api.list.ImmutableList;
|
|||||||
* @author lanyuanxiaoyao
|
* @author lanyuanxiaoyao
|
||||||
* @date 2023-04-24
|
* @date 2023-04-24
|
||||||
*/
|
*/
|
||||||
@BaseRequest(baseURL = "http://service-info-query")
|
@BaseRequest(baseURL = "http://service-info-query/info")
|
||||||
public interface InfoService {
|
public interface InfoService {
|
||||||
@Get("/info/job_id_alias")
|
@Get("/job_id_alias")
|
||||||
PageResponse<JobIdAndAlias> jobIdAndAlias(@Query Map<String, Object> queryMap);
|
PageResponse<JobIdAndAlias> jobIdAndAlias(@Query Map<String, Object> queryMap);
|
||||||
|
|
||||||
@Get("/info/job_metas")
|
@Get("/job_metas")
|
||||||
ImmutableList<JobAndMetas> jobAndMetas();
|
ImmutableList<JobAndMetas> jobAndMetas();
|
||||||
|
|
||||||
@Get("/info/flink_job/list")
|
@Get("/flink_job/list")
|
||||||
ImmutableList<FlinkJob> flinkJobList();
|
ImmutableList<FlinkJob> flinkJobList();
|
||||||
|
|
||||||
@Get("/info/flink_job/detail")
|
@Get("/flink_job/detail")
|
||||||
FlinkJob flinkJobDetail(@Query("flink_job_id") Long flinkJobId);
|
FlinkJob flinkJobDetail(@Query("flink_job_id") Long flinkJobId);
|
||||||
|
|
||||||
@Get("/info/table_meta/list")
|
@Get("/table_meta/list")
|
||||||
ImmutableList<TableMeta> tableMetaList();
|
ImmutableList<TableMeta> tableMetaList();
|
||||||
|
|
||||||
@Get("/info/table_meta/list")
|
@Get("/table_meta/list")
|
||||||
ImmutableList<TableMeta> tableMetaList(@Query("flink_job_id") Long flinkJobId);
|
ImmutableList<TableMeta> tableMetaList(@Query("flink_job_id") Long flinkJobId);
|
||||||
|
|
||||||
@Get("/info/table_meta/detail")
|
@Get("/table_meta/detail")
|
||||||
TableMeta tableMetaDetail(@Query("flink_job_id") Long flinkJobId, @Query("alias") String alias);
|
TableMeta tableMetaDetail(@Query("flink_job_id") Long flinkJobId, @Query("alias") String alias);
|
||||||
|
|
||||||
@Get("/info/sync_state/detail")
|
@Get("/sync_state/detail")
|
||||||
SyncState syncStateDetail(@Query("flink_job_id") Long flinkJobId, @Query("alias") String alias);
|
SyncState syncStateDetail(@Query("flink_job_id") Long flinkJobId, @Query("alias") String alias);
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -14,23 +14,23 @@ import org.eclipse.collections.api.list.ImmutableList;
|
|||||||
* @author lanyuanxiaoyao
|
* @author lanyuanxiaoyao
|
||||||
* @date 2023-04-28
|
* @date 2023-04-28
|
||||||
*/
|
*/
|
||||||
@BaseRequest(baseURL = "http://service-pulsar-query")
|
@BaseRequest(baseURL = "http://service-pulsar-query/pulsar")
|
||||||
public interface PulsarService {
|
public interface PulsarService {
|
||||||
@Get("/pulsar/name")
|
@Get("/name")
|
||||||
String name(@Query("pulsar_url") String pulsarUrl);
|
String name(@Query("pulsar_url") String pulsarUrl);
|
||||||
|
|
||||||
@Get("/pulsar/names")
|
@Get("/names")
|
||||||
ImmutableList<String> names();
|
ImmutableList<String> names();
|
||||||
|
|
||||||
@Get("/pulsar/tenants")
|
@Get("/tenants")
|
||||||
ImmutableList<PulsarTenant> tenants(@Query("name") String name);
|
ImmutableList<PulsarTenant> tenants(@Query("name") String name);
|
||||||
|
|
||||||
@Get("/pulsar/namespaces")
|
@Get("/namespaces")
|
||||||
ImmutableList<PulsarNamespace> namespaces(@Query("name") String name, @Query("tenant") String tenant);
|
ImmutableList<PulsarNamespace> namespaces(@Query("name") String name, @Query("tenant") String tenant);
|
||||||
|
|
||||||
@Get("/pulsar/topic")
|
@Get("/topic")
|
||||||
PulsarTopic topic(@Query("name") String name, @Query("topic") String topic);
|
PulsarTopic topic(@Query("name") String name, @Query("topic") String topic);
|
||||||
|
|
||||||
@Get("/pulsar/topics")
|
@Get("/topics")
|
||||||
ImmutableList<PulsarTopic> topics(@Query("name") String name, @Query("namespace") String namespace);
|
ImmutableList<PulsarTopic> topics(@Query("name") String name, @Query("namespace") String namespace);
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -10,7 +10,7 @@ import com.dtflys.forest.annotation.Query;
|
|||||||
* @author lanyuanxiaoyao
|
* @author lanyuanxiaoyao
|
||||||
* @date 2023-05-13
|
* @date 2023-05-13
|
||||||
*/
|
*/
|
||||||
@BaseRequest(baseURL = "http://service-zookeeper-query")
|
@BaseRequest(baseURL = "http://service-zookeeper-query/zookeeper")
|
||||||
public interface ZookeeperService {
|
public interface ZookeeperService {
|
||||||
@Get("/exists_path")
|
@Get("/exists_path")
|
||||||
Boolean existsPath(@Query("path") String path);
|
Boolean existsPath(@Query("path") String path);
|
||||||
|
|||||||
Reference in New Issue
Block a user