controllers

package
v0.0.0-...-b81b3d3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 10, 2024 License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ClusterController 

type ClusterController struct{}

func (*ClusterController) CreateCluster 

func (c *ClusterController) CreateCluster(ctx *gin.Context)

CreateCluster 创建集群信息 @Router /cluster [post] @Description 创建源端信息 @Tags 集群管理 @Param Cluster body services.ClusterService true "Cluster" @Success 200 {object} common.Response{data=services.ClusterService} @Failure 500 {object} common.Response

func (*ClusterController) DeleteCluster 

func (c *ClusterController) DeleteCluster(ctx *gin.Context)

DeleteCluster 删除集群信息 @Router /cluster [delete] @Description 删除集群信息 @Tags 集群管理 @Param Cluster body services.ClusterService true "Cluster" @Success 200 {object} common.Response @Failure 500 {object} common.Response

func (*ClusterController) GetClusterBigTables 

func (c *ClusterController) GetClusterBigTables(ctx *gin.Context)

GetClusterBigTables 获取集群的大表信息（默认只获取10G以上的大表） @Router /cluster/bigtable [get] @Description 获取集群的大表信息（默认只获取10G以上的大表） @Tags 集群管理 @Success 200 {object} common.Response @Failure 500 {object} common.Response

func (*ClusterController) GetClusterDatabases 

func (c *ClusterController) GetClusterDatabases(ctx *gin.Context)

GetClusterDatabases 查询指定数据库集群的库列表 @Router /cluster/{cluster_id}/databases [get] @Description 查询指定数据库集群的库列表 @Tags 集群管理 @Param cluster_id path string true "cluster id" @Success 200 {object} common.Response{data=[]string} @Failure 500 {object} common.Response

func (*ClusterController) GetClusterTables 

func (c *ClusterController) GetClusterTables(ctx *gin.Context)

GetClusterTables 查询指定数据库集群的库列表 @Router /cluster/{cluster_id}/{database}/tables [get] @Description 查询指定数据库集群的库列表 @Tags 集群管理 @Param cluster_id path string true "cluster id" @Param database path string true "database name" @Success 200 {object} common.Response{data=[]string} @Failure 500 {object} common.Response

func (*ClusterController) QueryCluster 

func (c *ClusterController) QueryCluster(ctx *gin.Context)

QueryCluster 查询集群信息 @Router /cluster [get] @Description 查询集群信息 @Tags 集群管理 @Param page query int false "page" @Param pageSize query int false "pageSize" @Param id query uint false "ID" @Param creator query string false "创建人" @Param editor query string false "修改人" @Param cluster_id query string false "cluster_id" @Param cluster_name query string false "集群名称" @Param description query string false "说明" @Param bu query string false "bu" @Param env query string false "env" @Param import_from query string false "添加方式：customized:自定义添加 ipaas:从资源中心导入" @Param cluster_type query string false "集群类型（mysql, 其他的）" @Param service_addr query string false "集群访问地址" @Param write_addr query string false "主库地址" @Param read_addr query string false "从库地址" @Param user_name query string false "用户名" @Success 200 {object} common.Response{data=services.ClusterService} @Failure 500 {object} common.Response

func (*ClusterController) SyncCluster 

func (c *ClusterController) SyncCluster(ctx *gin.Context)

SyncCluster 同步集群信息 @Router /cluster/sync [get] @Description 同步集群信息 @Tags 集群管理 @Success 200 {object} common.Response @Failure 500 {object} common.Response

func (*ClusterController) UpdateCluster 

func (c *ClusterController) UpdateCluster(ctx *gin.Context)

UpdateCluster 更新集群信息 @Router /cluster [put] @Description 更新集群信息 @Tags 集群管理 @Param Cluster body services.ClusterService true "Cluster" @Success 200 {object} common.Response{data=services.ClusterService} @Failure 500 {object} common.Response

type ClusterStatisticController 

type ClusterStatisticController struct{}

func (*ClusterStatisticController) ClusterStatisticGroupByBu 

func (c *ClusterStatisticController) ClusterStatisticGroupByBu(ctx *gin.Context)

ClusterStatisticGroupByBu 查询bu维度集群的大表统计信息 @Router /cluster/statistic/bu [get] @Description 查询集群维度集群的大表统计信息 @Tags 统计信息 @Param start_date query string false "统计开始日期" @Param end_date query string false "统计结束日期" @Param start_size query string false "统计大于等于该值的表" @Param end_size query string false "统计小于等于该值的表" @Param bu query string false "BU" @Success 200 {object} common.Response{data=services.ClusterStatistic} @Failure 500 {object} common.Response

func (*ClusterStatisticController) ClusterStatisticGroupByCluster 

func (c *ClusterStatisticController) ClusterStatisticGroupByCluster(ctx *gin.Context)

ClusterStatisticGroupByCluster 查询集群维度集群的大表统计信息 @Router /cluster/statistic/cluster [get] @Description 查询集群维度集群的大表统计信息 @Tags 统计信息 @Param start_date query string false "统计开始日期" @Param end_date query string false "统计结束日期" @Param start_size query string false "统计大于等于该值的表" @Param end_size query string false "统计小于等于该值的表" @Param bu query string false "BU" @Param cluster_id query string false "集群ID" @Param cluster_name query string false "集群名称" @Success 200 {object} common.Response{data=services.ClusterStatistic} @Failure 500 {object} common.Response

func (*ClusterStatisticController) ClusterStatisticGroupByDatabase 

func (c *ClusterStatisticController) ClusterStatisticGroupByDatabase(ctx *gin.Context)

ClusterStatisticGroupByDatabase 查询库维度集群的大表统计信息 @Router /cluster/statistic/database [get] @Description 查询库维度集群的大表统计信息 @Tags 统计信息 @Param start_date query string false "统计开始日期" @Param end_date query string false "统计结束日期" @Param start_size query string false "统计大于等于该值的表" @Param end_size query string false "统计小于等于该值的表" @Param bu query string false "BU" @Param cluster_id query string false "集群ID" @Param cluster_name query string false "集群名称" @Param database query string false "库名" @Success 200 {object} common.Response{data=services.ClusterStatistic} @Failure 500 {object} common.Response

func (*ClusterStatisticController) ClusterStatisticGroupByDate 

func (c *ClusterStatisticController) ClusterStatisticGroupByDate(ctx *gin.Context)

ClusterStatisticGroupByDate 查询bu维度集群的大表统计信息 @Router /cluster/statistic/date [get] @Description 查询集群维度集群的大表统计信息 @Tags 统计信息 @Param start_date query string false "统计开始日期" @Param end_date query string false "统计结束日期" @Param start_size query string false "统计大于等于该值的表" @Param end_size query string false "统计小于等于该值的表" @Success 200 {object} common.Response{data=services.ClusterStatistic} @Failure 500 {object} common.Response

func (*ClusterStatisticController) ClusterStatisticGroupByTable 

func (c *ClusterStatisticController) ClusterStatisticGroupByTable(ctx *gin.Context)

ClusterStatisticGroupByTable 查询表维度集群的大表统计信息 @Router /cluster/statistic/table [get] @Description 查询表维度集群的大表统计信息 @Tags 统计信息 @Param start_date query string false "统计开始日期" @Param end_date query string false "统计结束日期" @Param start_size query string false "统计大于等于该值的表" @Param end_size query string false "统计小于等于该值的表" @Param bu query string false "BU" @Param cluster_id query string false "集群ID" @Param cluster_name query string false "集群名称" @Param database query string false "库名" @Param table query string false "表名" @Success 200 {object} common.Response{data=services.ClusterStatistic} @Failure 500 {object} common.Response

type ConfigController 

type ConfigController struct{}

func (*ConfigController) GetConfig 

func (c *ConfigController) GetConfig(ctx *gin.Context)

GetConfig 查询配置 @Router /manage/config [get] @Description 查询配置 @Tags 管理员 @Success 200 {object} common.Response{data=services.ConfigService} @Failure 500 {object} common.Response

func (*ConfigController) NoticeTest 

func (c *ConfigController) NoticeTest(ctx *gin.Context)

NoticeTest 通知测试 @Router /notice/test [get] @Description 通知测试 @Tags 管理员 @Param user query string false "user" @Success 200 {object} common.Response @Failure 500 {object} common.Response

func (*ConfigController) UpdateConfig 

func (c *ConfigController) UpdateConfig(ctx *gin.Context)

UpdateConfig 修改用户配置 @Router /manage/config [put] @Description 修改用户配置 @Tags 管理员 @Param config body services.ConfigService true "config" @Success 200 {object} common.Response{data=services.ConfigService} @Failure 500 {object} common.Response

type ConnController 

type ConnController struct{}

func (*ConnController) CreateConnection 

func (c *ConnController) CreateConnection(ctx *gin.Context)

CreateConnection 创建归档库连接信息 @Router /dest/conn [post] @Description 创建归档库连接信息 @Tags 归档库连接信息 @Param connection body services.ConnService true "归档库连接信息" @Success 200 {object} common.Response{data=services.ConnService} @Failure 500 {object} common.Response

func (*ConnController) DeleteConnection 

func (c *ConnController) DeleteConnection(ctx *gin.Context)

DeleteConnection 删除归档库连接信息 @Router /dest/conn [delete] @Description 删除归档库连接信息 @Tags 归档库连接信息 @Param Source body services.ConnService true "Source" @Success 200 {object} common.Response @Failure 500 {object} common.Response

func (*ConnController) QueryConnection 

func (c *ConnController) QueryConnection(ctx *gin.Context)

QueryConnection 查询归档库连接信息 @Router /dest/conn [get] @Description 查询归档库连接信息 @Tags 归档库连接信息 @Param page query int false "page" @Param pageSize query int false "pageSize" @Param id query uint false "连接ID" @Param creator query string false "创建人" @Param editor query string false "修改人" @Param name query string false "连接名字" @Param bu query string false "bu" @Param description query string false "说明" @Param storage query string false "存储介质" Enums(mysql, databend) @Param data_bend_addr query string false "DataBend地址" @Param mysql_host query string false "mysql地址" @Success 200 {object} common.Response{data=services.ConnService} @Failure 500 {object} common.Response

func (*ConnController) TestConnection 

func (c *ConnController) TestConnection(ctx *gin.Context)

TestConnection 测试归档库连接信息 @Router /dest/conn/test [post] @Description 创建源端信息 @Tags 归档库连接信息 @Param connection body services.ConnService true "归档库连接信息" @Success 200 {object} common.Response{data=services.ConnService} @Failure 500 {object} common.Response

func (*ConnController) UpdateConnection 

func (c *ConnController) UpdateConnection(ctx *gin.Context)

UpdateConnection 更新归档库连接信息 @Router /dest/conn [put] @Description 更新归档库连接信息 @Tags 归档库连接信息 @Param Connection body services.ConnService true "Connection" @Success 200 {object} common.Response{data=services.ConnService} @Failure 500 {object} common.Response

type DestController 

type DestController struct{}

func (*DestController) CreateDestination 

func (c *DestController) CreateDestination(ctx *gin.Context)

CreateDestination 创建目标端信息 @Router /dest [post] @Description 创建目标端信息 @Tags 目标端信息 @Param Destination body services.DestService true "Destination" @Success 200 {object} common.Response{data=services.DestService} @Failure 500 {object} common.Response

func (*DestController) DeleteDestination 

func (c *DestController) DeleteDestination(ctx *gin.Context)

DeleteDestination 删除目标端信息 @Router /dest [delete] @Description 删除目标端信息 @Tags 目标端信息 @Param Destination body services.DestService true "Destination" @Success 200 {object} common.Response{data=services.DestService} @Failure 500 {object} common.Response

func (*DestController) QueryDestination 

func (c *DestController) QueryDestination(ctx *gin.Context)

QueryDestination 查询目标端信息 @Router /dest [get] @Description 查询目标端信息 @Tags 目标端信息 @Param page query int false "page" @Param pageSize query int false "pageSize" @Param id query uint false "目标端ID" @Param creator query string false "创建人" @Param editor query string false "修改人" @Param name query string false "目标端名字" @Param description query string false "描述" @Param storage query string false "存储介质" Enums(mysql, databend) @Param connection_id query uint false "连接ID" @Param database_name query string false "数据库" @Param tables_name query string false "表名字" @Param compress query bool false "是否压缩存储存储" @Success 200 {object} common.Response{data=services.DestService} @Failure 500 {object} common.Response

func (*DestController) UpdateDestination 

func (c *DestController) UpdateDestination(ctx *gin.Context)

UpdateDestination 更新目标端信息 @Router /dest [put] @Description 更新目标端信息 @Tags 目标端信息 @Param Destination body services.DestService true "Destination" @Success 200 {object} common.Response{data=services.DestService} @Failure 500 {object} common.Response

type HealthController 

type HealthController struct{}

func (*HealthController) Health 

func (c *HealthController) Health(ctx *gin.Context)

Health 健康检查 @Router /health [get] @Description 健康检查 @Tags 其他 @Success 200 {object} common.Response @Failure 500 {object} common.Response

type PolicyController 

type PolicyController struct{}

func (*PolicyController) CreatePolicy 

func (c *PolicyController) CreatePolicy(ctx *gin.Context)

CreatePolicy 创建策略 @Router /policy [post] @Description 创建策略 @Tags 策略 @Param Policy body services.PolicyService true "Policy" @Success 200 {object} common.Response{data=services.PolicyService} @Failure 500 {object} common.Response

func (*PolicyController) DeletePolicy 

func (c *PolicyController) DeletePolicy(ctx *gin.Context)

DeletePolicy 删除策略 @Router /policy [delete] @Description 删除策略 @Tags 策略 @Param Policy body services.PolicyService true "Policy" @Success 200 {object} common.Response{data=services.PolicyService} @Failure 500 {object} common.Response

func (*PolicyController) QueryPolicy 

func (c *PolicyController) QueryPolicy(ctx *gin.Context)

QueryPolicy 查询策略 @Router /policy [get] @Description 查询策略 @Tags 策略 @Param page query int false "page" @Param pageSize query int false "pageSize" @Param id query uint false "策略ID" @Param creator query string false "创建人" @Param editor query string false "修改人" @Param name query string false "策略名称" @Param description query string false "描述" @Param enable query bool false "是否生效" @Param period query string false "执行周期" Enums(once,monthly,quarterly,six-months,yearly) @Param pause query bool false "执行窗口外是否需要暂停执行" @Param rebuild_flag query bool false "执行窗口外是否重建表(仅在治理方式是删除时有效)。true:在执行窗口外仍然走重建流程; false:执行窗口外跳过重建流程" @Param cleaning_speed query string false "清理速度" Enums(steady,balanced,swift) @Param src_id query uint false "源端ID" @Param govern query string false "数据治理方式" Enums(truncate,delete,backup-delete,archive) @Param condition query string false "数据治理条件" @Param retain_src_data query bool false "归档时否保留源表数据" @Param dest_id query uint false "目标端ID" @Param relevant query string false "关注人" @Param notify_policy query string false "通知策略" Enums(silence,success,failed,always) @Success 200 {object} common.Response{data=services.PolicyService} @Failure 500 {object} common.Response

func (*PolicyController) UpdatePolicy 

func (c *PolicyController) UpdatePolicy(ctx *gin.Context)

UpdatePolicy 更新策略 @Router /policy [put] @Description 更新策略 @Tags 策略 @Param Policy body services.PolicyService true "Policy" @Success 200 {object} common.Response{data=services.PolicyService} @Failure 500 {object} common.Response

type PolicyRevisionController 

type PolicyRevisionController struct{}

func (*PolicyRevisionController) QueryPolicyRevision 

func (c *PolicyRevisionController) QueryPolicyRevision(ctx *gin.Context)

QueryPolicyRevision 查询策略修订记录 @Router /policy/revision [get] @Description 查询策略修订记录 @Tags 策略 @Param page query int false "page" @Param pageSize query int false "pageSize" @Param id query uint false "ID" @Param editor query string false "修改人" @Param policy_id query uint false "策略ID" @Param modify_field query string false "修改字段" @Param old_value query string false "原始值" @Param new_value query string false "修改值" @Success 200 {object} common.Response{data=services.PolicyRevisionService} @Failure 500 {object} common.Response

type PolicyStatisticController 

type PolicyStatisticController struct{}

func (*PolicyStatisticController) PolicyStatisticGroupByBu 

func (c *PolicyStatisticController) PolicyStatisticGroupByBu(ctx *gin.Context)

PolicyStatisticGroupByBu 查询bu维度统计信息 @Router /policy/statistic/bu [get] @Description 查询bu维度统计信息 @Tags 任务统计 @Param enable query bool false "是否开启" @Param bu query string false "BU" @Param govern query string false "治理方式" @Success 200 {object} common.Response{data=services.PolicyStatistic} @Failure 500 {object} common.Response

func (*PolicyStatisticController) PolicyStatisticGroupByCluster 

func (c *PolicyStatisticController) PolicyStatisticGroupByCluster(ctx *gin.Context)

PolicyStatisticGroupByCluster 查询集群维度统计信息 @Router /policy/statistic/cluster [get] @Description 查询集群维度统计信息 @Tags 任务统计 @Param enable query bool false "是否开启" @Param bu query string false "BU" @Param cluster_name query string false "集群名称" @Param govern query string false "治理方式" @Success 200 {object} common.Response{data=services.PolicyStatistic} @Failure 500 {object} common.Response

func (*PolicyStatisticController) PolicyStatisticGroupByDatabase 

func (c *PolicyStatisticController) PolicyStatisticGroupByDatabase(ctx *gin.Context)

PolicyStatisticGroupByDatabase 查询库维度统计信息 @Router /policy/statistic/database [get] @Description 查询库维度统计信息 @Tags 任务统计 @Param enable query bool false "是否开启" @Param bu query string false "BU" @Param cluster_name query string false "集群名称" @Param database query string false "库名" @Param govern query string false "治理方式" @Success 200 {object} common.Response{data=services.PolicyStatistic} @Failure 500 {object} common.Response

func (*PolicyStatisticController) PolicyStatisticGroupByTable 

func (c *PolicyStatisticController) PolicyStatisticGroupByTable(ctx *gin.Context)

PolicyStatisticGroupByTable 查询表维度统计信息 @Router /policy/statistic/table [get] @Description 查询表维度统计信息 @Tags 任务统计 @Param enable query bool false "是否开启" @Param bu query string false "BU" @Param cluster_name query string false "集群名称" @Param database query string false "库名" @Param table query string false "表名" @Param govern query string false "治理方式" @Success 200 {object} common.Response{data=services.PolicyStatistic} @Failure 500 {object} common.Response

type SourceController 

type SourceController struct{}

func (*SourceController) CreateSource 

func (c *SourceController) CreateSource(ctx *gin.Context)

CreateSource 创建源端信息 @Router /source [post] @Description 创建源端信息 @Tags 源端信息 @Param Source body services.SourceService true "Source" @Success 200 {object} common.Response{data=services.SourceService} @Failure 500 {object} common.Response

func (*SourceController) DeleteSource 

func (c *SourceController) DeleteSource(ctx *gin.Context)

DeleteSource 删除源端信息 @Router /source [delete] @Description 删除源端信息 @Tags 源端信息 @Param Source body services.SourceService true "Source" @Success 200 {object} common.Response @Failure 500 {object} common.Response

func (*SourceController) QuerySource 

func (c *SourceController) QuerySource(ctx *gin.Context)

QuerySource 查询源端信息 @Router /source [get] @Description 查询源端信息 @Tags 源端信息 @Param page query int false "page" @Param pageSize query int false "pageSize" @Param id query uint false "源端ID" @Param creator query string false "创建人" @Param editor query string false "修改人" @Param name query string false "源端名字" @Param description query string false "说明" @Param bu query string false "bu" @Param cluster_name query string false "service名称" @Param cluster_id query string false "cluster_id" @Param database_name query string false "数据库" @Param tables_name query string false "表名字" @Success 200 {object} common.Response{data=services.SourceService} @Failure 500 {object} common.Response

func (*SourceController) UpdateSource 

func (c *SourceController) UpdateSource(ctx *gin.Context)

UpdateSource 更新源端信息 @Router /source [put] @Description 创建源端信息 @Tags 源端信息 @Param Source body services.SourceService true "Source" @Success 200 {object} common.Response{data=services.SourceService} @Failure 500 {object} common.Response

type TaskChangeLogController 

type TaskChangeLogController struct{}

func (*TaskChangeLogController) QueryTaskChangeLog 

func (c *TaskChangeLogController) QueryTaskChangeLog(ctx *gin.Context)

QueryTaskChangeLog 查询任务状态变更历史极力 @Router /task/changelog [get] @Description 查询任务状态变更历史极力 @Tags 策略 @Param page query int false "page" @Param pageSize query int false "pageSize" @Param task_id query uint false "任务ID" @Success 200 {object} common.Response{data=services.TaskChangeLogService} @Failure 500 {object} common.Response

type TaskController 

type TaskController struct{}

func (*TaskController) DeleteTask 

func (c *TaskController) DeleteTask(ctx *gin.Context)

DeleteTask 删除任务 @Router /task [delete] @Description 删除任务 @Tags 任务 @Param Task body services.TaskService true "Task" @Success 200 {object} common.Response{data=services.TaskService} @Failure 500 {object} common.Response

func (*TaskController) QueryTask 

func (c *TaskController) QueryTask(ctx *gin.Context)

QueryTask 查询任务 @Router /task [get] @Description 查询任务 @Tags 任务 @Param page query int false "page" @Param pageSize query int false "pageSize" @Param id query uint false "任务ID" @Param creator query string false "创建人" @Param editor query string false "修改人" @Param name query string false "任务名称" @Param description query string false "描述" @Param enable query bool false "是否生效" @Param policy_id query int false "策略ID" @Param execute_date query string false "计划执行日期: 2024-03-01" @Param pause query bool false "执行窗口外是否需要暂停执行" @Param rebuild_flag query bool false "执行窗口外是否重建表(仅在治理方式是删除时有效)。true:在执行窗口外仍然走重建流程; false:执行窗口外跳过重建流程" @Param task_status query int false "任务状态" @Param task_reason query string false "任务失败原因" @Param task_detail query string false "任务失败详情" @Param workflow query string false "工作流" @Param src_id query uint false "源端ID" @Param src_name query string false "源端名称" @Param src_bu query string false "资产BU" @Param src_cluster_name query string false "源端集群名称" @Param src_cluster_id query string false "源端集群ID" @Param src_database_name query string false "源库名" @Param src_tables_name query string false "源表名" @Param src_columns query string false "源端归档列名" @Param govern query string false "数据治理方式" Enums(truncate,delete,backup-delete,archive) @Param condition query string false "数据治理条件" @Param clean_src query bool false "是否清理源表" @Param cleaning_speed query string false "清理速度" Enums(steady,balanced,swift) @Param dest_id query uint false "目标端ID" @Param dest_name query string false "目标端名称" @Param dest_storage query string false "存储介质" Enums(mysql, databend) @Param dest_connection_id query uint false "目标端连接ID" @Param dest_database_name query string false "目标端数据库" @Param dest_table_name query string false "目标端表名字" @Param dest_compress query bool false "目标端是否压缩存储存储" @Param relevant query string false "关注人" @Param notify_policy query string false "通知策略" Enums(silence,success,failed,always) @Success 200 {object} common.Response{data=services.TaskService} @Failure 500 {object} common.Response

func (*TaskController) UpdateTask 

func (c *TaskController) UpdateTask(ctx *gin.Context)

UpdateTask 更新任务 @Router /task [put] @Description 更新任务 @Tags 任务 @Param Task body services.TaskService true "Task" @Success 200 {object} common.Response{data=services.TaskService} @Failure 500 {object} common.Response

func (*TaskController) UpdateTaskResult 

func (c *TaskController) UpdateTaskResult(ctx *gin.Context)

UpdateTaskResult 上报任务执行结果 @Router /task/result [put] @Description 上报任务执行结果 @Tags 任务 @Param TaskResult body types.TaskResultService true "TaskResult" @Success 200 {object} common.Response{data=services.TaskService} @Failure 500 {object} common.Response

type TaskRevisionController 

type TaskRevisionController struct{}

func (*TaskRevisionController) QueryPolicyRevision 

func (c *TaskRevisionController) QueryPolicyRevision(ctx *gin.Context)

QueryPolicyRevision 查询任务修订记录 @Router /task/revision [get] @Description 查询任务修订记录 @Tags 任务 @Param page query int false "page" @Param pageSize query int false "pageSize" @Param id query uint false "ID" @Param editor query string false "修改人" @Param task_id query uint false "任务ID" @Param modify_field query string false "修改字段" @Param old_value query string false "原始值" @Param new_value query string false "修改值" @Success 200 {object} common.Response{data=services.PolicyRevisionService} @Failure 500 {object} common.Response

type TaskStatisticController 

type TaskStatisticController struct{}

func (*TaskStatisticController) TaskExecPlan 

func (c *TaskStatisticController) TaskExecPlan(ctx *gin.Context)

TaskExecPlan 查询任务执行计划 @Router /task/plan [get] @Description 查询任务执行计划 @Tags 任务统计 @Param start_date query string false "统计开始日期" @Param end_date query string false "统计结束日期" @Success 200 {object} common.Response{data=services.TaskPlanService} @Failure 500 {object} common.Response

func (*TaskStatisticController) TaskStatisticGroupByBu 

func (c *TaskStatisticController) TaskStatisticGroupByBu(ctx *gin.Context)

TaskStatisticGroupByBu 查询bu维度统计信息 @Router /task/statistic/bu [get] @Description 查询bu维度统计信息 @Tags 任务统计 @Param start_date query string false "统计开始日期" @Param end_date query string false "统计结束日期" @Param bu query string false "BU" @Param govern query string false "治理方式" @Success 200 {object} common.Response{data=services.TaskStatisticDetail} @Failure 500 {object} common.Response

func (*TaskStatisticController) TaskStatisticGroupByCluster 

func (c *TaskStatisticController) TaskStatisticGroupByCluster(ctx *gin.Context)

TaskStatisticGroupByCluster 查询集群维度统计信息 @Router /task/statistic/cluster [get] @Description 查询集群维度统计信息 @Tags 任务统计 @Param start_date query string false "统计开始日期" @Param end_date query string false "统计结束日期" @Param bu query string false "BU" @Param cluster_name query string false "集群名称" @Param govern query string false "治理方式" @Success 200 {object} common.Response{data=services.TaskStatisticDetail} @Failure 500 {object} common.Response

func (*TaskStatisticController) TaskStatisticGroupByDatabase 

func (c *TaskStatisticController) TaskStatisticGroupByDatabase(ctx *gin.Context)

TaskStatisticGroupByDatabase 查询库维度统计信息 @Router /task/statistic/database [get] @Description 查询库维度统计信息 @Tags 任务统计 @Param start_date query string false "统计开始日期" @Param end_date query string false "统计结束日期" @Param bu query string false "BU" @Param cluster_name query string false "集群名称" @Param database query string false "库名" @Param govern query string false "治理方式" @Success 200 {object} common.Response{data=services.TaskStatisticDetail} @Failure 500 {object} common.Response

func (*TaskStatisticController) TaskStatisticGroupByTable 

func (c *TaskStatisticController) TaskStatisticGroupByTable(ctx *gin.Context)

TaskStatisticGroupByTable 查询表维度统计信息 @Router /task/statistic/table [get] @Description 查询表维度统计信息 @Tags 任务统计 @Param start_date query string false "统计开始日期" @Param end_date query string false "统计结束日期" @Param bu query string false "BU" @Param cluster_name query string false "集群名称" @Param database query string false "库名" @Param table query string false "表名" @Param govern query string false "治理方式" @Success 200 {object} common.Response{data=services.TaskStatisticDetail} @Failure 500 {object} common.Response

func (*TaskStatisticController) TaskStatisticSummary 

func (c *TaskStatisticController) TaskStatisticSummary(ctx *gin.Context)

TaskStatisticSummary 查询任务统计信息 @Router /task/statistic/summary [get] @Description 查询任务统计信息 @Tags 任务统计 @Param start_date query string false "统计开始日期" @Param end_date query string false "统计结束日期" @Success 200 {object} common.Response{data=services.TaskStatisticService} @Failure 500 {object} common.Response

type UserController 

type UserController struct{}

func (*UserController) DeleteUser 

func (c *UserController) DeleteUser(ctx *gin.Context)

DeleteUser 删除用户 @Router /manage/user/{user} [delete] @Description 删除用户 @Tags 管理员 @Param user path string true "用户名" @Success 200 {object} common.Response{data=services.UserService} @Failure 500 {object} common.Response

func (*UserController) Login 

func (c *UserController) Login(ctx *gin.Context)

Login 用户登录 @Router /user/login [put] @Description 用户登录 @Tags 用户 @Param user body services.UserService true "username,password,is_ldap" @Success 200 {object} common.Response{data=services.UserService} @Failure 401 {object} common.Response

func (*UserController) ModifyUser 

func (c *UserController) ModifyUser(ctx *gin.Context)

ModifyUser 修改用户信息 @Router /user [put] @Description 修改用户信息 @Tags 用户 @Param user body services.UserService true "username" @Success 200 {object} common.Response{data=services.UserService} @Failure 401 {object} common.Response

func (*UserController) QueryUser 

func (c *UserController) QueryUser(ctx *gin.Context)

QueryUser 查询用户 @Router /manage/user [get] @Description 查询用户 @Tags 管理员 @Param page query int false "page" @Param pageSize query int false "pageSize" @Param username query string false "用户名" @Param real_name query string false "姓名" @Param email query string false "Email" @Param is_ldap query int false "是否是LDAP用户(0,1)" @Success 200 {object} common.Response{data=services.UserService} @Failure 500 {object} common.Response

func (*UserController) RegisterUser 

func (c *UserController) RegisterUser(ctx *gin.Context)

RegisterUser 注册用户 @Router /manage/user/register [post] @Description 注册用户 @Tags 管理员 @Param user body services.UserService true "username,password" @Success 200 {object} common.Response{data=services.UserService} @Failure 500 {object} common.Response

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.