client

package
v1.60.0 Latest Latest
Warning

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

 Go to latest Published: May 9, 2023 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type DmsClient 

type DmsClient struct {
	core.JDCloudClient
}

func NewDmsClient 

func NewDmsClient(credential *core.Credential) *DmsClient

func (*DmsClient) AddPersonalSql 

func (c *DmsClient) AddPersonalSql(request *dms.AddPersonalSqlRequest) (*dms.AddPersonalSqlResponse, error)

收藏sql

func (*DmsClient) AuthPrivilege added in v1.59.0 

func (c *DmsClient) AuthPrivilege(request *dms.AuthPrivilegeRequest) (*dms.AuthPrivilegeResponse, error)

实例授权

func (*DmsClient) CheckInstance added in v1.59.0 

func (c *DmsClient) CheckInstance(request *dms.CheckInstanceRequest) (*dms.CheckInstanceResponse, error)

校验用户是否有实例权限

func (*DmsClient) ConsoleExplain 

func (c *DmsClient) ConsoleExplain(request *dms.ConsoleExplainRequest) (*dms.ConsoleExplainResponse, error)

执行计划，支持Mysql，Stardb

func (*DmsClient) ConsoleGeneralData 

func (c *DmsClient) ConsoleGeneralData(request *dms.ConsoleGeneralDataRequest) (*dms.ConsoleGeneralDataResponse, error)

生成数据，支持Mysql，Stardb

func (*DmsClient) ConsoleSql 

func (c *DmsClient) ConsoleSql(request *dms.ConsoleSqlRequest) (*dms.ConsoleSqlResponse, error)

执行sql语句，支持Mysql，Stardb，Tidb，ClickHouse

func (*DmsClient) CreateDataFlow 

func (c *DmsClient) CreateDataFlow(request *dms.CreateDataFlowRequest) (*dms.CreateDataFlowResponse, error)

创建数据变更工单，支持Stardb

func (*DmsClient) CreateExportFlow 

func (c *DmsClient) CreateExportFlow(request *dms.CreateExportFlowRequest) (*dms.CreateExportFlowResponse, error)

创建数据导出工单，支持Stardb

func (*DmsClient) CreateImportFileTask 

func (c *DmsClient) CreateImportFileTask(request *dms.CreateImportFileTaskRequest) (*dms.CreateImportFileTaskResponse, error)

创建导入文件任务，支持Stardb

func (*DmsClient) CreateOnlineSqlTask added in v1.59.0 

func (c *DmsClient) CreateOnlineSqlTask(request *dms.CreateOnlineSqlTaskRequest) (*dms.CreateOnlineSqlTaskResponse, error)

创建Sql任务

func (*DmsClient) CreateStructureFlow 

func (c *DmsClient) CreateStructureFlow(request *dms.CreateStructureFlowRequest) (*dms.CreateStructureFlowResponse, error)

创建结构变更工单，支持Stardb

func (*DmsClient) CreateTableBatch 

func (c *DmsClient) CreateTableBatch(request *dms.CreateTableBatchRequest) (*dms.CreateTableBatchResponse, error)

批量建表，支持Stardb

func (*DmsClient) DatabaseList 

func (c *DmsClient) DatabaseList(request *dms.DatabaseListRequest) (*dms.DatabaseListResponse, error)

获取数据库实例的库列表，支持Mysql，Stardb，Tidb，ClickHouse

func (*DmsClient) DeletePersonalSql 

func (c *DmsClient) DeletePersonalSql(request *dms.DeletePersonalSqlRequest) (*dms.DeletePersonalSqlResponse, error)

删除收藏sql

func (*DmsClient) DeleteUser added in v1.59.0 

func (c *DmsClient) DeleteUser(request *dms.DeleteUserRequest) (*dms.DeleteUserResponse, error)

删除用户

func (*DmsClient) DisableLogger 

func (c *DmsClient) DisableLogger()

func (*DmsClient) DmsConsoleCheck added in v1.59.0 

func (c *DmsClient) DmsConsoleCheck(request *dms.DmsConsoleCheckRequest) (*dms.DmsConsoleCheckResponse, error)

校验当前的用户是否允许访问DMS控制台

func (*DmsClient) EnableUser added in v1.59.0 

func (c *DmsClient) EnableUser(request *dms.EnableUserRequest) (*dms.EnableUserResponse, error)

启用/禁用用户

func (*DmsClient) EventInfo added in v1.58.0 

func (c *DmsClient) EventInfo(request *dms.EventInfoRequest) (*dms.EventInfoResponse, error)

获取事件详情，支持Mysql

func (*DmsClient) ExeProgram 

func (c *DmsClient) ExeProgram(request *dms.ExeProgramRequest) (*dms.ExeProgramResponse, error)

执行编程对象sql，支持Mysql

func (*DmsClient) FormatSql 

func (c *DmsClient) FormatSql(request *dms.FormatSqlRequest) (*dms.FormatSqlResponse, error)

sql格式化，支持Mysql，Stardb

func (*DmsClient) FunctionInfo added in v1.58.0 

func (c *DmsClient) FunctionInfo(request *dms.FunctionInfoRequest) (*dms.FunctionInfoResponse, error)

获取函数详情，支持Mysql

func (*DmsClient) FunctionInvoke added in v1.58.0 

func (c *DmsClient) FunctionInvoke(request *dms.FunctionInvokeRequest) (*dms.FunctionInvokeResponse, error)

调用函数，支持Mysql

func (*DmsClient) FunctionList added in v1.58.0 

func (c *DmsClient) FunctionList(request *dms.FunctionListRequest) (*dms.FunctionListResponse, error)

获取函数列表，支持Mysql

func (*DmsClient) GeneralAlterEvent added in v1.58.0 

func (c *DmsClient) GeneralAlterEvent(request *dms.GeneralAlterEventRequest) (*dms.GeneralAlterEventResponse, error)

生成修改事件sql语句，支持Mysql

func (*DmsClient) GeneralAlterFunction added in v1.58.0 

func (c *DmsClient) GeneralAlterFunction(request *dms.GeneralAlterFunctionRequest) (*dms.GeneralAlterFunctionResponse, error)

生成修改函数sql语句，支持Mysql

func (*DmsClient) GeneralAlterProcedure added in v1.58.0 

func (c *DmsClient) GeneralAlterProcedure(request *dms.GeneralAlterProcedureRequest) (*dms.GeneralAlterProcedureResponse, error)

生成修改存储过程sql语句，支持Mysql

func (*DmsClient) GeneralAlterTableSql 

func (c *DmsClient) GeneralAlterTableSql(request *dms.GeneralAlterTableSqlRequest) (*dms.GeneralAlterTableSqlResponse, error)

生成修改表结构语句sql，支持Mysql，Stardb

func (*DmsClient) GeneralAlterTrigger added in v1.58.0 

func (c *DmsClient) GeneralAlterTrigger(request *dms.GeneralAlterTriggerRequest) (*dms.GeneralAlterTriggerResponse, error)

生成修改触发器sql语句，支持Mysql

func (*DmsClient) GeneralAlterView 

func (c *DmsClient) GeneralAlterView(request *dms.GeneralAlterViewRequest) (*dms.GeneralAlterViewResponse, error)

生成修改视图sql语句，支持Mysql

func (*DmsClient) GeneralCreateEvent added in v1.58.0 

func (c *DmsClient) GeneralCreateEvent(request *dms.GeneralCreateEventRequest) (*dms.GeneralCreateEventResponse, error)

生产创建事件SQL语句，支持Mysql

func (*DmsClient) GeneralCreateFunction added in v1.58.0 

func (c *DmsClient) GeneralCreateFunction(request *dms.GeneralCreateFunctionRequest) (*dms.GeneralCreateFunctionResponse, error)

生产创建函数过程SQL语句，支持Mysql

func (*DmsClient) GeneralCreateProcedure added in v1.58.0 

func (c *DmsClient) GeneralCreateProcedure(request *dms.GeneralCreateProcedureRequest) (*dms.GeneralCreateProcedureResponse, error)

生产创建存储过程SQL语句，支持Mysql

func (*DmsClient) GeneralCreateTableSql 

func (c *DmsClient) GeneralCreateTableSql(request *dms.GeneralCreateTableSqlRequest) (*dms.GeneralCreateTableSqlResponse, error)

生成建表语句sql，支持Mysql，Stardb，OpenGauss

func (*DmsClient) GeneralCreateTrigger added in v1.58.0 

func (c *DmsClient) GeneralCreateTrigger(request *dms.GeneralCreateTriggerRequest) (*dms.GeneralCreateTriggerResponse, error)

生成创建触发器SQL语句，支持Mysql

func (*DmsClient) GeneralCreateView 

func (c *DmsClient) GeneralCreateView(request *dms.GeneralCreateViewRequest) (*dms.GeneralCreateViewResponse, error)

生产创建视图SQL语句，支持Mysql

func (*DmsClient) GeneralDropEvent added in v1.58.0 

func (c *DmsClient) GeneralDropEvent(request *dms.GeneralDropEventRequest) (*dms.GeneralDropEventResponse, error)

生成删除事件sql语句，支持Mysql

func (*DmsClient) GeneralDropFunction added in v1.58.0 

func (c *DmsClient) GeneralDropFunction(request *dms.GeneralDropFunctionRequest) (*dms.GeneralDropFunctionResponse, error)

生成删除函数sql语句，支持Mysql

func (*DmsClient) GeneralDropProcedure added in v1.58.0 

func (c *DmsClient) GeneralDropProcedure(request *dms.GeneralDropProcedureRequest) (*dms.GeneralDropProcedureResponse, error)

生成删除存储过程sql语句，支持Mysql

func (*DmsClient) GeneralDropTrigger added in v1.58.0 

func (c *DmsClient) GeneralDropTrigger(request *dms.GeneralDropTriggerRequest) (*dms.GeneralDropTriggerResponse, error)

生成删除触发器sql语句，支持Mysql

func (*DmsClient) GeneralDropView 

func (c *DmsClient) GeneralDropView(request *dms.GeneralDropViewRequest) (*dms.GeneralDropViewResponse, error)

生成删除视图sql语句，支持Mysql

func (*DmsClient) GetCreateTableBatchSql 

func (c *DmsClient) GetCreateTableBatchSql(request *dms.GetCreateTableBatchSqlRequest) (*dms.GetCreateTableBatchSqlResponse, error)

获取批量建表sql，仅供前端使用，支持Stardb，OpenGauss

func (*DmsClient) GetDmsDomain 

func (c *DmsClient) GetDmsDomain(request *dms.GetDmsDomainRequest) (*dms.GetDmsDomainResponse, error)

获取Dms域名，仅供前端使用

func (*DmsClient) GetDmsDomains added in v1.59.0 

func (c *DmsClient) GetDmsDomains(request *dms.GetDmsDomainsRequest) (*dms.GetDmsDomainsResponse, error)

获取Dms域名，仅供前端使用

func (*DmsClient) GetUserInfo added in v1.59.0 

func (c *DmsClient) GetUserInfo(request *dms.GetUserInfoRequest) (*dms.GetUserInfoResponse, error)

获取用户信息

func (*DmsClient) HistoryImportData 

func (c *DmsClient) HistoryImportData(request *dms.HistoryImportDataRequest) (*dms.HistoryImportDataResponse, error)

获取当前实例用户查询导入数据sql历史

func (*DmsClient) HistorySql 

func (c *DmsClient) HistorySql(request *dms.HistorySqlRequest) (*dms.HistorySqlResponse, error)

获取当前实例用户查询sql历史

func (*DmsClient) Login 

func (c *DmsClient) Login(request *dms.LoginRequest) (*dms.LoginResponse, error)

rds，drds登录实例

func (*DmsClient) Logout 

func (c *DmsClient) Logout(request *dms.LogoutRequest) (*dms.LogoutResponse, error)

退出登录

func (*DmsClient) ModifyPrivilegeExpireDate added in v1.59.0 

func (c *DmsClient) ModifyPrivilegeExpireDate(request *dms.ModifyPrivilegeExpireDateRequest) (*dms.ModifyPrivilegeExpireDateResponse, error)

修改权限到期时间

func (*DmsClient) OnlineProxySubTaskQuery added in v1.59.0 

func (c *DmsClient) OnlineProxySubTaskQuery(request *dms.OnlineProxySubTaskQueryRequest) (*dms.OnlineProxySubTaskQueryResponse, error)

查询sql子任务状态

func (*DmsClient) OnlineSqlTaskQuery added in v1.59.0 

func (c *DmsClient) OnlineSqlTaskQuery(request *dms.OnlineSqlTaskQueryRequest) (*dms.OnlineSqlTaskQueryResponse, error)

查询任务状态

func (*DmsClient) OnlineSubSqlTaskQuery added in v1.59.0 

func (c *DmsClient) OnlineSubSqlTaskQuery(request *dms.OnlineSubSqlTaskQueryRequest) (*dms.OnlineSubSqlTaskQueryResponse, error)

查询sql子任务状态

func (*DmsClient) Open 

func (c *DmsClient) Open(request *dms.OpenRequest) (*dms.OpenResponse, error)

打开实例

func (*DmsClient) OperationDetail added in v1.59.0 

func (c *DmsClient) OperationDetail(request *dms.OperationDetailRequest) (*dms.OperationDetailResponse, error)

获取操作详情

func (*DmsClient) ProcedureInfo added in v1.58.0 

func (c *DmsClient) ProcedureInfo(request *dms.ProcedureInfoRequest) (*dms.ProcedureInfoResponse, error)

获取存储过程详情，支持Mysql

func (*DmsClient) ProcedureInvoke added in v1.58.0 

func (c *DmsClient) ProcedureInvoke(request *dms.ProcedureInvokeRequest) (*dms.ProcedureInvokeResponse, error)

执行存储过程，支持Mysql

func (*DmsClient) ProcedureList added in v1.58.0 

func (c *DmsClient) ProcedureList(request *dms.ProcedureListRequest) (*dms.ProcedureListResponse, error)

获取存储过程列表，支持Mysql

func (*DmsClient) ProgramList 

func (c *DmsClient) ProgramList(request *dms.ProgramListRequest) (*dms.ProgramListResponse, error)

获取视图列表，支持Mysql

func (*DmsClient) QueryInstance 

func (c *DmsClient) QueryInstance(request *dms.QueryInstanceRequest) (*dms.QueryInstanceResponse, error)

查询用户实例

func (*DmsClient) QueryOperationLog added in v1.59.0 

func (c *DmsClient) QueryOperationLog(request *dms.QueryOperationLogRequest) (*dms.QueryOperationLogResponse, error)

获取操作日志列表

func (*DmsClient) QueryOperationType added in v1.59.0 

func (c *DmsClient) QueryOperationType(request *dms.QueryOperationTypeRequest) (*dms.QueryOperationTypeResponse, error)

获取操作对应控制台功能

func (*DmsClient) QueryPersonalSqls 

func (c *DmsClient) QueryPersonalSqls(request *dms.QueryPersonalSqlsRequest) (*dms.QueryPersonalSqlsResponse, error)

获取当前实例用户收藏sql

func (*DmsClient) QueryPrivilegeList added in v1.59.0 

func (c *DmsClient) QueryPrivilegeList(request *dms.QueryPrivilegeListRequest) (*dms.QueryPrivilegeListResponse, error)

用户授权信息列表

func (*DmsClient) QueryPrivilegeSelfList added in v1.59.0 

func (c *DmsClient) QueryPrivilegeSelfList(request *dms.QueryPrivilegeSelfListRequest) (*dms.QueryPrivilegeSelfListResponse, error)

查看当前用户授权信息列表

func (*DmsClient) QueryTypeInstance added in v1.58.0 

func (c *DmsClient) QueryTypeInstance(request *dms.QueryTypeInstanceRequest) (*dms.QueryTypeInstanceResponse, error)

查询用户数据类型实例

func (*DmsClient) QueryUserList added in v1.59.0 

func (c *DmsClient) QueryUserList(request *dms.QueryUserListRequest) (*dms.QueryUserListResponse, error)

用户管理列表

func (*DmsClient) QueryUserNotSync added in v1.59.0 

func (c *DmsClient) QueryUserNotSync(request *dms.QueryUserNotSyncRequest) (*dms.QueryUserNotSyncResponse, error)

获取主账号下未同步的子账号数据

func (*DmsClient) ReleasePrivilege added in v1.59.0 

func (c *DmsClient) ReleasePrivilege(request *dms.ReleasePrivilegeRequest) (*dms.ReleasePrivilegeResponse, error)

释放权限

func (*DmsClient) RestartOnlineSqlTask added in v1.59.0 

func (c *DmsClient) RestartOnlineSqlTask(request *dms.RestartOnlineSqlTaskRequest) (*dms.RestartOnlineSqlTaskResponse, error)

重启Sql任务

func (*DmsClient) SetConfig 

func (c *DmsClient) SetConfig(config *core.Config)

func (*DmsClient) SetLogger 

func (c *DmsClient) SetLogger(logger core.Logger)

func (*DmsClient) SqlTableInfo 

func (c *DmsClient) SqlTableInfo(request *dms.SqlTableInfoRequest) (*dms.SqlTableInfoResponse, error)

获取sql中建表语句，表中列信息，支持Mysql，Stardb，Tidb，ClickHouse

func (*DmsClient) StartFlow 

func (c *DmsClient) StartFlow(request *dms.StartFlowRequest) (*dms.StartFlowResponse, error)

任务执行，支持Stardb

func (*DmsClient) StartOnlineSqlTask added in v1.59.0 

func (c *DmsClient) StartOnlineSqlTask(request *dms.StartOnlineSqlTaskRequest) (*dms.StartOnlineSqlTaskResponse, error)

启动Sql任务

func (*DmsClient) SuspendOnlineSqlTask added in v1.59.0 

func (c *DmsClient) SuspendOnlineSqlTask(request *dms.SuspendOnlineSqlTaskRequest) (*dms.SuspendOnlineSqlTaskResponse, error)

暂停Sql任务

func (*DmsClient) SyncSubUser added in v1.59.0 

func (c *DmsClient) SyncSubUser(request *dms.SyncSubUserRequest) (*dms.SyncSubUserResponse, error)

同步子账号

func (*DmsClient) TableInfo 

func (c *DmsClient) TableInfo(request *dms.TableInfoRequest) (*dms.TableInfoResponse, error)

获取表元数据，支持Mysql，Stardb，Tidb，ClickHouse

func (*DmsClient) TableList 

func (c *DmsClient) TableList(request *dms.TableListRequest) (*dms.TableListResponse, error)

获取数据库中的表列表，支持Mysql，Stardb，Tidb，ClickHouse

func (*DmsClient) TriggerInfo added in v1.58.0 

func (c *DmsClient) TriggerInfo(request *dms.TriggerInfoRequest) (*dms.TriggerInfoResponse, error)

获取触发器详情，支持Mysql

func (*DmsClient) TriggerList added in v1.58.0 

func (c *DmsClient) TriggerList(request *dms.TriggerListRequest) (*dms.TriggerListResponse, error)

获取触发器列表，支持Mysql

func (*DmsClient) UpdatePersonalSql 

func (c *DmsClient) UpdatePersonalSql(request *dms.UpdatePersonalSqlRequest) (*dms.UpdatePersonalSqlResponse, error)

更新收藏sql

func (*DmsClient) UpdateUserInfo added in v1.59.0 

func (c *DmsClient) UpdateUserInfo(request *dms.UpdateUserInfoRequest) (*dms.UpdateUserInfoResponse, error)

更新用户信息

func (*DmsClient) UploadImportFileTask 

func (c *DmsClient) UploadImportFileTask(request *dms.UploadImportFileTaskRequest) (*dms.UploadImportFileTaskResponse, error)

上传文件，支持Stardb，只支持前端页面使用

func (*DmsClient) ViewInfo 

func (c *DmsClient) ViewInfo(request *dms.ViewInfoRequest) (*dms.ViewInfoResponse, error)

获取视图详情，支持Mysql

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.