Documentation ¶
Index ¶
- Constants
- func CaptchaV2(c echo.Context) error
- func ConnectionV2(c echo.Context) error
- func CreateMigrationJobV2(c echo.Context) error
- func CreateOrUpdateMigrationJobV2(c echo.Context, create bool) error
- func CreateOrUpdateSyncJobV2(c echo.Context, create bool) error
- func CreateRoleV2(c echo.Context) error
- func CreateSubscriptionJobV2(c echo.Context) error
- func CreateSyncJobV2(c echo.Context) error
- func CreateUserV2(c echo.Context) error
- func DeleteJobV2(c echo.Context, filterJobType DtleJobType) error
- func DeleteMigrationJobV2(c echo.Context) error
- func DeleteRoleV2(c echo.Context) error
- func DeleteSubscriptionJobV2(c echo.Context) error
- func DeleteSyncJobV2(c echo.Context) error
- func DeleteUserV2(c echo.Context) error
- func DiagnosisJobAndTarFile(logger g.LoggerType, jobId, src, dst string) (err error)
- func DiagnosisJobV2(c echo.Context) error
- func FindNodeList() ([]nomadApi.NodeListStub, error)
- func FindNomadNodes(logger g.LoggerType) ([]models.NodeListItemV2, error)
- func GetCurrentUserV2(c echo.Context) error
- func GetJobDetail(c echo.Context, logger g.LoggerType, jobType DtleJobType) error
- func GetJobPositionV2(c echo.Context) error
- func GetMigrationJobDetailV2(c echo.Context) error
- func GetNodeInfo(nodeId string) (nomadApi.Node, error)
- func GetSubscriptionJobDetailV2(c echo.Context) error
- func GetSyncJobDetailV2(c echo.Context) error
- func GetTaskProgressV2(c echo.Context) error
- func GetUserName(c echo.Context) (string, string)
- func JobListV2(c echo.Context, filterJobType DtleJobType) error
- func ListActionV2(c echo.Context) error
- func ListDatabaseColumnsV2(c echo.Context) error
- func ListDatabaseSchemasV2(c echo.Context) error
- func ListMysqlColumnsV2(c echo.Context) error
- func ListMysqlSchemasV2(c echo.Context) error
- func LoginV2(c echo.Context) error
- func LoginWithoutVerifyCodeV2(c echo.Context) error
- func MigrationJobListV2(c echo.Context) error
- func MySQLConnectionV2(c echo.Context) error
- func NodeListV2(c echo.Context) error
- func PauseJobV2(c echo.Context, filterJobType DtleJobType) error
- func PauseMigrationJobV2(c echo.Context) error
- func PauseSubscriptionJobV2(c echo.Context) error
- func PauseSyncJobV2(c echo.Context) error
- func ResetPasswordV2(c echo.Context) error
- func ResumeJobV2(c echo.Context, filterJobType DtleJobType) error
- func ResumeMigrationJobV2(c echo.Context) error
- func ResumeSubscriptionJobV2(c echo.Context) error
- func ResumeSyncJobV2(c echo.Context) error
- func ReverseJobV2(c echo.Context, filterJobType DtleJobType) error
- func ReverseMigrationJobV2(c echo.Context) error
- func ReverseStartJobV2(c echo.Context, filterJobType DtleJobType) error
- func ReverseStartMigrationJobV2(c echo.Context) error
- func ReverseStartSyncJobV2(c echo.Context) error
- func ReverseSyncJobV2(c echo.Context) error
- func RoleListV2(c echo.Context) error
- func SubscriptionJobListV2(c echo.Context) error
- func SyncJobListV2(c echo.Context) error
- func TenantListV2(c echo.Context) error
- func UpdateLogLevelV2(c echo.Context) error
- func UpdateMigrationJobV2(c echo.Context) error
- func UpdateRoleInfo(logger g.LoggerType, role *common.Role, create bool) error
- func UpdateRoleV2(c echo.Context) error
- func UpdateSubscriptionJobV2(c echo.Context) error
- func UpdateSyncJobV2(c echo.Context) error
- func UpdateUserV2(c echo.Context) error
- func UserListV2(c echo.Context) error
- func ValidateJobV2(c echo.Context) error
- func ValidatePassword(blacklistKey, currentPwd, verifiedPwd string) error
- func VerifyPassword(encryptPwd string) bool
- type Blacklist
- type BlacklistItem
- type DtleJobType
Constants ¶
const ( DB_TYPE_MYSQL = "MySQL" DB_TYPE_ORACLE = "Oracle" )
const ( DtleJobTypeMigration = DtleJobType("migration") DtleJobTypeSync = DtleJobType("sync") DtleJobTypeSubscription = DtleJobType("subscription") DtleJobTypeUnknown = DtleJobType("unknown") )
const ( ProfileCpu = "cpu" ProfileHeap = "heap" ProfileMutex = "mutex" ProfileBlock = "block" ProfileGoroutine = "goroutine" ProfileThreadCreate = "threadcreate" ProfileStatus = "status" )
Variables ¶
This section is empty.
Functions ¶
func CaptchaV2 ¶
func CaptchaV2(c echo.Context) error
@Summary create base64Captcha @Description create base64Captcha @Tags user @Id CaptchaV2 @Param captcha_type formData string true "captcha type" Enums(default,audio) @Success 200 {object} models.CaptchaRespV2 @router /v2/login/captcha [post]
func ConnectionV2 ¶
func ConnectionV2(c echo.Context) error
@Id ConnectionV2 @Description connect to database instance. @Tags database @Security ApiKeyAuth @Param host query string true "database host" @Param port query int true "database port" @Param user query string true "database user" @Param password query string true "database password" @Param database_type query string true "database_type" @Param service_name query string false "database service_name" @Param is_password_encrypted query bool false "indecate that database password is encrypted or not" @Success 200 {object} models.ConnectionRespV2 @Router /v2/database/instance_connection [get]
func CreateMigrationJobV2 ¶
func CreateMigrationJobV2(c echo.Context) error
@Id CreateMigrationJobV2 @Description create migration job. @Tags job @Accept application/json @Security ApiKeyAuth @Param migration_job_config body models.CreateOrUpdateMysqlToMysqlJobParamV2 true "migration job config" @Success 200 {object} models.CreateOrUpdateMysqlToMysqlJobRespV2 @Router /v2/job/migration/create [post]
func CreateOrUpdateSyncJobV2 ¶
func CreateRoleV2 ¶
func CreateRoleV2(c echo.Context) error
@Id CreateRoleV2 @Description create Role. @Tags Role @Accept application/json @Security ApiKeyAuth @Param Role body models.CreateRoleReqV2 true "Role info" @Success 200 {object} models.CreateRoleRespV2 @Router /v2/role/create [post]
func CreateSubscriptionJobV2 ¶
func CreateSubscriptionJobV2(c echo.Context) error
@Id CreateSubscriptionJobV2 @Description create subscription job. @Tags job @Accept application/json @Security ApiKeyAuth @Param subscription_job_config body models.CreateOrUpdateMysqlToKafkaJobParamV2 true "subscription job config" @Success 200 {object} models.CreateOrUpdateMysqlToKafkaJobRespV2 @Router /v2/job/subscription/create [post]
func CreateSyncJobV2 ¶
func CreateSyncJobV2(c echo.Context) error
@Id CreateSyncJobV2 @Description create sync job. @Tags job @Accept application/json @Security ApiKeyAuth @Param sync_job_config body models.CreateOrUpdateMysqlToMysqlJobParamV2 true "sync job config" @Success 200 {object} models.CreateOrUpdateMysqlToMysqlJobRespV2 @Router /v2/job/sync/create [post]
func CreateUserV2 ¶
func CreateUserV2(c echo.Context) error
@Id CreateUserV2 @Description create user. @Tags user @Accept application/json @Security ApiKeyAuth @Param user body models.CreateUserReqV2 true "user info" @Success 200 {object} models.CreateUserRespV2 @Router /v2/user/create [post]
func DeleteJobV2 ¶
func DeleteJobV2(c echo.Context, filterJobType DtleJobType) error
func DeleteMigrationJobV2 ¶
func DeleteMigrationJobV2(c echo.Context) error
@Id DeleteMigrationJobV2 @Description delete migration job. @Tags job @accept application/x-www-form-urlencoded @Security ApiKeyAuth @Param job_id formData string true "job id" @Success 200 {object} models.DeleteJobRespV2 @Router /v2/job/migration/delete [post]
func DeleteRoleV2 ¶
func DeleteRoleV2(c echo.Context) error
@Id DeleteRoleV2 @Description delete Role. @Tags Role @accept application/x-www-form-urlencoded @Security ApiKeyAuth @Param tenant formData string true "tenant" @Param name formData string true "role name" @Success 200 {object} models.DeleteRoleRespV2 @Router /v2/role/delete [post]
func DeleteSubscriptionJobV2 ¶
func DeleteSubscriptionJobV2(c echo.Context) error
@Id DeleteSubscriptionJobV2 @Description delete subscription job. @Tags job @accept application/x-www-form-urlencoded @Security ApiKeyAuth @Param job_id formData string true "job id" @Success 200 {object} models.DeleteJobRespV2 @Router /v2/job/subscription/delete [post]
func DeleteSyncJobV2 ¶
func DeleteSyncJobV2(c echo.Context) error
@Id DeleteSyncJobV2 @Description delete sync job. @Tags job @accept application/x-www-form-urlencoded @Security ApiKeyAuth @Param job_id formData string true "job id" @Success 200 {object} models.DeleteJobRespV2 @Router /v2/job/sync/delete [post]
func DeleteUserV2 ¶
func DeleteUserV2(c echo.Context) error
@Id DeleteUserV2 @Description delete user. @Tags user @accept application/x-www-form-urlencoded @Security ApiKeyAuth @Param tenant formData string true "tenant" @Param username formData string true "user name" @Success 200 {object} models.DeleteUserRespV2 @Router /v2/user/delete [post]
func DiagnosisJobAndTarFile ¶
func DiagnosisJobAndTarFile(logger g.LoggerType, jobId, src, dst string) (err error)
func DiagnosisJobV2 ¶
func DiagnosisJobV2(c echo.Context) error
@Id DiagnosisJobV2 @Description diagnosis job. @Tags job @Security ApiKeyAuth @Param job_id formData string false "job id" @Success 200 @router /v2/job/diagnosis [get]
func FindNodeList ¶
func FindNodeList() ([]nomadApi.NodeListStub, error)
func FindNomadNodes ¶
func FindNomadNodes(logger g.LoggerType) ([]models.NodeListItemV2, error)
func GetCurrentUserV2 ¶
func GetCurrentUserV2(c echo.Context) error
@Id GetCurrentUserV2 @Description get current user. @Tags user @Security ApiKeyAuth @Success 200 {object} models.CurrentUserResp @Router /v2/user/current_user [get]
func GetJobDetail ¶
func GetJobDetail(c echo.Context, logger g.LoggerType, jobType DtleJobType) error
func GetJobPositionV2 ¶
func GetJobPositionV2(c echo.Context) error
@Id GetJobPositionV2 @Description get src task current gtid/scn. @Tags job @Success 200 {object} models.JobPositionResp @Security ApiKeyAuth @Param job_id query string true "job id" @Router /v2/job/position [get]
func GetMigrationJobDetailV2 ¶
func GetMigrationJobDetailV2(c echo.Context) error
@Id GetMigrationJobDetailV2 @Description get migration job detail. @Tags job @Success 200 {object} models.MysqlToMysqlJobDetailRespV2 @Security ApiKeyAuth @Param job_id query string true "job id" @Router /v2/job/migration/detail [get]
func GetSubscriptionJobDetailV2 ¶
func GetSubscriptionJobDetailV2(c echo.Context) error
@Id GetSubscriptionJobDetailV2 @Description get subscription job detail. @Tags job @Success 200 {object} models.MysqlToKafkaJobDetailRespV2 @Security ApiKeyAuth @Param job_id query string true "job id" @Router /v2/job/subscription/detail [get]
func GetSyncJobDetailV2 ¶
func GetSyncJobDetailV2(c echo.Context) error
@Id GetSyncJobDetailV2 @Description get sync job detail. @Tags job @Success 200 {object} models.MysqlToMysqlJobDetailRespV2 @Security ApiKeyAuth @Param job_id query string true "job id" @Router /v2/job/sync/detail [get]
func GetTaskProgressV2 ¶
func GetTaskProgressV2(c echo.Context) error
@Id GetTaskProgressV2 @Description get progress of tasks within an allocation. @Tags monitor @Security ApiKeyAuth @Param allocation_id query string true "allocation id" @Param task_name query string true "task name" @Param nomad_http_address query string false "nomad_http_address is the http address of the nomad that the target dtle is running with. ignore it if you are not sure what to provide" @Success 200 {object} models.GetTaskProgressRespV2 @Router /v2/monitor/task [get]
func GetUserName ¶
func JobListV2 ¶
func JobListV2(c echo.Context, filterJobType DtleJobType) error
func ListActionV2 ¶
func ListActionV2(c echo.Context) error
@Id ListActionV2 @Description list user action. @Tags user @Security ApiKeyAuth @Success 200 {object} models.ListActionRespV2 @Router /v2/user/list_action [get]
func ListDatabaseColumnsV2 ¶
func ListDatabaseColumnsV2(c echo.Context) error
@Id ListDatabaseColumnsV2 @Description list columns of database source instance. @Tags database @Security ApiKeyAuth @Param host query string true "database host" @Param port query int true "database port" @Param user query string true "database user" @Param password query string true "database password" @Param database_type query string true "database_type" @Param service_name query string false "database service_name" @Param schema query string true "database schema" @Param table query string true "database table" @Param character_set query string false "database character set" @Param is_password_encrypted query bool false "indecate that database password is encrypted or not" @Success 200 {object} models.ListColumnsRespV2 @Router /v2/database/columns [get]
func ListDatabaseSchemasV2 ¶
func ListDatabaseSchemasV2(c echo.Context) error
@Id ListDatabaseSchemasV2 @Description list schemas of database source instance. @Tags database @Security ApiKeyAuth @Param database_type query string true "database_type" @Param host query string true "database host" @Param port query int true "database port" @Param user query string true "database user" @Param password query string true "database password" @Param service_name query string false "database service_name" @Param character_set query string false "database character set" @Param is_password_encrypted query bool false "indecate that database password is encrypted or not" @Success 200 {object} models.ListSchemasRespV2 @Router /v2/database/schemas [get]
func ListMysqlColumnsV2 ¶
func ListMysqlColumnsV2(c echo.Context) error
@Id ListMysqlColumnsV2 @Description list columns of mysql source instance. @Tags mysql @Security ApiKeyAuth @Param mysql_host query string true "mysql host" @Param mysql_port query string true "mysql port" @Param mysql_user query string true "mysql user" @Param mysql_password query string true "mysql password" @Param mysql_schema query string true "mysql schema" @Param mysql_table query string true "mysql table" @Param mysql_character_set query string false "mysql character set" @Param is_mysql_password_encrypted query bool false "indecate that mysql password is encrypted or not" @Success 200 {object} models.ListColumnsRespV2 @Router /v2/mysql/columns [get]
func ListMysqlSchemasV2 ¶
func ListMysqlSchemasV2(c echo.Context) error
@Id ListMysqlSchemasV2 @Description list schemas of mysql source instance. @Tags mysql @Security ApiKeyAuth @Param mysql_host query string true "mysql host" @Param mysql_port query string true "mysql port" @Param mysql_user query string true "mysql user" @Param mysql_password query string true "mysql password" @Param mysql_character_set query string false "mysql character set" @Param is_mysql_password_encrypted query bool false "indecate that mysql password is encrypted or not" @Success 200 {object} models.ListSchemasRespV2 @Router /v2/mysql/schemas [get]
func LoginV2 ¶
func LoginV2(c echo.Context) error
@Summary user loginV2 @Description user login @Tags user @Id loginV2 @Param user body models.UserLoginReqV2 true "user login request" @Success 200 {object} models.GetUserLoginResV2 @router /v2/login [post]
func LoginWithoutVerifyCodeV2 ¶
func LoginWithoutVerifyCodeV2(c echo.Context) error
@Summary user LoginWithoutVerifyCodeV2 @Description user login Without Verify Code @Tags user @Id LoginWithoutVerifyCodeV2 @Param user body models.LoginWithoutVerifyCodeReqV2 true "user login request" @Success 200 {object} models.GetUserLoginResV2 @router /v2/loginWithoutVerifyCode [post]
func MigrationJobListV2 ¶
func MigrationJobListV2(c echo.Context) error
@Id MigrationJobListV2 @Description get job list. @Tags job @Success 200 {object} models.JobListRespV2 @Security ApiKeyAuth @Param filter_job_id query string false "filter job id" @Param filter_job_src_ip query string false "filter job src ip" @Param filter_job_src_port query string false "filter job src port" @Param filter_job_dest_ip query string false "filter job dest ip" @Param filter_job_dest_port query string false "filter job dest port" @Param filter_job_status query string false "filter job status" @Param order_by query string false "order by" default(job_create_time) Enums(job_create_time) @Router /v2/jobs/migration [get]
func MySQLConnectionV2 ¶
func MySQLConnectionV2(c echo.Context) error
@Id MySQLConnectionV2 @Description connect to mysql instance. @Tags mysql @Security ApiKeyAuth @Param mysql_host query string true "mysql host" @Param mysql_port query string true "mysql port" @Param mysql_user query string true "mysql user" @Param mysql_password query string true "mysql password" @Param is_mysql_password_encrypted query bool false "indecate that mysql password is encrypted or not" @Success 200 {object} models.ConnectionRespV2 @Router /v2/mysql/instance_connection [get]
func NodeListV2 ¶
func NodeListV2(c echo.Context) error
@Id NodeListV2 @Description get node list. @Tags node @Security ApiKeyAuth @Success 200 {object} models.NodeListRespV2 @Router /v2/nodes [get]
func PauseJobV2 ¶
func PauseJobV2(c echo.Context, filterJobType DtleJobType) error
func PauseMigrationJobV2 ¶
func PauseMigrationJobV2(c echo.Context) error
@Id PauseMigrationJobV2 @Description pause migration job. @Tags job @accept application/x-www-form-urlencoded @Security ApiKeyAuth @Param job_id formData string true "job id" @Success 200 {object} models.PauseJobRespV2 @Router /v2/job/migration/pause [post]
func PauseSubscriptionJobV2 ¶
func PauseSubscriptionJobV2(c echo.Context) error
@Id PauseSubscriptionJobV2 @Description pause subscription job. @Tags job @accept application/x-www-form-urlencoded @Security ApiKeyAuth @Param job_id formData string true "job id" @Success 200 {object} models.PauseJobRespV2 @Router /v2/job/subscription/pause [post]
func PauseSyncJobV2 ¶
func PauseSyncJobV2(c echo.Context) error
@Id PauseSyncJobV2 @Description pause sync job. @Tags job @accept application/x-www-form-urlencoded @Security ApiKeyAuth @Param job_id formData string true "job id" @Success 200 {object} models.PauseJobRespV2 @Router /v2/job/sync/pause [post]
func ResetPasswordV2 ¶
func ResetPasswordV2(c echo.Context) error
@Id ResetPasswordV2 @Description reset user password. @Tags user @Accept application/json @Security ApiKeyAuth @Param user body models.ResetPasswordReqV2 true "reset user password" @Success 200 {object} models.ResetPasswordRespV2 @Router /v2/user/reset_password [post]
func ResumeJobV2 ¶
func ResumeJobV2(c echo.Context, filterJobType DtleJobType) error
func ResumeMigrationJobV2 ¶
func ResumeMigrationJobV2(c echo.Context) error
@Id ResumeMigrationJobV2 @Description resume migration job. @Tags job @accept application/x-www-form-urlencoded @Security ApiKeyAuth @Param job_id formData string true "job id" @Success 200 {object} models.ResumeJobRespV2 @Router /v2/job/migration/resume [post]
func ResumeSubscriptionJobV2 ¶
func ResumeSubscriptionJobV2(c echo.Context) error
@Id ResumeSubscriptionJobV2 @Description resume subscription job. @Tags job @accept application/x-www-form-urlencoded @Security ApiKeyAuth @Param job_id formData string true "job id" @Success 200 {object} models.ResumeJobRespV2 @Router /v2/job/subscription/resume [post]
func ResumeSyncJobV2 ¶
func ResumeSyncJobV2(c echo.Context) error
@Id ResumeSyncJobV2 @Description resume sync job. @Tags job @accept application/x-www-form-urlencoded @Security ApiKeyAuth @Param job_id formData string true "job id" @Success 200 {object} models.ResumeJobRespV2 @Router /v2/job/sync/resume [post]
func ReverseJobV2 ¶
func ReverseJobV2(c echo.Context, filterJobType DtleJobType) error
func ReverseMigrationJobV2 ¶
func ReverseMigrationJobV2(c echo.Context) error
@Id ReverseMigrationJobV2 @Description reverse migration Job @Tags job @Accept application/json @Security ApiKeyAuth @Param reverse_config body models.ReverseJobReq true "reverse config config" @Success 200 {object} models.ReverseJobResp @Router /v2/job/migration/reverse [post]
func ReverseStartJobV2 ¶
func ReverseStartJobV2(c echo.Context, filterJobType DtleJobType) error
@Summary start reverse-init job @Id ReverseStartJobV2 @Tags job @Description Finish Job. @accept application/x-www-form-urlencoded @Security ApiKeyAuth @Param job_id formData string true "job id" @Success 200 {object} models.ReverseStartRespV2 @Router /v2/job/reverse_start [post]
func ReverseStartMigrationJobV2 ¶
func ReverseStartMigrationJobV2(c echo.Context) error
@Summary start reverse-init job @Id ReverseStartMigrationJobV2 @Tags job @Description Start Reverse Job. @accept application/x-www-form-urlencoded @Security ApiKeyAuth @Param job_id formData string true "job id" @Success 200 {object} models.ReverseStartRespV2 @Router /v2/job/migration/reverse_start [post]
func ReverseStartSyncJobV2 ¶
func ReverseStartSyncJobV2(c echo.Context) error
@Summary start reverse-init job @Id ReverseStartSyncJobV2 @Tags job @Description Start Reverse Job. @accept application/x-www-form-urlencoded @Security ApiKeyAuth @Param job_id formData string true "job id" @Success 200 {object} models.ReverseStartRespV2 @Router /v2/job/sync/reverse_start [post]
func ReverseSyncJobV2 ¶
func ReverseSyncJobV2(c echo.Context) error
@Id ReverseSyncJobV2 @Description reverse sync Job @Tags job @Accept application/json @Security ApiKeyAuth @Param reverse_config body models.ReverseJobReq true "reverse config config" @Success 200 {object} models.ReverseJobResp @Router /v2/job/sync/reverse [post]
func RoleListV2 ¶
func RoleListV2(c echo.Context) error
@Id RoleListV2 @Description get role list. @Tags Role @Success 200 {object} models.RoleListResp @Security ApiKeyAuth @Param filter_tenant query string false "filter tenant" @Router /v2/role/list [get]
func SubscriptionJobListV2 ¶
func SubscriptionJobListV2(c echo.Context) error
@Id SubscriptionJobListV2 @Description get subscription job list. @Tags job @Success 200 {object} models.JobListRespV2 @Security ApiKeyAuth @Param filter_job_id query string false "filter job id" @Param filter_job_src_ip query string false "filter job src ip" @Param filter_job_src_port query string false "filter job src port" @Param filter_job_dest_ip query string false "filter job dest ip" @Param filter_job_dest_port query string false "filter job dest port" @Param filter_job_status query string false "filter job status" @Param order_by query string false "order by" default(job_create_time) Enums(job_create_time) @Router /v2/jobs/subscription [get]
func SyncJobListV2 ¶
func SyncJobListV2(c echo.Context) error
@Id SyncJobListV2 @Description get sync job list. @Tags job @Success 200 {object} models.JobListRespV2 @Security ApiKeyAuth @Param filter_job_id query string false "filter job id" @Param filter_job_src_ip query string false "filter job src ip" @Param filter_job_src_port query string false "filter job src port" @Param filter_job_dest_ip query string false "filter job dest ip" @Param filter_job_dest_port query string false "filter job dest port" @Param filter_job_status query string false "filter job status" @Param order_by query string false "order by" default(job_create_time) Enums(job_create_time) @Router /v2/jobs/sync [get]
func TenantListV2 ¶
func TenantListV2(c echo.Context) error
@Id TenantListV2 @Description get tenant list. @Tags user @Success 200 {object} models.TenantListResp @Security ApiKeyAuth @Router /v2/tenant/list [get]
func UpdateLogLevelV2 ¶
func UpdateLogLevelV2(c echo.Context) error
@Id UpdateLogLevelV2 @Description reload log level dynamically. @Tags log @accept application/x-www-form-urlencoded @Security ApiKeyAuth @Param dtle_log_level formData string true "dtle log level" Enums(TRACE, DEBUG, INFO, WARN, ERROR) @Param dtle_debug_job formData string false "dtle debug job" @Success 200 {object} models.UpdataLogLevelRespV2 @router /v2/log/level [post]
func UpdateMigrationJobV2 ¶
func UpdateMigrationJobV2(c echo.Context) error
@Id UpdateMigrationJobV2 @Description update migration job. @Tags job @Accept application/json @Security ApiKeyAuth @Param migration_job_config body models.CreateOrUpdateMysqlToMysqlJobParamV2 true "migration job config" @Success 200 {object} models.CreateOrUpdateMysqlToMysqlJobRespV2 @Router /v2/job/migration/update [post]
func UpdateRoleInfo ¶
func UpdateRoleV2 ¶
func UpdateRoleV2(c echo.Context) error
@Id UpdateRoleV2 @Description update Role info. @Tags Role @Accept application/json @Security ApiKeyAuth @Param Role body models.UpdateRoleReqV2 true "Role info" @Success 200 {object} models.UpdateRoleRespV2 @Router /v2/role/update [post]
func UpdateSubscriptionJobV2 ¶
func UpdateSubscriptionJobV2(c echo.Context) error
@Id CreateOrUpdateSubscriptionJobV2 @Description update subscription job. @Tags job @Accept application/json @Security ApiKeyAuth @Param subscription_job_config body models.CreateOrUpdateMysqlToKafkaJobParamV2 true "subscription job config" @Success 200 {object} models.CreateOrUpdateMysqlToKafkaJobRespV2 @Router /v2/job/subscription/update [post]
func UpdateSyncJobV2 ¶
func UpdateSyncJobV2(c echo.Context) error
@Id UpdateSyncJobV2 @Description update sync job. @Tags job @Accept application/json @Security ApiKeyAuth @Param sync_job_config body models.CreateOrUpdateMysqlToMysqlJobParamV2 true "sync job config" @Success 200 {object} models.CreateOrUpdateMysqlToMysqlJobRespV2 @Router /v2/job/sync/update [post]
func UpdateUserV2 ¶
func UpdateUserV2(c echo.Context) error
@Id UpdateUserV2 @Description update user info. @Tags user @Accept application/json @Security ApiKeyAuth @Param user body models.UpdateUserReqV2 true "user info" @Success 200 {object} models.UpdateUserRespV2 @Router /v2/user/update [post]
func UserListV2 ¶
func UserListV2(c echo.Context) error
@Id UserListV2 @Description get user list. @Tags user @Success 200 {object} models.UserListResp @Security ApiKeyAuth @Param filter_username query string false "filter user name" @Param filter_tenant query string false "filter tenant" @Router /v2/user/list [get]
func ValidateJobV2 ¶
func ValidateJobV2(c echo.Context) error
@Id ValidateJobV2 @Description validate job config. @Tags validation @Accept application/json @Security ApiKeyAuth @Param job_config body models.ValidateJobReqV2 true "validate job config" @Success 200 {object} models.ValidateJobRespV2 @Router /v2/validation/job [post]
func ValidatePassword ¶
validate current user in blacklist and update blacklist
func VerifyPassword ¶
there are at least three types of uppercase letters, lowercase characters, numbers, and special characters
Types ¶
type Blacklist ¶
type Blacklist struct {
// contains filtered or unexported fields
}
var BL *Blacklist
type BlacklistItem ¶
type BlacklistItem struct {
// contains filtered or unexported fields
}
type DtleJobType ¶
type DtleJobType string
func GetJobTypeFromJobId ¶
func GetJobTypeFromJobId(jobId string) DtleJobType