v2

package
v0.2.1-0...-d023f04 Latest Latest
Warning

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

 Go to latest Published: Aug 17, 2023 License: MPL-2.0 Imports: 38 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	DB_TYPE_MYSQL  = "MySQL"
	DB_TYPE_ORACLE = "Oracle"
)
View Source 
const (
	DtleJobTypeMigration    = DtleJobType("migration")
	DtleJobTypeSync         = DtleJobType("sync")
	DtleJobTypeSubscription = DtleJobType("subscription")
	DtleJobTypeUnknown      = DtleJobType("unknown")
)
View Source 
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 CreateOrUpdateMigrationJobV2 

func CreateOrUpdateMigrationJobV2(c echo.Context, create bool) error

func CreateOrUpdateSyncJobV2 

func CreateOrUpdateSyncJobV2(c echo.Context, create bool) error

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 GetNodeInfo 

func GetNodeInfo(nodeId string) (nomadApi.Node, error)

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 GetUserName(c echo.Context) (string, string)

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 UpdateRoleInfo(logger g.LoggerType, role *common.Role, create bool) error

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 

func ValidatePassword(blacklistKey, currentPwd, verifiedPwd string) error

validate current user in blacklist and update blacklist

func VerifyPassword 

func VerifyPassword(encryptPwd string) bool

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

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.