diff --git a/frontend/package.json.md5 b/frontend/package.json.md5 index 0a3c8755..544c423d 100755 --- a/frontend/package.json.md5 +++ b/frontend/package.json.md5 @@ -1 +1 @@ -83b4b7d166ed9172beba2d6236382c0b \ No newline at end of file +339d5c974e6ab5cba2d5def171f5ce0a \ No newline at end of file diff --git a/frontend/wailsjs/go/app/App.d.ts b/frontend/wailsjs/go/app/App.d.ts index df5bf2f2..e3c2ba0a 100755 --- a/frontend/wailsjs/go/app/App.d.ts +++ b/frontend/wailsjs/go/app/App.d.ts @@ -21,6 +21,8 @@ export function BuildSQLAuditExport(arg1:sqlaudit.Filter,arg2:string):Promise; +export function CancelImportJob(arg1:string):Promise; + export function CancelQuery(arg1:string):Promise; export function CancelSQLFileExecution(arg1:string):Promise; @@ -115,6 +117,8 @@ export function DBShowCreateTable(arg1:connection.ConnectionConfig,arg2:string,a export function DBTableExists(arg1:connection.ConnectionConfig,arg2:string,arg3:string):Promise; +export function DataImportCapability(arg1:connection.ConnectionConfig):Promise; + export function DataSync(arg1:sync.SyncConfig):Promise; export function DataSyncAnalyze(arg1:sync.SyncConfig):Promise; @@ -179,6 +183,8 @@ export function DataSyncSchedulePreview(arg1:syncjob.JobDefinition,arg2:number): export function DeleteConnection(arg1:string):Promise; +export function DeleteImportJob(arg1:string):Promise; + export function DeleteQuery(arg1:string):Promise; export function DeleteSQLDirectory(arg1:string):Promise; @@ -225,6 +231,8 @@ export function ExportDatabaseSQLWithOptions(arg1:connection.ConnectionConfig,ar export function ExportDatabasesSQLWithOptions(arg1:connection.ConnectionConfig,arg2:Array,arg3:boolean,arg4:app.ExportFileOptions):Promise; +export function ExportImportErrorRows(arg1:string):Promise; + export function ExportQuery(arg1:connection.ConnectionConfig,arg2:string,arg3:string,arg4:string,arg5:string):Promise; export function ExportQueryWithOptions(arg1:connection.ConnectionConfig,arg2:string,arg3:string,arg4:string,arg5:app.ExportFileOptions):Promise; @@ -265,6 +273,8 @@ export function GetEditableSavedConnection(arg1:string):Promise; +export function GetImportJob(arg1:string):Promise; + export function GetSQLAuditEvents(arg1:sqlaudit.Filter):Promise; export function GetSQLAuditHealth():Promise; @@ -295,7 +305,7 @@ export function ImportDataWithProgress(arg1:connection.ConnectionConfig,arg2:str export function ImportDataWithProgressOptions(arg1:connection.ConnectionConfig,arg2:string,arg3:string,arg4:string,arg5:app.ImportFileOptions):Promise; -export function ImportDatabaseSQL(arg1:connection.ConnectionConfig,arg2:string,arg3:string,arg4:string):Promise; +export function ImportDatabaseSQL(arg1:connection.ConnectionConfig,arg2:string,arg3:string,arg4:string,arg5:boolean):Promise; export function ImportLegacyConnections(arg1:Array):Promise>; @@ -341,6 +351,8 @@ export function ListDatabaseCharsets(arg1:connection.ConnectionConfig):Promise; +export function ListImportJobs():Promise; + export function ListInstalledFontFamilies():Promise; export function ListSQLDirectory(arg1:string):Promise; @@ -443,6 +455,8 @@ export function PreviewChanges(arg1:connection.ConnectionConfig,arg2:string,arg3 export function PreviewImportFile(arg1:string):Promise; +export function PreviewImportFileWithOptions(arg1:string,arg2:app.ImportFileOptions):Promise; + export function ReadAppLogTail(arg1:number,arg2:string):Promise; export function ReadSQLFile(arg1:string):Promise; diff --git a/frontend/wailsjs/go/app/App.js b/frontend/wailsjs/go/app/App.js index b9ea70eb..9c6b96ef 100755 --- a/frontend/wailsjs/go/app/App.js +++ b/frontend/wailsjs/go/app/App.js @@ -26,6 +26,10 @@ export function CancelApplicationQuit() { return window['go']['app']['App']['CancelApplicationQuit'](); } +export function CancelImportJob(arg1) { + return window['go']['app']['App']['CancelImportJob'](arg1); +} + export function CancelQuery(arg1) { return window['go']['app']['App']['CancelQuery'](arg1); } @@ -214,6 +218,10 @@ export function DBTableExists(arg1, arg2, arg3) { return window['go']['app']['App']['DBTableExists'](arg1, arg2, arg3); } +export function DataImportCapability(arg1) { + return window['go']['app']['App']['DataImportCapability'](arg1); +} + export function DataSync(arg1) { return window['go']['app']['App']['DataSync'](arg1); } @@ -342,6 +350,10 @@ export function DeleteConnection(arg1) { return window['go']['app']['App']['DeleteConnection'](arg1); } +export function DeleteImportJob(arg1) { + return window['go']['app']['App']['DeleteImportJob'](arg1); +} + export function DeleteQuery(arg1) { return window['go']['app']['App']['DeleteQuery'](arg1); } @@ -434,6 +446,10 @@ export function ExportDatabasesSQLWithOptions(arg1, arg2, arg3, arg4) { return window['go']['app']['App']['ExportDatabasesSQLWithOptions'](arg1, arg2, arg3, arg4); } +export function ExportImportErrorRows(arg1) { + return window['go']['app']['App']['ExportImportErrorRows'](arg1); +} + export function ExportQuery(arg1, arg2, arg3, arg4, arg5) { return window['go']['app']['App']['ExportQuery'](arg1, arg2, arg3, arg4, arg5); } @@ -514,6 +530,10 @@ export function GetGlobalProxyConfig() { return window['go']['app']['App']['GetGlobalProxyConfig'](); } +export function GetImportJob(arg1) { + return window['go']['app']['App']['GetImportJob'](arg1); +} + export function GetSQLAuditEvents(arg1) { return window['go']['app']['App']['GetSQLAuditEvents'](arg1); } @@ -574,8 +594,8 @@ export function ImportDataWithProgressOptions(arg1, arg2, arg3, arg4, arg5) { return window['go']['app']['App']['ImportDataWithProgressOptions'](arg1, arg2, arg3, arg4, arg5); } -export function ImportDatabaseSQL(arg1, arg2, arg3, arg4) { - return window['go']['app']['App']['ImportDatabaseSQL'](arg1, arg2, arg3, arg4); +export function ImportDatabaseSQL(arg1, arg2, arg3, arg4, arg5) { + return window['go']['app']['App']['ImportDatabaseSQL'](arg1, arg2, arg3, arg4, arg5); } export function ImportLegacyConnections(arg1) { @@ -666,6 +686,10 @@ export function ListDatabaseCollations(arg1) { return window['go']['app']['App']['ListDatabaseCollations'](arg1); } +export function ListImportJobs() { + return window['go']['app']['App']['ListImportJobs'](); +} + export function ListInstalledFontFamilies() { return window['go']['app']['App']['ListInstalledFontFamilies'](); } @@ -870,6 +894,10 @@ export function PreviewImportFile(arg1) { return window['go']['app']['App']['PreviewImportFile'](arg1); } +export function PreviewImportFileWithOptions(arg1, arg2) { + return window['go']['app']['App']['PreviewImportFileWithOptions'](arg1, arg2); +} + export function ReadAppLogTail(arg1, arg2) { return window['go']['app']['App']['ReadAppLogTail'](arg1, arg2); } diff --git a/frontend/wailsjs/go/models.ts b/frontend/wailsjs/go/models.ts index 66d0189d..531e9059 100755 --- a/frontend/wailsjs/go/models.ts +++ b/frontend/wailsjs/go/models.ts @@ -1,15 +1,15 @@ export namespace ai { - + export class ChatSendOptions { model?: string; temperature?: number; maxTokens?: number; thinkingIntensity?: string; - + static createFrom(source: any = {}) { return new ChatSendOptions(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.model = source["model"]; @@ -25,11 +25,11 @@ export namespace ai { configPath?: string; command?: string; args?: string[]; - + static createFrom(source: any = {}) { return new MCPClientInstallResult(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.success = source["success"]; @@ -53,11 +53,11 @@ export namespace ai { configPath?: string; command?: string; args?: string[]; - + static createFrom(source: any = {}) { return new MCPClientInstallStatus(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.client = source["client"]; @@ -79,11 +79,11 @@ export namespace ai { path?: string; token?: string; schemaOnly: boolean; - + static createFrom(source: any = {}) { return new MCPHTTPServerOptions(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.addr = source["addr"]; @@ -103,11 +103,11 @@ export namespace ai { authorizationHeader?: string; startedAt?: number; message: string; - + static createFrom(source: any = {}) { return new MCPHTTPServerStatus(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.enabled = source["enabled"]; @@ -131,11 +131,11 @@ export namespace ai { env?: Record; enabled: boolean; timeoutSeconds: number; - + static createFrom(source: any = {}) { return new MCPServerConfig(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.id = source["id"]; @@ -157,11 +157,11 @@ export namespace ai { content: string; structuredContent?: any; isError: boolean; - + static createFrom(source: any = {}) { return new MCPToolCallResult(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.alias = source["alias"]; @@ -182,11 +182,11 @@ export namespace ai { title?: string; description?: string; inputSchema?: Record; - + static createFrom(source: any = {}) { return new MCPToolDescriptor(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.alias = source["alias"]; @@ -201,11 +201,11 @@ export namespace ai { export class ToolCallFunction { name: string; arguments: string; - + static createFrom(source: any = {}) { return new ToolCallFunction(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.name = source["name"]; @@ -216,18 +216,18 @@ export namespace ai { id: string; type: string; function: ToolCallFunction; - + static createFrom(source: any = {}) { return new ToolCall(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.id = source["id"]; this.type = source["type"]; this.function = this.convertValues(source["function"], ToolCallFunction); } - + convertValues(a: any, classs: any, asMap: boolean = false): any { if (!a) { return a; @@ -253,11 +253,11 @@ export namespace ai { tool_call_id?: string; tool_calls?: ToolCall[]; reasoning_content?: string; - + static createFrom(source: any = {}) { return new Message(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.role = source["role"]; @@ -267,7 +267,7 @@ export namespace ai { this.tool_calls = this.convertValues(source["tool_calls"], ToolCall); this.reasoning_content = source["reasoning_content"]; } - + convertValues(a: any, classs: any, asMap: boolean = false): any { if (!a) { return a; @@ -303,11 +303,11 @@ export namespace ai { maxTokens: number; temperature: number; thinkingIntensity?: string; - + static createFrom(source: any = {}) { return new ProviderConfig(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.id = source["id"]; @@ -333,11 +333,11 @@ export namespace ai { operationType: string; requiresConfirm: boolean; warningMessage?: string; - + static createFrom(source: any = {}) { return new SafetyResult(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.allowed = source["allowed"]; @@ -354,11 +354,11 @@ export namespace ai { enabled: boolean; scopes?: string[]; requiredTools?: string[]; - + static createFrom(source: any = {}) { return new SkillConfig(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.id = source["id"]; @@ -374,11 +374,11 @@ export namespace ai { name: string; description: string; parameters: any; - + static createFrom(source: any = {}) { return new ToolFunction(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.name = source["name"]; @@ -389,17 +389,17 @@ export namespace ai { export class Tool { type: string; function: ToolFunction; - + static createFrom(source: any = {}) { return new Tool(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.type = source["type"]; this.function = this.convertValues(source["function"], ToolFunction); } - + convertValues(a: any, classs: any, asMap: boolean = false): any { if (!a) { return a; @@ -418,19 +418,19 @@ export namespace ai { return a; } } - - - + + + export class UserPromptSettings { global: string; database: string; jvm: string; jvmDiagnostic: string; - + static createFrom(source: any = {}) { return new UserPromptSettings(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.global = source["global"]; @@ -443,16 +443,16 @@ export namespace ai { } export namespace app { - + export class CloudBackupConnectionSummary { id: string; name: string; host?: string; - + static createFrom(source: any = {}) { return new CloudBackupConnectionSummary(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.id = source["id"]; @@ -466,11 +466,11 @@ export namespace app { files?: string[]; connections?: CloudBackupConnectionSummary[]; restartRequired: boolean; - + static createFrom(source: any = {}) { return new CloudBackupCategory(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.id = source["id"]; @@ -479,7 +479,7 @@ export namespace app { this.connections = this.convertValues(source["connections"], CloudBackupConnectionSummary); this.restartRequired = source["restartRequired"]; } - + convertValues(a: any, classs: any, asMap: boolean = false): any { if (!a) { return a; @@ -522,11 +522,11 @@ export namespace app { s3LastSyncError?: string; s3RemoteAvailable: boolean; s3RemoteUpdatedAt?: string; - + static createFrom(source: any = {}) { return new CloudBackupConfig(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.enabled = source["enabled"]; @@ -574,11 +574,11 @@ export namespace app { clearS3Credential: boolean; clearRemoteSecret: boolean; clearEncryptionKey: boolean; - + static createFrom(source: any = {}) { return new CloudBackupConfigInput(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.enabled = source["enabled"]; @@ -602,17 +602,17 @@ export namespace app { this.clearEncryptionKey = source["clearEncryptionKey"]; } } - + export class CloudBackupRestorePoint { objectKey: string; lastModified?: string; size?: number; etag?: string; - + static createFrom(source: any = {}) { return new CloudBackupRestorePoint(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.objectKey = source["objectKey"]; @@ -629,11 +629,11 @@ export namespace app { restartRequired: boolean; categories: CloudBackupCategory[]; confirmationToken?: string; - + static createFrom(source: any = {}) { return new CloudBackupRestorePreview(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.createdAt = source["createdAt"]; @@ -644,7 +644,7 @@ export namespace app { this.categories = this.convertValues(source["categories"], CloudBackupCategory); this.confirmationToken = source["confirmationToken"]; } - + convertValues(a: any, classs: any, asMap: boolean = false): any { if (!a) { return a; @@ -666,11 +666,11 @@ export namespace app { export class CloudBackupRestoreRequest { confirmationToken: string; categories: string[]; - + static createFrom(source: any = {}) { return new CloudBackupRestoreRequest(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.confirmationToken = source["confirmationToken"]; @@ -687,11 +687,11 @@ export namespace app { remoteAvailable: boolean; remoteUpdatedAt?: string; dirty: boolean; - + static createFrom(source: any = {}) { return new CloudBackupStatus(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.configured = source["configured"]; @@ -710,11 +710,11 @@ export namespace app { filePassword?: string; connectionIds?: string[]; redisDbAliases?: Record; - + static createFrom(source: any = {}) { return new ConnectionExportOptions(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.includeSecrets = source["includeSecrets"]; @@ -726,17 +726,17 @@ export namespace app { export class ConnectionPackageImportResult { connections: connection.SavedConnectionView[]; redisDbAliases?: Record; - + static createFrom(source: any = {}) { return new ConnectionPackageImportResult(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.connections = this.convertValues(source["connections"], connection.SavedConnectionView); this.redisDbAliases = source["redisDbAliases"]; } - + convertValues(a: any, classs: any, asMap: boolean = false): any { if (!a) { return a; @@ -755,6 +755,71 @@ export namespace app { return a; } } + export class DataImportModeCapability { + supported: boolean; + reason: string; + requiresPinnedSession: boolean; + supportsTransactionalBatch: boolean; + supportsContinue: boolean; + supportedFormats: string[]; + supportedEncodings: string[]; + supportedCompressions: string[]; + supportedClientDirectives: string[]; + supportedConflictPolicies: string[]; + + static createFrom(source: any = {}) { + return new DataImportModeCapability(source); + } + + constructor(source: any = {}) { + if ('string' === typeof source) source = JSON.parse(source); + this.supported = source["supported"]; + this.reason = source["reason"]; + this.requiresPinnedSession = source["requiresPinnedSession"]; + this.supportsTransactionalBatch = source["supportsTransactionalBatch"]; + this.supportsContinue = source["supportsContinue"]; + this.supportedFormats = source["supportedFormats"]; + this.supportedEncodings = source["supportedEncodings"]; + this.supportedCompressions = source["supportedCompressions"]; + this.supportedClientDirectives = source["supportedClientDirectives"]; + this.supportedConflictPolicies = source["supportedConflictPolicies"]; + } + } + export class DataImportCapability { + databaseType: string; + tableImport: DataImportModeCapability; + sqlFileImport: DataImportModeCapability; + + static createFrom(source: any = {}) { + return new DataImportCapability(source); + } + + constructor(source: any = {}) { + if ('string' === typeof source) source = JSON.parse(source); + this.databaseType = source["databaseType"]; + this.tableImport = this.convertValues(source["tableImport"], DataImportModeCapability); + this.sqlFileImport = this.convertValues(source["sqlFileImport"], DataImportModeCapability); + } + + convertValues(a: any, classs: any, asMap: boolean = false): any { + if (!a) { + return a; + } + if (a.slice && a.map) { + return (a as any[]).map(elem => this.convertValues(elem, classs)); + } else if ("object" === typeof a) { + if (asMap) { + for (const key of Object.keys(a)) { + a[key] = new classs(a[key]); + } + return a; + } + return new classs(a); + } + return a; + } + } + export class ElasticsearchConsoleRequestResult { index: number; method: string; @@ -773,11 +838,11 @@ export namespace app { outcomeUnknown?: boolean; readOnly: boolean; serverMajor?: number; - + static createFrom(source: any = {}) { return new ElasticsearchConsoleRequestResult(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.index = source["index"]; @@ -809,11 +874,11 @@ export namespace app { completed: number; failedIndex?: number; outcomeUnknown?: boolean; - + static createFrom(source: any = {}) { return new ElasticsearchConsoleExecutionResult(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.success = source["success"]; @@ -826,7 +891,7 @@ export namespace app { this.failedIndex = source["failedIndex"]; this.outcomeUnknown = source["outcomeUnknown"]; } - + convertValues(a: any, classs: any, asMap: boolean = false): any { if (!a) { return a; @@ -860,11 +925,11 @@ export namespace app { containsScript?: boolean; operationCount?: number; blockReason?: string; - + static createFrom(source: any = {}) { return new ElasticsearchConsoleRequestInspection(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.index = source["index"]; @@ -895,11 +960,11 @@ export namespace app { blocked: boolean; blockReason?: string; serverMajor?: number; - + static createFrom(source: any = {}) { return new ElasticsearchConsoleInspection(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.success = source["success"]; @@ -914,7 +979,7 @@ export namespace app { this.blockReason = source["blockReason"]; this.serverMajor = source["serverMajor"]; } - + convertValues(a: any, classs: any, asMap: boolean = false): any { if (!a) { return a; @@ -933,8 +998,8 @@ export namespace app { return a; } } - - + + export class ExportFileOptions { format: string; columns?: string[]; @@ -949,11 +1014,11 @@ export namespace app { insertSQLColumnTypes?: Record; insertSQLTargetColumns?: Record; insertSQLAllowEmptyTargetTable?: boolean; - + static createFrom(source: any = {}) { return new ExportFileOptions(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.format = source["format"]; @@ -974,26 +1039,48 @@ export namespace app { export class ImportFileOptions { columnMappings?: Record; jobId?: string; - + continueOnError?: boolean; + encoding?: string; + delimiter?: string; + headerRow?: number; + nullToken?: string; + emptyStringAsNull?: boolean; + sheetName?: string; + sourceIdentityToken?: string; + conflictPolicy?: string; + conflictKeyColumns?: string[]; + resumeJobId?: string; + static createFrom(source: any = {}) { return new ImportFileOptions(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.columnMappings = source["columnMappings"]; this.jobId = source["jobId"]; + this.continueOnError = source["continueOnError"]; + this.encoding = source["encoding"]; + this.delimiter = source["delimiter"]; + this.headerRow = source["headerRow"]; + this.nullToken = source["nullToken"]; + this.emptyStringAsNull = source["emptyStringAsNull"]; + this.sheetName = source["sheetName"]; + this.sourceIdentityToken = source["sourceIdentityToken"]; + this.conflictPolicy = source["conflictPolicy"]; + this.conflictKeyColumns = source["conflictKeyColumns"]; + this.resumeJobId = source["resumeJobId"]; } } export class NacosConfigIdentity { dataId: string; group: string; index?: number; - + static createFrom(source: any = {}) { return new NacosConfigIdentity(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.dataId = source["dataId"]; @@ -1009,11 +1096,11 @@ export namespace app { pageNo?: number; pageSize?: number; search?: string; - + static createFrom(source: any = {}) { return new NacosConfigQuery(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.namespaceId = source["namespaceId"]; @@ -1029,11 +1116,11 @@ export namespace app { id: string; showName: string; description?: string; - + static createFrom(source: any = {}) { return new NacosCreateNamespacePayload(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.id = source["id"]; @@ -1046,11 +1133,11 @@ export namespace app { namespaceName?: string; scope?: string; items?: NacosConfigIdentity[]; - + static createFrom(source: any = {}) { return new NacosExportConfigsOptions(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.namespaceId = source["namespaceId"]; @@ -1058,7 +1145,7 @@ export namespace app { this.scope = source["scope"]; this.items = this.convertValues(source["items"], NacosConfigIdentity); } - + convertValues(a: any, classs: any, asMap: boolean = false): any { if (!a) { return a; @@ -1083,11 +1170,11 @@ export namespace app { group: string; pageNo?: number; pageSize?: number; - + static createFrom(source: any = {}) { return new NacosHistoryQuery(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.namespaceId = source["namespaceId"]; @@ -1103,11 +1190,11 @@ export namespace app { file?: string; scope?: string; items?: NacosConfigIdentity[]; - + static createFrom(source: any = {}) { return new NacosImportConfigsOptions(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.namespaceId = source["namespaceId"]; @@ -1116,7 +1203,7 @@ export namespace app { this.scope = source["scope"]; this.items = this.convertValues(source["items"], NacosConfigIdentity); } - + convertValues(a: any, classs: any, asMap: boolean = false): any { if (!a) { return a; @@ -1147,11 +1234,11 @@ export namespace app { healthy?: boolean; ephemeral?: boolean; metadata?: Record; - + static createFrom(source: any = {}) { return new NacosInstancePayload(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.namespaceId = source["namespaceId"]; @@ -1173,11 +1260,11 @@ export namespace app { groupName?: string; clusters?: string; healthyOnly?: boolean; - + static createFrom(source: any = {}) { return new NacosInstanceQuery(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.namespaceId = source["namespaceId"]; @@ -1196,11 +1283,11 @@ export namespace app { appName?: string; desc?: string; betaIps?: string; - + static createFrom(source: any = {}) { return new NacosPublishConfigPayload(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.namespaceId = source["namespaceId"]; @@ -1220,11 +1307,11 @@ export namespace app { ephemeral?: boolean; protectThreshold?: number; metadata?: Record; - + static createFrom(source: any = {}) { return new NacosServicePayload(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.namespaceId = source["namespaceId"]; @@ -1240,11 +1327,11 @@ export namespace app { groupName?: string; pageNo?: number; pageSize?: number; - + static createFrom(source: any = {}) { return new NacosServiceQuery(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.namespaceId = source["namespaceId"]; @@ -1260,11 +1347,11 @@ export namespace app { dataId: string; group: string; contentMd5?: string; - + static createFrom(source: any = {}) { return new NacosStartConfigListenPayload(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.watchId = source["watchId"]; @@ -1279,11 +1366,11 @@ export namespace app { id: string; showName: string; description?: string; - + static createFrom(source: any = {}) { return new NacosUpdateNamespacePayload(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.id = source["id"]; @@ -1295,11 +1382,11 @@ export namespace app { scope?: string; keys?: string[]; pattern?: string; - + static createFrom(source: any = {}) { return new RedisExportKeysOptions(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.scope = source["scope"]; @@ -1312,11 +1399,11 @@ export namespace app { scope?: string; keys?: string[]; file?: string; - + static createFrom(source: any = {}) { return new RedisImportKeysOptions(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.conflictMode = source["conflictMode"]; @@ -1342,11 +1429,11 @@ export namespace app { export class SecurityUpdateOptions { allowPartial?: boolean; writeBackup?: boolean; - + static createFrom(source: any = {}) { return new SecurityUpdateOptions(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.allowPartial = source["allowPartial"]; @@ -1358,11 +1445,11 @@ export namespace app { sourceType: string; rawPayload?: string; options?: SecurityUpdateOptions; - + static createFrom(source: any = {}) { return new RestartSecurityUpdateRequest(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.migrationId = source["migrationId"]; @@ -1370,7 +1457,7 @@ export namespace app { this.rawPayload = source["rawPayload"]; this.options = this.convertValues(source["options"], SecurityUpdateOptions); } - + convertValues(a: any, classs: any, asMap: boolean = false): any { if (!a) { return a; @@ -1401,11 +1488,11 @@ export namespace app { options: resultdiff.CompareOptions; maxRowsPerSide?: number; includeSameRows?: boolean; - + static createFrom(source: any = {}) { return new ResultDiffStartRequest(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.jobId = source["jobId"]; @@ -1420,7 +1507,7 @@ export namespace app { this.maxRowsPerSide = source["maxRowsPerSide"]; this.includeSameRows = source["includeSameRows"]; } - + convertValues(a: any, classs: any, asMap: boolean = false): any { if (!a) { return a; @@ -1441,11 +1528,11 @@ export namespace app { } export class RetrySecurityUpdateRequest { migrationId?: string; - + static createFrom(source: any = {}) { return new RetrySecurityUpdateRequest(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.migrationId = source["migrationId"]; @@ -1461,11 +1548,11 @@ export namespace app { reasonCode: string; action: string; message: string; - + static createFrom(source: any = {}) { return new SecurityUpdateIssue(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.id = source["id"]; @@ -1479,18 +1566,18 @@ export namespace app { this.message = source["message"]; } } - + export class SecurityUpdateSummary { total: number; updated: number; pending: number; skipped: number; failed: number; - + static createFrom(source: any = {}) { return new SecurityUpdateSummary(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.total = source["total"]; @@ -1518,11 +1605,11 @@ export namespace app { summary: SecurityUpdateSummary; issues: SecurityUpdateIssue[]; lastError?: string; - + static createFrom(source: any = {}) { return new SecurityUpdateStatus(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.schemaVersion = source["schemaVersion"]; @@ -1543,7 +1630,7 @@ export namespace app { this.issues = this.convertValues(source["issues"], SecurityUpdateIssue); this.lastError = source["lastError"]; } - + convertValues(a: any, classs: any, asMap: boolean = false): any { if (!a) { return a; @@ -1562,23 +1649,23 @@ export namespace app { return a; } } - + export class StartSecurityUpdateRequest { sourceType: string; rawPayload?: string; options?: SecurityUpdateOptions; - + static createFrom(source: any = {}) { return new StartSecurityUpdateRequest(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.sourceType = source["sourceType"]; this.rawPayload = source["rawPayload"]; this.options = this.convertValues(source["options"], SecurityUpdateOptions); } - + convertValues(a: any, classs: any, asMap: boolean = false): any { if (!a) { return a; @@ -1601,15 +1688,15 @@ export namespace app { } export namespace connection { - + export class UpdateRow { keys: Record; values: Record; - + static createFrom(source: any = {}) { return new UpdateRow(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.keys = source["keys"]; @@ -1621,11 +1708,11 @@ export namespace connection { updates: UpdateRow[]; deletes: any[]; locatorStrategy?: string; - + static createFrom(source: any = {}) { return new ChangeSet(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.inserts = source["inserts"]; @@ -1633,7 +1720,7 @@ export namespace connection { this.deletes = source["deletes"]; this.locatorStrategy = source["locatorStrategy"]; } - + convertValues(a: any, classs: any, asMap: boolean = false): any { if (!a) { return a; @@ -1662,11 +1749,11 @@ export namespace connection { allowTraceCommands?: boolean; allowMutatingCommands?: boolean; timeoutSeconds?: number; - + static createFrom(source: any = {}) { return new JVMDiagnosticConfig(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.enabled = source["enabled"]; @@ -1685,11 +1772,11 @@ export namespace connection { baseUrl?: string; apiKey?: string; timeoutSeconds?: number; - + static createFrom(source: any = {}) { return new JVMAgentConfig(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.enabled = source["enabled"]; @@ -1703,11 +1790,11 @@ export namespace connection { baseUrl?: string; apiKey?: string; timeoutSeconds?: number; - + static createFrom(source: any = {}) { return new JVMEndpointConfig(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.enabled = source["enabled"]; @@ -1723,11 +1810,11 @@ export namespace connection { username?: string; password?: string; domainAllowlist?: string[]; - + static createFrom(source: any = {}) { return new JVMJMXConfig(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.enabled = source["enabled"]; @@ -1747,11 +1834,11 @@ export namespace connection { endpoint?: JVMEndpointConfig; agent?: JVMAgentConfig; diagnostic?: JVMDiagnosticConfig; - + static createFrom(source: any = {}) { return new JVMConfig(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.environment = source["environment"]; @@ -1763,7 +1850,7 @@ export namespace connection { this.agent = this.convertValues(source["agent"], JVMAgentConfig); this.diagnostic = this.convertValues(source["diagnostic"], JVMDiagnosticConfig); } - + convertValues(a: any, classs: any, asMap: boolean = false): any { if (!a) { return a; @@ -1787,11 +1874,11 @@ export namespace connection { port: number; user?: string; password?: string; - + static createFrom(source: any = {}) { return new HTTPTunnelConfig(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.host = source["host"]; @@ -1806,11 +1893,11 @@ export namespace connection { port: number; user?: string; password?: string; - + static createFrom(source: any = {}) { return new ProxyConfig(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.type = source["type"]; @@ -1826,11 +1913,11 @@ export namespace connection { user: string; password: string; keyPath: string; - + static createFrom(source: any = {}) { return new SSHConfig(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.host = source["host"]; @@ -1845,11 +1932,11 @@ export namespace connection { restrictStructureEdit?: boolean; restrictScriptExecution?: boolean; restrictDataImport?: boolean; - + static createFrom(source: any = {}) { return new ConnectionProtectionConfig(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.restrictDataEdit = source["restrictDataEdit"]; @@ -1907,11 +1994,11 @@ export namespace connection { mongoReplicaUser?: string; mongoReplicaPassword?: string; jvm?: JVMConfig; - + static createFrom(source: any = {}) { return new ConnectionConfig(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.id = source["id"]; @@ -1963,7 +2050,7 @@ export namespace connection { this.mongoReplicaPassword = source["mongoReplicaPassword"]; this.jvm = this.convertValues(source["jvm"], JVMConfig); } - + convertValues(a: any, classs: any, asMap: boolean = false): any { if (!a) { return a; @@ -1982,7 +2069,7 @@ export namespace connection { return a; } } - + export class GlobalProxyView { enabled: boolean; type: string; @@ -1992,11 +2079,11 @@ export namespace connection { password?: string; hasPassword?: boolean; secretRef?: string; - + static createFrom(source: any = {}) { return new GlobalProxyView(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.enabled = source["enabled"]; @@ -2009,13 +2096,13 @@ export namespace connection { this.secretRef = source["secretRef"]; } } - - - - - - - + + + + + + + export class QueryResult { success: boolean; message: string; @@ -2025,11 +2112,11 @@ export namespace connection { queryId?: string; transactionId?: string; transactionPending?: boolean; - + static createFrom(source: any = {}) { return new QueryResult(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.success = source["success"]; @@ -2042,7 +2129,7 @@ export namespace connection { this.transactionPending = source["transactionPending"]; } } - + export class SaveGlobalProxyInput { enabled: boolean; type: string; @@ -2051,11 +2138,11 @@ export namespace connection { user?: string; password?: string; clearPassword?: boolean; - + static createFrom(source: any = {}) { return new SaveGlobalProxyInput(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.enabled = source["enabled"]; @@ -2070,11 +2157,11 @@ export namespace connection { export class SchemaVisibilityRule { mode: string; schemas?: string[]; - + static createFrom(source: any = {}) { return new SchemaVisibilityRule(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.mode = source["mode"]; @@ -2102,11 +2189,16 @@ export namespace connection { clearRedisSentinelPassword?: boolean; clearOpaqueURI?: boolean; clearOpaqueDSN?: boolean; - + clearJVMJMXPassword?: boolean; + clearJVMEndpointAPIKey?: boolean; + clearJVMAgentAPIKey?: boolean; + clearJVMDiagnosticAPIKey?: boolean; + clearSensitiveConnectionParams?: boolean; + static createFrom(source: any = {}) { return new SavedConnectionInput(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.id = source["id"]; @@ -2129,8 +2221,13 @@ export namespace connection { this.clearRedisSentinelPassword = source["clearRedisSentinelPassword"]; this.clearOpaqueURI = source["clearOpaqueURI"]; this.clearOpaqueDSN = source["clearOpaqueDSN"]; + this.clearJVMJMXPassword = source["clearJVMJMXPassword"]; + this.clearJVMEndpointAPIKey = source["clearJVMEndpointAPIKey"]; + this.clearJVMAgentAPIKey = source["clearJVMAgentAPIKey"]; + this.clearJVMDiagnosticAPIKey = source["clearJVMDiagnosticAPIKey"]; + this.clearSensitiveConnectionParams = source["clearSensitiveConnectionParams"]; } - + convertValues(a: any, classs: any, asMap: boolean = false): any { if (!a) { return a; @@ -2171,11 +2268,16 @@ export namespace connection { hasRedisSentinelPassword?: boolean; hasOpaqueURI?: boolean; hasOpaqueDSN?: boolean; - + hasJVMJMXPassword?: boolean; + hasJVMEndpointAPIKey?: boolean; + hasJVMAgentAPIKey?: boolean; + hasJVMDiagnosticAPIKey?: boolean; + hasSensitiveConnectionParams?: boolean; + static createFrom(source: any = {}) { return new SavedConnectionView(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.id = source["id"]; @@ -2199,8 +2301,13 @@ export namespace connection { this.hasRedisSentinelPassword = source["hasRedisSentinelPassword"]; this.hasOpaqueURI = source["hasOpaqueURI"]; this.hasOpaqueDSN = source["hasOpaqueDSN"]; + this.hasJVMJMXPassword = source["hasJVMJMXPassword"]; + this.hasJVMEndpointAPIKey = source["hasJVMEndpointAPIKey"]; + this.hasJVMAgentAPIKey = source["hasJVMAgentAPIKey"]; + this.hasJVMDiagnosticAPIKey = source["hasJVMDiagnosticAPIKey"]; + this.hasSensitiveConnectionParams = source["hasSensitiveConnectionParams"]; } - + convertValues(a: any, classs: any, asMap: boolean = false): any { if (!a) { return a; @@ -2230,11 +2337,11 @@ export namespace connection { fingerprintVersion?: string; bindingStatus?: string; originalConnectionId?: string; - + static createFrom(source: any = {}) { return new SavedQuery(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.id = source["id"]; @@ -2255,11 +2362,11 @@ export namespace connection { parentGroupId: string; queryIds: string[]; childOrder: string[]; - + static createFrom(source: any = {}) { return new SavedQueryGroup(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.id = source["id"]; @@ -2273,18 +2380,18 @@ export namespace connection { queries: SavedQuery[]; groups?: SavedQueryGroup[]; legacyConnections?: SavedConnectionInput[]; - + static createFrom(source: any = {}) { return new SavedQueryImportPayload(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.queries = this.convertValues(source["queries"], SavedQuery); this.groups = this.convertValues(source["groups"], SavedQueryGroup); this.legacyConnections = this.convertValues(source["legacyConnections"], SavedConnectionInput); } - + convertValues(a: any, classs: any, asMap: boolean = false): any { if (!a) { return a; @@ -2303,23 +2410,23 @@ export namespace connection { return a; } } - + export class TestGlobalProxyInput { proxy: SaveGlobalProxyInput; url: string; timeoutSeconds?: number; - + static createFrom(source: any = {}) { return new TestGlobalProxyInput(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.proxy = this.convertValues(source["proxy"], SaveGlobalProxyInput); this.url = source["url"]; this.timeoutSeconds = source["timeoutSeconds"]; } - + convertValues(a: any, classs: any, asMap: boolean = false): any { if (!a) { return a; @@ -2342,7 +2449,7 @@ export namespace connection { } export namespace jvm { - + export class ChangeRequest { providerMode: string; resourceId: string; @@ -2352,11 +2459,11 @@ export namespace jvm { expectedVersion?: string; confirmationToken?: string; payload?: Record; - + static createFrom(source: any = {}) { return new ChangeRequest(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.providerMode = source["providerMode"]; @@ -2375,11 +2482,11 @@ export namespace jvm { command: string; source?: string; reason?: string; - + static createFrom(source: any = {}) { return new DiagnosticCommandRequest(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.sessionId = source["sessionId"]; @@ -2392,11 +2499,11 @@ export namespace jvm { export class DiagnosticSessionRequest { title?: string; reason?: string; - + static createFrom(source: any = {}) { return new DiagnosticSessionRequest(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.title = source["title"]; @@ -2407,16 +2514,16 @@ export namespace jvm { } export namespace nativewindow { - + export class HostStateRequest { id: string; revision: number; storeState: Record; - + static createFrom(source: any = {}) { return new HostStateRequest(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.id = source["id"]; @@ -2433,11 +2540,11 @@ export namespace nativewindow { y: number; width: number; height: number; - + static createFrom(source: any = {}) { return new OpenRequest(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.id = source["id"]; @@ -2455,11 +2562,11 @@ export namespace nativewindow { y: number; width: number; height: number; - + static createFrom(source: any = {}) { return new WindowBounds(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.x = source["x"]; @@ -2475,11 +2582,11 @@ export namespace nativewindow { bounds?: WindowBounds; visibilityRevision?: number; applied?: boolean; - + static createFrom(source: any = {}) { return new OperationResult(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.success = source["success"]; @@ -2489,7 +2596,7 @@ export namespace nativewindow { this.visibilityRevision = source["visibilityRevision"]; this.applied = source["applied"]; } - + convertValues(a: any, classs: any, asMap: boolean = false): any { if (!a) { return a; @@ -2508,7 +2615,7 @@ export namespace nativewindow { return a; } } - + export class WindowInfo { id: string; kind: string; @@ -2522,11 +2629,11 @@ export namespace nativewindow { ready: boolean; closeSent: boolean; hidden?: boolean; - + static createFrom(source: any = {}) { return new WindowInfo(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.id = source["id"]; @@ -2547,15 +2654,15 @@ export namespace nativewindow { } export namespace redis { - + export class ZSetMember { member: string; score: number; - + static createFrom(source: any = {}) { return new ZSetMember(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.member = source["member"]; @@ -2566,16 +2673,16 @@ export namespace redis { } export namespace resultdiff { - + export class CompareOptions { trimStrings: boolean; ignoreCase: boolean; nullEqualsEmpty: boolean; - + static createFrom(source: any = {}) { return new CompareOptions(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.trimStrings = source["trimStrings"]; @@ -2588,11 +2695,11 @@ export namespace resultdiff { sql?: string; columns?: string[]; rows?: any[]; - + static createFrom(source: any = {}) { return new DatasetSpec(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.mode = source["mode"]; @@ -2608,11 +2715,11 @@ export namespace resultdiff { offset: number; limit: number; includeSameRows?: boolean; - + static createFrom(source: any = {}) { return new PageRequest(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.jobId = source["jobId"]; @@ -2629,11 +2736,11 @@ export namespace resultdiff { columns?: string[]; rows: any[]; done: boolean; - + static createFrom(source: any = {}) { return new UploadChunkRequest(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.jobId = source["jobId"]; @@ -2647,7 +2754,7 @@ export namespace resultdiff { } export namespace sqlaudit { - + export class Filter { search: string; connectionId: string; @@ -2661,11 +2768,11 @@ export namespace sqlaudit { toTimestamp: number; page: number; pageSize: number; - + static createFrom(source: any = {}) { return new Filter(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.search = source["search"]; @@ -2687,11 +2794,11 @@ export namespace sqlaudit { captureMode: string; retentionDays: number; maxRecords: number; - + static createFrom(source: any = {}) { return new Settings(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.enabled = source["enabled"]; @@ -2868,11 +2975,11 @@ export namespace sync { selectedInsertPks?: string[]; selectedUpdatePks?: string[]; selectedDeletePks?: string[]; - + static createFrom(source: any = {}) { return new TableOptions(source); } - + constructor(source: any = {}) { if ('string' === typeof source) source = JSON.parse(source); this.insert = source["insert"]; @@ -2947,6 +3054,9 @@ export namespace sync { return a; } } + + + export class SyncResult { success: boolean; message: string;