v1

package
v0.1.50 Latest Latest
Warning

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

 Go to latest Published: Jul 27, 2023 License: Apache-2.0, BSD-2-Clause, BSD-3-Clause Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func DliClientBuilder 

func DliClientBuilder() *http_client.HcHttpClientBuilder

func GenReqDefForAssociateConnectionQueue 

func GenReqDefForAssociateConnectionQueue() *def.HttpRequestDef

func GenReqDefForAssociateQueueToElasticResourcePool 

func GenReqDefForAssociateQueueToElasticResourcePool() *def.HttpRequestDef

func GenReqDefForAuthorizeResource 

func GenReqDefForAuthorizeResource() *def.HttpRequestDef

func GenReqDefForBatchDeleteFlinkJobs 

func GenReqDefForBatchDeleteFlinkJobs() *def.HttpRequestDef

func GenReqDefForBatchDeleteQueuePlans 

func GenReqDefForBatchDeleteQueuePlans() *def.HttpRequestDef

func GenReqDefForBatchRunFlinkJobs 

func GenReqDefForBatchRunFlinkJobs() *def.HttpRequestDef

func GenReqDefForCancelBatchJob 

func GenReqDefForCancelBatchJob() *def.HttpRequestDef

func GenReqDefForCancelSqlJob 

func GenReqDefForCancelSqlJob() *def.HttpRequestDef

func GenReqDefForChangeAuthorization 

func GenReqDefForChangeAuthorization() *def.HttpRequestDef

func GenReqDefForChangeFlinkJobStatusReport 

func GenReqDefForChangeFlinkJobStatusReport() *def.HttpRequestDef

func GenReqDefForChangeQueuePlan 

func GenReqDefForChangeQueuePlan() *def.HttpRequestDef

func GenReqDefForCheckConnection 

func GenReqDefForCheckConnection() *def.HttpRequestDef

func GenReqDefForCheckSql 

func GenReqDefForCheckSql() *def.HttpRequestDef

func GenReqDefForCreateAuthInfo 

func GenReqDefForCreateAuthInfo() *def.HttpRequestDef

func GenReqDefForCreateBatchJob 

func GenReqDefForCreateBatchJob() *def.HttpRequestDef

func GenReqDefForCreateDatabase 

func GenReqDefForCreateDatabase() *def.HttpRequestDef

func GenReqDefForCreateDatasourceConnection 

func GenReqDefForCreateDatasourceConnection() *def.HttpRequestDef

func GenReqDefForCreateDliAgency 

func GenReqDefForCreateDliAgency() *def.HttpRequestDef

func GenReqDefForCreateElasticResourcePool 

func GenReqDefForCreateElasticResourcePool() *def.HttpRequestDef

func GenReqDefForCreateEnhancedConnection 

func GenReqDefForCreateEnhancedConnection() *def.HttpRequestDef

func GenReqDefForCreateEnhancedConnectionRoutes 

func GenReqDefForCreateEnhancedConnectionRoutes() *def.HttpRequestDef

func GenReqDefForCreateFlinkJar 

func GenReqDefForCreateFlinkJar() *def.HttpRequestDef

func GenReqDefForCreateFlinkSqlJob 

func GenReqDefForCreateFlinkSqlJob() *def.HttpRequestDef

func GenReqDefForCreateFlinkTemplate 

func GenReqDefForCreateFlinkTemplate() *def.HttpRequestDef

func GenReqDefForCreateGlobalValue 

func GenReqDefForCreateGlobalValue() *def.HttpRequestDef

func GenReqDefForCreateIefMessageChannel 

func GenReqDefForCreateIefMessageChannel() *def.HttpRequestDef

func GenReqDefForCreateIefSystemEvents 

func GenReqDefForCreateIefSystemEvents() *def.HttpRequestDef

func GenReqDefForCreateJobTemplates 

func GenReqDefForCreateJobTemplates() *def.HttpRequestDef

func GenReqDefForCreateQueue 

func GenReqDefForCreateQueue() *def.HttpRequestDef

func GenReqDefForCreateQueuePlan 

func GenReqDefForCreateQueuePlan() *def.HttpRequestDef

func GenReqDefForCreateSqlJob 

func GenReqDefForCreateSqlJob() *def.HttpRequestDef

func GenReqDefForCreateSqlTemplates 

func GenReqDefForCreateSqlTemplates() *def.HttpRequestDef

func GenReqDefForCreateStreamGraph 

func GenReqDefForCreateStreamGraph() *def.HttpRequestDef

func GenReqDefForCreateTable 

func GenReqDefForCreateTable() *def.HttpRequestDef

func GenReqDefForDeleteAuthInfo 

func GenReqDefForDeleteAuthInfo() *def.HttpRequestDef

func GenReqDefForDeleteDatabase 

func GenReqDefForDeleteDatabase() *def.HttpRequestDef

func GenReqDefForDeleteDatasourceConnection 

func GenReqDefForDeleteDatasourceConnection() *def.HttpRequestDef

func GenReqDefForDeleteElasticResourcePool 

func GenReqDefForDeleteElasticResourcePool() *def.HttpRequestDef

func GenReqDefForDeleteEnhancedConnection 

func GenReqDefForDeleteEnhancedConnection() *def.HttpRequestDef

func GenReqDefForDeleteEnhancedConnectionRoutes 

func GenReqDefForDeleteEnhancedConnectionRoutes() *def.HttpRequestDef

func GenReqDefForDeleteFlinkJob 

func GenReqDefForDeleteFlinkJob() *def.HttpRequestDef

func GenReqDefForDeleteFlinkTemplate 

func GenReqDefForDeleteFlinkTemplate() *def.HttpRequestDef

func GenReqDefForDeleteGlobalValue 

func GenReqDefForDeleteGlobalValue() *def.HttpRequestDef

func GenReqDefForDeleteQueue 

func GenReqDefForDeleteQueue() *def.HttpRequestDef

func GenReqDefForDeleteQueuePlan 

func GenReqDefForDeleteQueuePlan() *def.HttpRequestDef

func GenReqDefForDeleteResource 

func GenReqDefForDeleteResource() *def.HttpRequestDef

func GenReqDefForDeleteSqlTemplates 

func GenReqDefForDeleteSqlTemplates() *def.HttpRequestDef

func GenReqDefForDeleteTable 

func GenReqDefForDeleteTable() *def.HttpRequestDef

func GenReqDefForDisassociateConnectionQueue 

func GenReqDefForDisassociateConnectionQueue() *def.HttpRequestDef

func GenReqDefForExportFlinkJob 

func GenReqDefForExportFlinkJob() *def.HttpRequestDef

func GenReqDefForExportSqlJobResult 

func GenReqDefForExportSqlJobResult() *def.HttpRequestDef

func GenReqDefForExportTable 

func GenReqDefForExportTable() *def.HttpRequestDef

func GenReqDefForImportFlinkJob 

func GenReqDefForImportFlinkJob() *def.HttpRequestDef

func GenReqDefForImportTable 

func GenReqDefForImportTable() *def.HttpRequestDef

func GenReqDefForListAllTables 

func GenReqDefForListAllTables() *def.HttpRequestDef

func GenReqDefForListAuthInfo 

func GenReqDefForListAuthInfo() *def.HttpRequestDef

func GenReqDefForListBatches 

func GenReqDefForListBatches() *def.HttpRequestDef

func GenReqDefForListDatabaseUsers 

func GenReqDefForListDatabaseUsers() *def.HttpRequestDef

func GenReqDefForListDatabases 

func GenReqDefForListDatabases() *def.HttpRequestDef

func GenReqDefForListDatasourceConnections 

func GenReqDefForListDatasourceConnections() *def.HttpRequestDef

func GenReqDefForListElasticResourcePoolQueues 

func GenReqDefForListElasticResourcePoolQueues() *def.HttpRequestDef

func GenReqDefForListElasticResourcePoolScaleRecords 

func GenReqDefForListElasticResourcePoolScaleRecords() *def.HttpRequestDef

func GenReqDefForListElasticResourcePools 

func GenReqDefForListElasticResourcePools() *def.HttpRequestDef

func GenReqDefForListEnhancedConnections 

func GenReqDefForListEnhancedConnections() *def.HttpRequestDef

func GenReqDefForListFlinkJobs 

func GenReqDefForListFlinkJobs() *def.HttpRequestDef

func GenReqDefForListFlinkTemplates 

func GenReqDefForListFlinkTemplates() *def.HttpRequestDef

func GenReqDefForListGlobalValues 

func GenReqDefForListGlobalValues() *def.HttpRequestDef

func GenReqDefForListJobTemplates 

func GenReqDefForListJobTemplates() *def.HttpRequestDef

func GenReqDefForListQueuePlans 

func GenReqDefForListQueuePlans() *def.HttpRequestDef

func GenReqDefForListQueueUsers 

func GenReqDefForListQueueUsers() *def.HttpRequestDef

func GenReqDefForListQueues 

func GenReqDefForListQueues() *def.HttpRequestDef

func GenReqDefForListResources 

func GenReqDefForListResources() *def.HttpRequestDef

func GenReqDefForListSqlJobs 

func GenReqDefForListSqlJobs() *def.HttpRequestDef

func GenReqDefForListTablePrivileges 

func GenReqDefForListTablePrivileges() *def.HttpRequestDef

func GenReqDefForListTableUsers 

func GenReqDefForListTableUsers() *def.HttpRequestDef

func GenReqDefForPreviewJobResult 

func GenReqDefForPreviewJobResult() *def.HttpRequestDef

func GenReqDefForRegisterAuthorizedQueue 

func GenReqDefForRegisterAuthorizedQueue() *def.HttpRequestDef

func GenReqDefForRegisterBucket 

func GenReqDefForRegisterBucket() *def.HttpRequestDef

func GenReqDefForRunIefJobActionCallBack 

func GenReqDefForRunIefJobActionCallBack() *def.HttpRequestDef

func GenReqDefForRunQueueAction 

func GenReqDefForRunQueueAction() *def.HttpRequestDef

func GenReqDefForShowBatchInfo 

func GenReqDefForShowBatchInfo() *def.HttpRequestDef

func GenReqDefForShowBatchLog 

func GenReqDefForShowBatchLog() *def.HttpRequestDef

func GenReqDefForShowBatchState 

func GenReqDefForShowBatchState() *def.HttpRequestDef

func GenReqDefForShowDatasourceConnection 

func GenReqDefForShowDatasourceConnection() *def.HttpRequestDef

func GenReqDefForShowDescribeTable 

func GenReqDefForShowDescribeTable() *def.HttpRequestDef

func GenReqDefForShowDliAgency 

func GenReqDefForShowDliAgency() *def.HttpRequestDef

func GenReqDefForShowEnhancedConnection 

func GenReqDefForShowEnhancedConnection() *def.HttpRequestDef

func GenReqDefForShowEnhancedPrivilege 

func GenReqDefForShowEnhancedPrivilege() *def.HttpRequestDef

func GenReqDefForShowFlinkExecuteGraph 

func GenReqDefForShowFlinkExecuteGraph() *def.HttpRequestDef

func GenReqDefForShowFlinkJob 

func GenReqDefForShowFlinkJob() *def.HttpRequestDef

func GenReqDefForShowFlinkMetric 

func GenReqDefForShowFlinkMetric() *def.HttpRequestDef

func GenReqDefForShowJobProgress 

func GenReqDefForShowJobProgress() *def.HttpRequestDef

func GenReqDefForShowJobTemplate 

func GenReqDefForShowJobTemplate() *def.HttpRequestDef

func GenReqDefForShowNodeConnectivity 

func GenReqDefForShowNodeConnectivity() *def.HttpRequestDef

func GenReqDefForShowObjectUser 

func GenReqDefForShowObjectUser() *def.HttpRequestDef

func GenReqDefForShowPartitions 

func GenReqDefForShowPartitions() *def.HttpRequestDef

func GenReqDefForShowQueueDetail 

func GenReqDefForShowQueueDetail() *def.HttpRequestDef

func GenReqDefForShowResourceInfo 

func GenReqDefForShowResourceInfo() *def.HttpRequestDef

func GenReqDefForShowSqlJobDetail 

func GenReqDefForShowSqlJobDetail() *def.HttpRequestDef

func GenReqDefForShowSqlJobStatus 

func GenReqDefForShowSqlJobStatus() *def.HttpRequestDef

func GenReqDefForShowSqlSampleTemplates 

func GenReqDefForShowSqlSampleTemplates() *def.HttpRequestDef

func GenReqDefForShowSqlTemplates 

func GenReqDefForShowSqlTemplates() *def.HttpRequestDef

func GenReqDefForShowTableContent 

func GenReqDefForShowTableContent() *def.HttpRequestDef

func GenReqDefForStopFlinkJobs 

func GenReqDefForStopFlinkJobs() *def.HttpRequestDef

func GenReqDefForUpdateAuthInfo 

func GenReqDefForUpdateAuthInfo() *def.HttpRequestDef

func GenReqDefForUpdateDatabaseOwner 

func GenReqDefForUpdateDatabaseOwner() *def.HttpRequestDef

func GenReqDefForUpdateElasticResourcePool 

func GenReqDefForUpdateElasticResourcePool() *def.HttpRequestDef

func GenReqDefForUpdateElasticResourcePoolQueueInfo 

func GenReqDefForUpdateElasticResourcePoolQueueInfo() *def.HttpRequestDef

func GenReqDefForUpdateFlinkJar 

func GenReqDefForUpdateFlinkJar() *def.HttpRequestDef

func GenReqDefForUpdateFlinkSql 

func GenReqDefForUpdateFlinkSql() *def.HttpRequestDef

func GenReqDefForUpdateFlinkTemplate 

func GenReqDefForUpdateFlinkTemplate() *def.HttpRequestDef

func GenReqDefForUpdateGlobalValue 

func GenReqDefForUpdateGlobalValue() *def.HttpRequestDef

func GenReqDefForUpdateGroupOrResourceOwner 

func GenReqDefForUpdateGroupOrResourceOwner() *def.HttpRequestDef

func GenReqDefForUpdateHostMassage 

func GenReqDefForUpdateHostMassage() *def.HttpRequestDef

func GenReqDefForUpdateJobTemplates 

func GenReqDefForUpdateJobTemplates() *def.HttpRequestDef

func GenReqDefForUpdateQueueCidr 

func GenReqDefForUpdateQueueCidr() *def.HttpRequestDef

func GenReqDefForUpdateSqlTemplates 

func GenReqDefForUpdateSqlTemplates() *def.HttpRequestDef

func GenReqDefForUpdateTableOwner 

func GenReqDefForUpdateTableOwner() *def.HttpRequestDef

func GenReqDefForUploadFiles 

func GenReqDefForUploadFiles() *def.HttpRequestDef

func GenReqDefForUploadJars 

func GenReqDefForUploadJars() *def.HttpRequestDef

func GenReqDefForUploadPythonFiles 

func GenReqDefForUploadPythonFiles() *def.HttpRequestDef

func GenReqDefForUploadResources 

func GenReqDefForUploadResources() *def.HttpRequestDef

Types

type AssociateConnectionQueueInvoker 

type AssociateConnectionQueueInvoker struct {
	*invoker.BaseInvoker
}

func (*AssociateConnectionQueueInvoker) Invoke 

func (i *AssociateConnectionQueueInvoker) Invoke() (*model.AssociateConnectionQueueResponse, error)

type AssociateQueueToElasticResourcePoolInvoker 

type AssociateQueueToElasticResourcePoolInvoker struct {
	*invoker.BaseInvoker
}

func (*AssociateQueueToElasticResourcePoolInvoker) Invoke 

func (i *AssociateQueueToElasticResourcePoolInvoker) Invoke() (*model.AssociateQueueToElasticResourcePoolResponse, error)

type AuthorizeResourceInvoker 

type AuthorizeResourceInvoker struct {
	*invoker.BaseInvoker
}

func (*AuthorizeResourceInvoker) Invoke 

func (i *AuthorizeResourceInvoker) Invoke() (*model.AuthorizeResourceResponse, error)

type BatchDeleteFlinkJobsInvoker 

type BatchDeleteFlinkJobsInvoker struct {
	*invoker.BaseInvoker
}

func (*BatchDeleteFlinkJobsInvoker) Invoke 

func (i *BatchDeleteFlinkJobsInvoker) Invoke() (*model.BatchDeleteFlinkJobsResponse, error)

type BatchDeleteQueuePlansInvoker 

type BatchDeleteQueuePlansInvoker struct {
	*invoker.BaseInvoker
}

func (*BatchDeleteQueuePlansInvoker) Invoke 

func (i *BatchDeleteQueuePlansInvoker) Invoke() (*model.BatchDeleteQueuePlansResponse, error)

type BatchRunFlinkJobsInvoker 

type BatchRunFlinkJobsInvoker struct {
	*invoker.BaseInvoker
}

func (*BatchRunFlinkJobsInvoker) Invoke 

func (i *BatchRunFlinkJobsInvoker) Invoke() (*model.BatchRunFlinkJobsResponse, error)

type CancelBatchJobInvoker 

type CancelBatchJobInvoker struct {
	*invoker.BaseInvoker
}

func (*CancelBatchJobInvoker) Invoke 

func (i *CancelBatchJobInvoker) Invoke() (*model.CancelBatchJobResponse, error)

type CancelSqlJobInvoker 

type CancelSqlJobInvoker struct {
	*invoker.BaseInvoker
}

func (*CancelSqlJobInvoker) Invoke 

func (i *CancelSqlJobInvoker) Invoke() (*model.CancelSqlJobResponse, error)

type ChangeAuthorizationInvoker 

type ChangeAuthorizationInvoker struct {
	*invoker.BaseInvoker
}

func (*ChangeAuthorizationInvoker) Invoke 

func (i *ChangeAuthorizationInvoker) Invoke() (*model.ChangeAuthorizationResponse, error)

type ChangeFlinkJobStatusReportInvoker 

type ChangeFlinkJobStatusReportInvoker struct {
	*invoker.BaseInvoker
}

func (*ChangeFlinkJobStatusReportInvoker) Invoke 

func (i *ChangeFlinkJobStatusReportInvoker) Invoke() (*model.ChangeFlinkJobStatusReportResponse, error)

type ChangeQueuePlanInvoker 

type ChangeQueuePlanInvoker struct {
	*invoker.BaseInvoker
}

func (*ChangeQueuePlanInvoker) Invoke 

func (i *ChangeQueuePlanInvoker) Invoke() (*model.ChangeQueuePlanResponse, error)

type CheckConnectionInvoker 

type CheckConnectionInvoker struct {
	*invoker.BaseInvoker
}

func (*CheckConnectionInvoker) Invoke 

func (i *CheckConnectionInvoker) Invoke() (*model.CheckConnectionResponse, error)

type CheckSqlInvoker 

type CheckSqlInvoker struct {
	*invoker.BaseInvoker
}

func (*CheckSqlInvoker) Invoke 

func (i *CheckSqlInvoker) Invoke() (*model.CheckSqlResponse, error)

type CreateAuthInfoInvoker 

type CreateAuthInfoInvoker struct {
	*invoker.BaseInvoker
}

func (*CreateAuthInfoInvoker) Invoke 

func (i *CreateAuthInfoInvoker) Invoke() (*model.CreateAuthInfoResponse, error)

type CreateBatchJobInvoker 

type CreateBatchJobInvoker struct {
	*invoker.BaseInvoker
}

func (*CreateBatchJobInvoker) Invoke 

func (i *CreateBatchJobInvoker) Invoke() (*model.CreateBatchJobResponse, error)

type CreateDatabaseInvoker 

type CreateDatabaseInvoker struct {
	*invoker.BaseInvoker
}

func (*CreateDatabaseInvoker) Invoke 

func (i *CreateDatabaseInvoker) Invoke() (*model.CreateDatabaseResponse, error)

type CreateDatasourceConnectionInvoker 

type CreateDatasourceConnectionInvoker struct {
	*invoker.BaseInvoker
}

func (*CreateDatasourceConnectionInvoker) Invoke 

func (i *CreateDatasourceConnectionInvoker) Invoke() (*model.CreateDatasourceConnectionResponse, error)

type CreateDliAgencyInvoker 

type CreateDliAgencyInvoker struct {
	*invoker.BaseInvoker
}

func (*CreateDliAgencyInvoker) Invoke 

func (i *CreateDliAgencyInvoker) Invoke() (*model.CreateDliAgencyResponse, error)

type CreateElasticResourcePoolInvoker 

type CreateElasticResourcePoolInvoker struct {
	*invoker.BaseInvoker
}

func (*CreateElasticResourcePoolInvoker) Invoke 

func (i *CreateElasticResourcePoolInvoker) Invoke() (*model.CreateElasticResourcePoolResponse, error)

type CreateEnhancedConnectionInvoker 

type CreateEnhancedConnectionInvoker struct {
	*invoker.BaseInvoker
}

func (*CreateEnhancedConnectionInvoker) Invoke 

func (i *CreateEnhancedConnectionInvoker) Invoke() (*model.CreateEnhancedConnectionResponse, error)

type CreateEnhancedConnectionRoutesInvoker 

type CreateEnhancedConnectionRoutesInvoker struct {
	*invoker.BaseInvoker
}

func (*CreateEnhancedConnectionRoutesInvoker) Invoke 

func (i *CreateEnhancedConnectionRoutesInvoker) Invoke() (*model.CreateEnhancedConnectionRoutesResponse, error)

type CreateFlinkJarInvoker 

type CreateFlinkJarInvoker struct {
	*invoker.BaseInvoker
}

func (*CreateFlinkJarInvoker) Invoke 

func (i *CreateFlinkJarInvoker) Invoke() (*model.CreateFlinkJarResponse, error)

type CreateFlinkSqlJobInvoker 

type CreateFlinkSqlJobInvoker struct {
	*invoker.BaseInvoker
}

func (*CreateFlinkSqlJobInvoker) Invoke 

func (i *CreateFlinkSqlJobInvoker) Invoke() (*model.CreateFlinkSqlJobResponse, error)

type CreateFlinkTemplateInvoker 

type CreateFlinkTemplateInvoker struct {
	*invoker.BaseInvoker
}

func (*CreateFlinkTemplateInvoker) Invoke 

func (i *CreateFlinkTemplateInvoker) Invoke() (*model.CreateFlinkTemplateResponse, error)

type CreateGlobalValueInvoker 

type CreateGlobalValueInvoker struct {
	*invoker.BaseInvoker
}

func (*CreateGlobalValueInvoker) Invoke 

func (i *CreateGlobalValueInvoker) Invoke() (*model.CreateGlobalValueResponse, error)

type CreateIefMessageChannelInvoker 

type CreateIefMessageChannelInvoker struct {
	*invoker.BaseInvoker
}

func (*CreateIefMessageChannelInvoker) Invoke 

func (i *CreateIefMessageChannelInvoker) Invoke() (*model.CreateIefMessageChannelResponse, error)

type CreateIefSystemEventsInvoker 

type CreateIefSystemEventsInvoker struct {
	*invoker.BaseInvoker
}

func (*CreateIefSystemEventsInvoker) Invoke 

func (i *CreateIefSystemEventsInvoker) Invoke() (*model.CreateIefSystemEventsResponse, error)

type CreateJobTemplatesInvoker 

type CreateJobTemplatesInvoker struct {
	*invoker.BaseInvoker
}

func (*CreateJobTemplatesInvoker) Invoke 

func (i *CreateJobTemplatesInvoker) Invoke() (*model.CreateJobTemplatesResponse, error)

type CreateQueueInvoker 

type CreateQueueInvoker struct {
	*invoker.BaseInvoker
}

func (*CreateQueueInvoker) Invoke 

func (i *CreateQueueInvoker) Invoke() (*model.CreateQueueResponse, error)

type CreateQueuePlanInvoker 

type CreateQueuePlanInvoker struct {
	*invoker.BaseInvoker
}

func (*CreateQueuePlanInvoker) Invoke 

func (i *CreateQueuePlanInvoker) Invoke() (*model.CreateQueuePlanResponse, error)

type CreateSqlJobInvoker 

type CreateSqlJobInvoker struct {
	*invoker.BaseInvoker
}

func (*CreateSqlJobInvoker) Invoke 

func (i *CreateSqlJobInvoker) Invoke() (*model.CreateSqlJobResponse, error)

type CreateSqlTemplatesInvoker 

type CreateSqlTemplatesInvoker struct {
	*invoker.BaseInvoker
}

func (*CreateSqlTemplatesInvoker) Invoke 

func (i *CreateSqlTemplatesInvoker) Invoke() (*model.CreateSqlTemplatesResponse, error)

type CreateStreamGraphInvoker 

type CreateStreamGraphInvoker struct {
	*invoker.BaseInvoker
}

func (*CreateStreamGraphInvoker) Invoke 

func (i *CreateStreamGraphInvoker) Invoke() (*model.CreateStreamGraphResponse, error)

type CreateTableInvoker 

type CreateTableInvoker struct {
	*invoker.BaseInvoker
}

func (*CreateTableInvoker) Invoke 

func (i *CreateTableInvoker) Invoke() (*model.CreateTableResponse, error)

type DeleteAuthInfoInvoker 

type DeleteAuthInfoInvoker struct {
	*invoker.BaseInvoker
}

func (*DeleteAuthInfoInvoker) Invoke 

func (i *DeleteAuthInfoInvoker) Invoke() (*model.DeleteAuthInfoResponse, error)

type DeleteDatabaseInvoker 

type DeleteDatabaseInvoker struct {
	*invoker.BaseInvoker
}

func (*DeleteDatabaseInvoker) Invoke 

func (i *DeleteDatabaseInvoker) Invoke() (*model.DeleteDatabaseResponse, error)

type DeleteDatasourceConnectionInvoker 

type DeleteDatasourceConnectionInvoker struct {
	*invoker.BaseInvoker
}

func (*DeleteDatasourceConnectionInvoker) Invoke 

func (i *DeleteDatasourceConnectionInvoker) Invoke() (*model.DeleteDatasourceConnectionResponse, error)

type DeleteElasticResourcePoolInvoker 

type DeleteElasticResourcePoolInvoker struct {
	*invoker.BaseInvoker
}

func (*DeleteElasticResourcePoolInvoker) Invoke 

func (i *DeleteElasticResourcePoolInvoker) Invoke() (*model.DeleteElasticResourcePoolResponse, error)

type DeleteEnhancedConnectionInvoker 

type DeleteEnhancedConnectionInvoker struct {
	*invoker.BaseInvoker
}

func (*DeleteEnhancedConnectionInvoker) Invoke 

func (i *DeleteEnhancedConnectionInvoker) Invoke() (*model.DeleteEnhancedConnectionResponse, error)

type DeleteEnhancedConnectionRoutesInvoker 

type DeleteEnhancedConnectionRoutesInvoker struct {
	*invoker.BaseInvoker
}

func (*DeleteEnhancedConnectionRoutesInvoker) Invoke 

func (i *DeleteEnhancedConnectionRoutesInvoker) Invoke() (*model.DeleteEnhancedConnectionRoutesResponse, error)

type DeleteFlinkJobInvoker 

type DeleteFlinkJobInvoker struct {
	*invoker.BaseInvoker
}

func (*DeleteFlinkJobInvoker) Invoke 

func (i *DeleteFlinkJobInvoker) Invoke() (*model.DeleteFlinkJobResponse, error)

type DeleteFlinkTemplateInvoker 

type DeleteFlinkTemplateInvoker struct {
	*invoker.BaseInvoker
}

func (*DeleteFlinkTemplateInvoker) Invoke 

func (i *DeleteFlinkTemplateInvoker) Invoke() (*model.DeleteFlinkTemplateResponse, error)

type DeleteGlobalValueInvoker 

type DeleteGlobalValueInvoker struct {
	*invoker.BaseInvoker
}

func (*DeleteGlobalValueInvoker) Invoke 

func (i *DeleteGlobalValueInvoker) Invoke() (*model.DeleteGlobalValueResponse, error)

type DeleteQueueInvoker 

type DeleteQueueInvoker struct {
	*invoker.BaseInvoker
}

func (*DeleteQueueInvoker) Invoke 

func (i *DeleteQueueInvoker) Invoke() (*model.DeleteQueueResponse, error)

type DeleteQueuePlanInvoker 

type DeleteQueuePlanInvoker struct {
	*invoker.BaseInvoker
}

func (*DeleteQueuePlanInvoker) Invoke 

func (i *DeleteQueuePlanInvoker) Invoke() (*model.DeleteQueuePlanResponse, error)

type DeleteResourceInvoker 

type DeleteResourceInvoker struct {
	*invoker.BaseInvoker
}

func (*DeleteResourceInvoker) Invoke 

func (i *DeleteResourceInvoker) Invoke() (*model.DeleteResourceResponse, error)

type DeleteSqlTemplatesInvoker 

type DeleteSqlTemplatesInvoker struct {
	*invoker.BaseInvoker
}

func (*DeleteSqlTemplatesInvoker) Invoke 

func (i *DeleteSqlTemplatesInvoker) Invoke() (*model.DeleteSqlTemplatesResponse, error)

type DeleteTableInvoker 

type DeleteTableInvoker struct {
	*invoker.BaseInvoker
}

func (*DeleteTableInvoker) Invoke 

func (i *DeleteTableInvoker) Invoke() (*model.DeleteTableResponse, error)

type DisassociateConnectionQueueInvoker 

type DisassociateConnectionQueueInvoker struct {
	*invoker.BaseInvoker
}

func (*DisassociateConnectionQueueInvoker) Invoke 

func (i *DisassociateConnectionQueueInvoker) Invoke() (*model.DisassociateConnectionQueueResponse, error)

type DliClient 

type DliClient struct {
	HcClient *http_client.HcHttpClient
}

func NewDliClient 

func NewDliClient(hcClient *http_client.HcHttpClient) *DliClient

func (*DliClient) AssociateConnectionQueue 

func (c *DliClient) AssociateConnectionQueue(request *model.AssociateConnectionQueueRequest) (*model.AssociateConnectionQueueResponse, error)

AssociateConnectionQueue 绑定队列

该API用于在已创建的增强型跨源中绑定队列。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) AssociateConnectionQueueInvoker 

func (c *DliClient) AssociateConnectionQueueInvoker(request *model.AssociateConnectionQueueRequest) *AssociateConnectionQueueInvoker

AssociateConnectionQueueInvoker 绑定队列

func (*DliClient) AssociateQueueToElasticResourcePool 

func (c *DliClient) AssociateQueueToElasticResourcePool(request *model.AssociateQueueToElasticResourcePoolRequest) (*model.AssociateQueueToElasticResourcePoolResponse, error)

AssociateQueueToElasticResourcePool 关联队列到弹性资源池

关联队列到弹性资源池

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) AssociateQueueToElasticResourcePoolInvoker 

func (c *DliClient) AssociateQueueToElasticResourcePoolInvoker(request *model.AssociateQueueToElasticResourcePoolRequest) *AssociateQueueToElasticResourcePoolInvoker

AssociateQueueToElasticResourcePoolInvoker 关联队列到弹性资源池

func (*DliClient) AuthorizeResource 

func (c *DliClient) AuthorizeResource(request *model.AuthorizeResourceRequest) (*model.AuthorizeResourceResponse, error)

AuthorizeResource 数据赋权（用户、项目）

该API用于将DLI资源权限赋给、回收、更新指定的其他用户或项目。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) AuthorizeResourceInvoker 

func (c *DliClient) AuthorizeResourceInvoker(request *model.AuthorizeResourceRequest) *AuthorizeResourceInvoker

AuthorizeResourceInvoker 数据赋权（用户、项目）

func (*DliClient) BatchDeleteFlinkJobs 

func (c *DliClient) BatchDeleteFlinkJobs(request *model.BatchDeleteFlinkJobsRequest) (*model.BatchDeleteFlinkJobsResponse, error)

BatchDeleteFlinkJobs 批量删除Flink作业

批量删除任何状态的作业。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) BatchDeleteFlinkJobsInvoker 

func (c *DliClient) BatchDeleteFlinkJobsInvoker(request *model.BatchDeleteFlinkJobsRequest) *BatchDeleteFlinkJobsInvoker

BatchDeleteFlinkJobsInvoker 批量删除Flink作业

func (*DliClient) BatchDeleteQueuePlans 

func (c *DliClient) BatchDeleteQueuePlans(request *model.BatchDeleteQueuePlansRequest) (*model.BatchDeleteQueuePlansResponse, error)

BatchDeleteQueuePlans 批量删除队列定时扩缩容计划

该API用于批量删除队列定时扩缩容计划。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) BatchDeleteQueuePlansInvoker 

func (c *DliClient) BatchDeleteQueuePlansInvoker(request *model.BatchDeleteQueuePlansRequest) *BatchDeleteQueuePlansInvoker

BatchDeleteQueuePlansInvoker 批量删除队列定时扩缩容计划

func (*DliClient) BatchRunFlinkJobs 

func (c *DliClient) BatchRunFlinkJobs(request *model.BatchRunFlinkJobsRequest) (*model.BatchRunFlinkJobsResponse, error)

BatchRunFlinkJobs 批量运行Flink作业

触发批量运行Flink作业。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) BatchRunFlinkJobsInvoker 

func (c *DliClient) BatchRunFlinkJobsInvoker(request *model.BatchRunFlinkJobsRequest) *BatchRunFlinkJobsInvoker

BatchRunFlinkJobsInvoker 批量运行Flink作业

func (*DliClient) CancelBatchJob 

func (c *DliClient) CancelBatchJob(request *model.CancelBatchJobRequest) (*model.CancelBatchJobResponse, error)

CancelBatchJob 取消批处理作业

该API用于取消批处理作业。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) CancelBatchJobInvoker 

func (c *DliClient) CancelBatchJobInvoker(request *model.CancelBatchJobRequest) *CancelBatchJobInvoker

CancelBatchJobInvoker 取消批处理作业

func (*DliClient) CancelSqlJob 

func (c *DliClient) CancelSqlJob(request *model.CancelSqlJobRequest) (*model.CancelSqlJobResponse, error)

CancelSqlJob 取消作业

该API用于取消已经提交的作业，若作业已经执行结束或失败则无法取消。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) CancelSqlJobInvoker 

func (c *DliClient) CancelSqlJobInvoker(request *model.CancelSqlJobRequest) *CancelSqlJobInvoker

CancelSqlJobInvoker 取消作业

func (*DliClient) ChangeAuthorization 

func (c *DliClient) ChangeAuthorization(request *model.ChangeAuthorizationRequest) (*model.ChangeAuthorizationResponse, error)

ChangeAuthorization 数据赋权（用户）

该API用于将数据库或数据表的数据权限赋给指定的其他用户。 说明： 被赋权用户所在用户组的所属区域需具有Tenant Guest权限。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) ChangeAuthorizationInvoker 

func (c *DliClient) ChangeAuthorizationInvoker(request *model.ChangeAuthorizationRequest) *ChangeAuthorizationInvoker

ChangeAuthorizationInvoker 数据赋权（用户）

func (*DliClient) ChangeFlinkJobStatusReport 

func (c *DliClient) ChangeFlinkJobStatusReport(request *model.ChangeFlinkJobStatusReportRequest) (*model.ChangeFlinkJobStatusReportResponse, error)

ChangeFlinkJobStatusReport 边缘Flink作业状态信息上报

该API用于处理边缘Flink作业状态上报信息

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) ChangeFlinkJobStatusReportInvoker 

func (c *DliClient) ChangeFlinkJobStatusReportInvoker(request *model.ChangeFlinkJobStatusReportRequest) *ChangeFlinkJobStatusReportInvoker

ChangeFlinkJobStatusReportInvoker 边缘Flink作业状态信息上报

func (*DliClient) ChangeQueuePlan 

func (c *DliClient) ChangeQueuePlan(request *model.ChangeQueuePlanRequest) (*model.ChangeQueuePlanResponse, error)

ChangeQueuePlan 修改队列定时扩缩容计划

该API用于修改指定ID的队列定时扩缩容计划。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) ChangeQueuePlanInvoker 

func (c *DliClient) ChangeQueuePlanInvoker(request *model.ChangeQueuePlanRequest) *ChangeQueuePlanInvoker

ChangeQueuePlanInvoker 修改队列定时扩缩容计划

func (*DliClient) CheckConnection 

func (c *DliClient) CheckConnection(request *model.CheckConnectionRequest) (*model.CheckConnectionResponse, error)

CheckConnection 创建地址连通性请求

创建地址连通性请求API接口，往指定集群发送地址连通性测试请求，并将测试地址插入表内

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) CheckConnectionInvoker 

func (c *DliClient) CheckConnectionInvoker(request *model.CheckConnectionRequest) *CheckConnectionInvoker

CheckConnectionInvoker 创建地址连通性请求

func (*DliClient) CheckSql 

func (c *DliClient) CheckSql(request *model.CheckSqlRequest) (*model.CheckSqlResponse, error)

CheckSql 检查SQL语法

该API用于检查SQL语法。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) CheckSqlInvoker 

func (c *DliClient) CheckSqlInvoker(request *model.CheckSqlRequest) *CheckSqlInvoker

CheckSqlInvoker 检查SQL语法

func (*DliClient) CreateAuthInfo 

func (c *DliClient) CreateAuthInfo(request *model.CreateAuthInfoRequest) (*model.CreateAuthInfoResponse, error)

CreateAuthInfo 创建跨源认证

该API用于创建跨源认证。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) CreateAuthInfoInvoker 

func (c *DliClient) CreateAuthInfoInvoker(request *model.CreateAuthInfoRequest) *CreateAuthInfoInvoker

CreateAuthInfoInvoker 创建跨源认证

func (*DliClient) CreateBatchJob 

func (c *DliClient) CreateBatchJob(request *model.CreateBatchJobRequest) (*model.CreateBatchJobResponse, error)

CreateBatchJob 创建批处理作业

该API用于在某个队列上创建作业。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) CreateBatchJobInvoker 

func (c *DliClient) CreateBatchJobInvoker(request *model.CreateBatchJobRequest) *CreateBatchJobInvoker

CreateBatchJobInvoker 创建批处理作业

func (*DliClient) CreateDatabase 

func (c *DliClient) CreateDatabase(request *model.CreateDatabaseRequest) (*model.CreateDatabaseResponse, error)

CreateDatabase 创建数据库

该API用于新增数据库。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) CreateDatabaseInvoker 

func (c *DliClient) CreateDatabaseInvoker(request *model.CreateDatabaseRequest) *CreateDatabaseInvoker

CreateDatabaseInvoker 创建数据库

func (*DliClient) CreateDatasourceConnection 

func (c *DliClient) CreateDatasourceConnection(request *model.CreateDatasourceConnectionRequest) (*model.CreateDatasourceConnectionResponse, error)

CreateDatasourceConnection 创建经典型跨源连接

该API用于创建与其他服务的经典型跨源连接。 说明： 如果需要了解Console界面的使用方法，可参考经典型跨源连接。 系统default队列不支持创建跨源连接。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) CreateDatasourceConnectionInvoker 

func (c *DliClient) CreateDatasourceConnectionInvoker(request *model.CreateDatasourceConnectionRequest) *CreateDatasourceConnectionInvoker

CreateDatasourceConnectionInvoker 创建经典型跨源连接

func (*DliClient) CreateDliAgency 

func (c *DliClient) CreateDliAgency(request *model.CreateDliAgencyRequest) (*model.CreateDliAgencyResponse, error)

CreateDliAgency 创建DLI委托

创建DLI委托

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) CreateDliAgencyInvoker 

func (c *DliClient) CreateDliAgencyInvoker(request *model.CreateDliAgencyRequest) *CreateDliAgencyInvoker

CreateDliAgencyInvoker 创建DLI委托

func (*DliClient) CreateElasticResourcePool 

func (c *DliClient) CreateElasticResourcePool(request *model.CreateElasticResourcePoolRequest) (*model.CreateElasticResourcePoolResponse, error)

CreateElasticResourcePool 创建弹性资源池

创建弹性资源池

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) CreateElasticResourcePoolInvoker 

func (c *DliClient) CreateElasticResourcePoolInvoker(request *model.CreateElasticResourcePoolRequest) *CreateElasticResourcePoolInvoker

CreateElasticResourcePoolInvoker 创建弹性资源池

func (*DliClient) CreateEnhancedConnection 

func (c *DliClient) CreateEnhancedConnection(request *model.CreateEnhancedConnectionRequest) (*model.CreateEnhancedConnectionResponse, error)

CreateEnhancedConnection 创建增强型跨源连接

该API用于创建与其他服务的增强型跨源连接。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) CreateEnhancedConnectionInvoker 

func (c *DliClient) CreateEnhancedConnectionInvoker(request *model.CreateEnhancedConnectionRequest) *CreateEnhancedConnectionInvoker

CreateEnhancedConnectionInvoker 创建增强型跨源连接

func (*DliClient) CreateEnhancedConnectionRoutes 

func (c *DliClient) CreateEnhancedConnectionRoutes(request *model.CreateEnhancedConnectionRoutesRequest) (*model.CreateEnhancedConnectionRoutesResponse, error)

CreateEnhancedConnectionRoutes 创建路由

该API用于创建跨源需要的路由。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) CreateEnhancedConnectionRoutesInvoker 

func (c *DliClient) CreateEnhancedConnectionRoutesInvoker(request *model.CreateEnhancedConnectionRoutesRequest) *CreateEnhancedConnectionRoutesInvoker

CreateEnhancedConnectionRoutesInvoker 创建路由

func (*DliClient) CreateFlinkJar 

func (c *DliClient) CreateFlinkJar(request *model.CreateFlinkJarRequest) (*model.CreateFlinkJarResponse, error)

CreateFlinkJar 新建Flink Jar作业

用户自定义作业目前支持jar格式，运行在独享集群中。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) CreateFlinkJarInvoker 

func (c *DliClient) CreateFlinkJarInvoker(request *model.CreateFlinkJarRequest) *CreateFlinkJarInvoker

CreateFlinkJarInvoker 新建Flink Jar作业

func (*DliClient) CreateFlinkSqlJob 

func (c *DliClient) CreateFlinkSqlJob(request *model.CreateFlinkSqlJobRequest) (*model.CreateFlinkSqlJobResponse, error)

CreateFlinkSqlJob 新建Flink SQL作业

通过POST方式，提交流式SQL作业，请求体为JSON格式。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) CreateFlinkSqlJobInvoker 

func (c *DliClient) CreateFlinkSqlJobInvoker(request *model.CreateFlinkSqlJobRequest) *CreateFlinkSqlJobInvoker

CreateFlinkSqlJobInvoker 新建Flink SQL作业

func (*DliClient) CreateFlinkTemplate 

func (c *DliClient) CreateFlinkTemplate(request *model.CreateFlinkTemplateRequest) (*model.CreateFlinkTemplateResponse, error)

CreateFlinkTemplate 新建Flink作业模板

在DLI服务中新建一个Flink作业模板，最多100个。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) CreateFlinkTemplateInvoker 

func (c *DliClient) CreateFlinkTemplateInvoker(request *model.CreateFlinkTemplateRequest) *CreateFlinkTemplateInvoker

CreateFlinkTemplateInvoker 新建Flink作业模板

func (*DliClient) CreateGlobalValue 

func (c *DliClient) CreateGlobalValue(request *model.CreateGlobalValueRequest) (*model.CreateGlobalValueResponse, error)

CreateGlobalValue 创建DLI全局变量

创建全局变量。全局变量用于替换SQL作业中的敏感数据。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) CreateGlobalValueInvoker 

func (c *DliClient) CreateGlobalValueInvoker(request *model.CreateGlobalValueRequest) *CreateGlobalValueInvoker

CreateGlobalValueInvoker 创建DLI全局变量

func (*DliClient) CreateIefMessageChannel 

func (c *DliClient) CreateIefMessageChannel(request *model.CreateIefMessageChannelRequest) (*model.CreateIefMessageChannelResponse, error)

CreateIefMessageChannel 创建IEF消息通道

该API用于创建IEF消息通道

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) CreateIefMessageChannelInvoker 

func (c *DliClient) CreateIefMessageChannelInvoker(request *model.CreateIefMessageChannelRequest) *CreateIefMessageChannelInvoker

CreateIefMessageChannelInvoker 创建IEF消息通道

func (*DliClient) CreateIefSystemEvents 

func (c *DliClient) CreateIefSystemEvents(request *model.CreateIefSystemEventsRequest) (*model.CreateIefSystemEventsResponse, error)

CreateIefSystemEvents IEF系统事件上报

该API用于处理IEF系统事件上报

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) CreateIefSystemEventsInvoker 

func (c *DliClient) CreateIefSystemEventsInvoker(request *model.CreateIefSystemEventsRequest) *CreateIefSystemEventsInvoker

CreateIefSystemEventsInvoker IEF系统事件上报

func (*DliClient) CreateJobTemplates 

func (c *DliClient) CreateJobTemplates(request *model.CreateJobTemplatesRequest) (*model.CreateJobTemplatesResponse, error)

CreateJobTemplates 创建作业模板

该API用于创建作业模板。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) CreateJobTemplatesInvoker 

func (c *DliClient) CreateJobTemplatesInvoker(request *model.CreateJobTemplatesRequest) *CreateJobTemplatesInvoker

CreateJobTemplatesInvoker 创建作业模板

func (*DliClient) CreateQueue 

func (c *DliClient) CreateQueue(request *model.CreateQueueRequest) (*model.CreateQueueResponse, error)

CreateQueue 创建队列

该API用于创建队列，该队列将会绑定用户指定的计算资源。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) CreateQueueInvoker 

func (c *DliClient) CreateQueueInvoker(request *model.CreateQueueRequest) *CreateQueueInvoker

CreateQueueInvoker 创建队列

func (*DliClient) CreateQueuePlan 

func (c *DliClient) CreateQueuePlan(request *model.CreateQueuePlanRequest) (*model.CreateQueuePlanResponse, error)

CreateQueuePlan 创建队列定时扩缩容计划

创建队列定时扩缩容计划接口，对指定的队列创建定时规格变更计划。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) CreateQueuePlanInvoker 

func (c *DliClient) CreateQueuePlanInvoker(request *model.CreateQueuePlanRequest) *CreateQueuePlanInvoker

CreateQueuePlanInvoker 创建队列定时扩缩容计划

func (*DliClient) CreateSqlJob 

func (c *DliClient) CreateSqlJob(request *model.CreateSqlJobRequest) (*model.CreateSqlJobResponse, error)

CreateSqlJob 提交SQL作业

该API用于通过执行SQL语句的方式向队列提交作业。

作业包含以下类型：DDL、DCL、IMPORT、QUERY和INSERT。其中，IMPORT与导入数据的功能一致，区别仅在于实现方式不同。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) CreateSqlJobInvoker 

func (c *DliClient) CreateSqlJobInvoker(request *model.CreateSqlJobRequest) *CreateSqlJobInvoker

CreateSqlJobInvoker 提交SQL作业

func (*DliClient) CreateSqlTemplates 

func (c *DliClient) CreateSqlTemplates(request *model.CreateSqlTemplatesRequest) (*model.CreateSqlTemplatesResponse, error)

CreateSqlTemplates 存储指定SQL语句

该API用于存储指定的SQL语句，后续可以重复使用。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) CreateSqlTemplatesInvoker 

func (c *DliClient) CreateSqlTemplatesInvoker(request *model.CreateSqlTemplatesRequest) *CreateSqlTemplatesInvoker

CreateSqlTemplatesInvoker 存储指定SQL语句

func (*DliClient) CreateStreamGraph 

func (c *DliClient) CreateStreamGraph(request *model.CreateStreamGraphRequest) (*model.CreateStreamGraphResponse, error)

CreateStreamGraph 生成flink SQL作业的静态流图

生成flink SQL作业的静态流图

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) CreateStreamGraphInvoker 

func (c *DliClient) CreateStreamGraphInvoker(request *model.CreateStreamGraphRequest) *CreateStreamGraphInvoker

CreateStreamGraphInvoker 生成flink SQL作业的静态流图

func (*DliClient) CreateTable 

func (c *DliClient) CreateTable(request *model.CreateTableRequest) (*model.CreateTableResponse, error)

CreateTable 创建表

该API用于创建新的表。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) CreateTableInvoker 

func (c *DliClient) CreateTableInvoker(request *model.CreateTableRequest) *CreateTableInvoker

CreateTableInvoker 创建表

func (*DliClient) DeleteAuthInfo 

func (c *DliClient) DeleteAuthInfo(request *model.DeleteAuthInfoRequest) (*model.DeleteAuthInfoResponse, error)

DeleteAuthInfo 删除跨源认证

该API用于删除跨源认证信息。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) DeleteAuthInfoInvoker 

func (c *DliClient) DeleteAuthInfoInvoker(request *model.DeleteAuthInfoRequest) *DeleteAuthInfoInvoker

DeleteAuthInfoInvoker 删除跨源认证

func (*DliClient) DeleteDatabase 

func (c *DliClient) DeleteDatabase(request *model.DeleteDatabaseRequest) (*model.DeleteDatabaseResponse, error)

DeleteDatabase 删除数据库

该API用于删除空数据库，若待删除的数据库中存在表，则需先删除其中的所有表。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) DeleteDatabaseInvoker 

func (c *DliClient) DeleteDatabaseInvoker(request *model.DeleteDatabaseRequest) *DeleteDatabaseInvoker

DeleteDatabaseInvoker 删除数据库

func (*DliClient) DeleteDatasourceConnection 

func (c *DliClient) DeleteDatasourceConnection(request *model.DeleteDatasourceConnectionRequest) (*model.DeleteDatasourceConnectionResponse, error)

DeleteDatasourceConnection 删除经典型跨源连接

该API用于删除已创建的经典型跨源连接。 说明： 创建中的连接，无法删除。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) DeleteDatasourceConnectionInvoker 

func (c *DliClient) DeleteDatasourceConnectionInvoker(request *model.DeleteDatasourceConnectionRequest) *DeleteDatasourceConnectionInvoker

DeleteDatasourceConnectionInvoker 删除经典型跨源连接

func (*DliClient) DeleteElasticResourcePool 

func (c *DliClient) DeleteElasticResourcePool(request *model.DeleteElasticResourcePoolRequest) (*model.DeleteElasticResourcePoolResponse, error)

DeleteElasticResourcePool 删除弹性资源池

删除弹性资源池

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) DeleteElasticResourcePoolInvoker 

func (c *DliClient) DeleteElasticResourcePoolInvoker(request *model.DeleteElasticResourcePoolRequest) *DeleteElasticResourcePoolInvoker

DeleteElasticResourcePoolInvoker 删除弹性资源池

func (*DliClient) DeleteEnhancedConnection 

func (c *DliClient) DeleteEnhancedConnection(request *model.DeleteEnhancedConnectionRequest) (*model.DeleteEnhancedConnectionResponse, error)

DeleteEnhancedConnection 删除增强型跨源连接

该API用于删除已创建的增强型跨源连接。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) DeleteEnhancedConnectionInvoker 

func (c *DliClient) DeleteEnhancedConnectionInvoker(request *model.DeleteEnhancedConnectionRequest) *DeleteEnhancedConnectionInvoker

DeleteEnhancedConnectionInvoker 删除增强型跨源连接

func (*DliClient) DeleteEnhancedConnectionRoutes 

func (c *DliClient) DeleteEnhancedConnectionRoutes(request *model.DeleteEnhancedConnectionRoutesRequest) (*model.DeleteEnhancedConnectionRoutesResponse, error)

DeleteEnhancedConnectionRoutes 删除路由

该API用于删除跨源需要的路由。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) DeleteEnhancedConnectionRoutesInvoker 

func (c *DliClient) DeleteEnhancedConnectionRoutesInvoker(request *model.DeleteEnhancedConnectionRoutesRequest) *DeleteEnhancedConnectionRoutesInvoker

DeleteEnhancedConnectionRoutesInvoker 删除路由

func (*DliClient) DeleteFlinkJob 

func (c *DliClient) DeleteFlinkJob(request *model.DeleteFlinkJobRequest) (*model.DeleteFlinkJobResponse, error)

DeleteFlinkJob 删除作业

删除任何状态的作业。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) DeleteFlinkJobInvoker 

func (c *DliClient) DeleteFlinkJobInvoker(request *model.DeleteFlinkJobRequest) *DeleteFlinkJobInvoker

DeleteFlinkJobInvoker 删除作业

func (*DliClient) DeleteFlinkTemplate 

func (c *DliClient) DeleteFlinkTemplate(request *model.DeleteFlinkTemplateRequest) (*model.DeleteFlinkTemplateResponse, error)

DeleteFlinkTemplate 删除Flink作业模板

删除一个Flink作业模板，即使当前模板正在被作业使用，也允许删除。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) DeleteFlinkTemplateInvoker 

func (c *DliClient) DeleteFlinkTemplateInvoker(request *model.DeleteFlinkTemplateRequest) *DeleteFlinkTemplateInvoker

DeleteFlinkTemplateInvoker 删除Flink作业模板

func (*DliClient) DeleteGlobalValue 

func (c *DliClient) DeleteGlobalValue(request *model.DeleteGlobalValueRequest) (*model.DeleteGlobalValueResponse, error)

DeleteGlobalValue 删除DLI全局变量

删除全局变量。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) DeleteGlobalValueInvoker 

func (c *DliClient) DeleteGlobalValueInvoker(request *model.DeleteGlobalValueRequest) *DeleteGlobalValueInvoker

DeleteGlobalValueInvoker 删除DLI全局变量

func (*DliClient) DeleteQueue 

func (c *DliClient) DeleteQueue(request *model.DeleteQueueRequest) (*model.DeleteQueueResponse, error)

DeleteQueue 删除队列

该API用于删除指定队列。 说明： 若指定队列正在执行任务，则不允许删除。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) DeleteQueueInvoker 

func (c *DliClient) DeleteQueueInvoker(request *model.DeleteQueueRequest) *DeleteQueueInvoker

DeleteQueueInvoker 删除队列

func (*DliClient) DeleteQueuePlan 

func (c *DliClient) DeleteQueuePlan(request *model.DeleteQueuePlanRequest) (*model.DeleteQueuePlanResponse, error)

DeleteQueuePlan 单个删除队列定时扩缩容计划

该API用于删除指定ID的队列定时扩缩容计划。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) DeleteQueuePlanInvoker 

func (c *DliClient) DeleteQueuePlanInvoker(request *model.DeleteQueuePlanRequest) *DeleteQueuePlanInvoker

DeleteQueuePlanInvoker 单个删除队列定时扩缩容计划

func (*DliClient) DeleteResource 

func (c *DliClient) DeleteResource(request *model.DeleteResourceRequest) (*model.DeleteResourceResponse, error)

DeleteResource 删除组内资源包

该API用于删除某个project某个分组下的资源包

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) DeleteResourceInvoker 

func (c *DliClient) DeleteResourceInvoker(request *model.DeleteResourceRequest) *DeleteResourceInvoker

DeleteResourceInvoker 删除组内资源包

func (*DliClient) DeleteSqlTemplates 

func (c *DliClient) DeleteSqlTemplates(request *model.DeleteSqlTemplatesRequest) (*model.DeleteSqlTemplatesResponse, error)

DeleteSqlTemplates 批量删除SQL模板

该API用于批量删除SQL模板。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) DeleteSqlTemplatesInvoker 

func (c *DliClient) DeleteSqlTemplatesInvoker(request *model.DeleteSqlTemplatesRequest) *DeleteSqlTemplatesInvoker

DeleteSqlTemplatesInvoker 批量删除SQL模板

func (*DliClient) DeleteTable 

func (c *DliClient) DeleteTable(request *model.DeleteTableRequest) (*model.DeleteTableResponse, error)

DeleteTable 删除表

该API用于删除指定的表。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) DeleteTableInvoker 

func (c *DliClient) DeleteTableInvoker(request *model.DeleteTableRequest) *DeleteTableInvoker

DeleteTableInvoker 删除表

func (*DliClient) DisassociateConnectionQueue 

func (c *DliClient) DisassociateConnectionQueue(request *model.DisassociateConnectionQueueRequest) (*model.DisassociateConnectionQueueResponse, error)

DisassociateConnectionQueue 解绑队列

该API用于在增强型跨源中解绑已绑定的队列。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) DisassociateConnectionQueueInvoker 

func (c *DliClient) DisassociateConnectionQueueInvoker(request *model.DisassociateConnectionQueueRequest) *DisassociateConnectionQueueInvoker

DisassociateConnectionQueueInvoker 解绑队列

func (*DliClient) ExportFlinkJob 

func (c *DliClient) ExportFlinkJob(request *model.ExportFlinkJobRequest) (*model.ExportFlinkJobResponse, error)

ExportFlinkJob flink作业导出

通过POST方式，导出flink作业，请求体为JSON格式。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) ExportFlinkJobInvoker 

func (c *DliClient) ExportFlinkJobInvoker(request *model.ExportFlinkJobRequest) *ExportFlinkJobInvoker

ExportFlinkJobInvoker flink作业导出

func (*DliClient) ExportSqlJobResult 

func (c *DliClient) ExportSqlJobResult(request *model.ExportSqlJobResultRequest) (*model.ExportSqlJobResultResponse, error)

ExportSqlJobResult 导出查询结果

该API用于将SQL语句的查询结果导出到OBS对象存储中，只支持导出“QUERY”类型作业的查询结果。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) ExportSqlJobResultInvoker 

func (c *DliClient) ExportSqlJobResultInvoker(request *model.ExportSqlJobResultRequest) *ExportSqlJobResultInvoker

ExportSqlJobResultInvoker 导出查询结果

func (*DliClient) ExportTable 

func (c *DliClient) ExportTable(request *model.ExportTableRequest) (*model.ExportTableResponse, error)

ExportTable 导出查询结果

该API用于将SQL语句的查询结果导出到OBS对象存储中，只支持导出“QUERY”类型作业的查询结果。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) ExportTableInvoker 

func (c *DliClient) ExportTableInvoker(request *model.ExportTableRequest) *ExportTableInvoker

ExportTableInvoker 导出查询结果

func (*DliClient) ImportFlinkJob 

func (c *DliClient) ImportFlinkJob(request *model.ImportFlinkJobRequest) (*model.ImportFlinkJobResponse, error)

ImportFlinkJob flink作业导入

通过POST方式，导入flink作业，请求体为JSON格式。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) ImportFlinkJobInvoker 

func (c *DliClient) ImportFlinkJobInvoker(request *model.ImportFlinkJobRequest) *ImportFlinkJobInvoker

ImportFlinkJobInvoker flink作业导入

func (*DliClient) ImportTable 

func (c *DliClient) ImportTable(request *model.ImportTableRequest) (*model.ImportTableResponse, error)

ImportTable 导入数据

该API用于将数据从文件导入DLI或OBS表，目前仅支持将OBS上的数据导入DLI或OBS中。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) ImportTableInvoker 

func (c *DliClient) ImportTableInvoker(request *model.ImportTableRequest) *ImportTableInvoker

ImportTableInvoker 导入数据

func (*DliClient) ListAllTables 

func (c *DliClient) ListAllTables(request *model.ListAllTablesRequest) (*model.ListAllTablesResponse, error)

ListAllTables 查询所有表

该API用于查询指定数据库下符合过滤条件的或所有的表信息。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) ListAllTablesInvoker 

func (c *DliClient) ListAllTablesInvoker(request *model.ListAllTablesRequest) *ListAllTablesInvoker

ListAllTablesInvoker 查询所有表

func (*DliClient) ListAuthInfo 

func (c *DliClient) ListAuthInfo(request *model.ListAuthInfoRequest) (*model.ListAuthInfoResponse, error)

ListAuthInfo 获取跨源认证列表

该API用于查询跨源认证信息。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) ListAuthInfoInvoker 

func (c *DliClient) ListAuthInfoInvoker(request *model.ListAuthInfoRequest) *ListAuthInfoInvoker

ListAuthInfoInvoker 获取跨源认证列表

func (*DliClient) ListBatches 

func (c *DliClient) ListBatches(request *model.ListBatchesRequest) (*model.ListBatchesResponse, error)

ListBatches 查询批处理作业列表

该API用于查询Project下某队列批处理作业的列表。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) ListBatchesInvoker 

func (c *DliClient) ListBatchesInvoker(request *model.ListBatchesRequest) *ListBatchesInvoker

ListBatchesInvoker 查询批处理作业列表

func (*DliClient) ListDatabaseUsers 

func (c *DliClient) ListDatabaseUsers(request *model.ListDatabaseUsersRequest) (*model.ListDatabaseUsersResponse, error)

ListDatabaseUsers 查看数据库的使用者

该API用于查询可以使用的指定队列的所有用户名称。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) ListDatabaseUsersInvoker 

func (c *DliClient) ListDatabaseUsersInvoker(request *model.ListDatabaseUsersRequest) *ListDatabaseUsersInvoker

ListDatabaseUsersInvoker 查看数据库的使用者

func (*DliClient) ListDatabases 

func (c *DliClient) ListDatabases(request *model.ListDatabasesRequest) (*model.ListDatabasesResponse, error)

ListDatabases 查询所有数据库

该API用于查询出所有的数据库信息。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) ListDatabasesInvoker 

func (c *DliClient) ListDatabasesInvoker(request *model.ListDatabasesRequest) *ListDatabasesInvoker

ListDatabasesInvoker 查询所有数据库

func (*DliClient) ListDatasourceConnections 

func (c *DliClient) ListDatasourceConnections(request *model.ListDatasourceConnectionsRequest) (*model.ListDatasourceConnectionsResponse, error)

ListDatasourceConnections 查询经典型跨源连接列表

该API用于查询该用户已创建的经典型跨源连接列表。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) ListDatasourceConnectionsInvoker 

func (c *DliClient) ListDatasourceConnectionsInvoker(request *model.ListDatasourceConnectionsRequest) *ListDatasourceConnectionsInvoker

ListDatasourceConnectionsInvoker 查询经典型跨源连接列表

func (*DliClient) ListElasticResourcePoolQueues 

func (c *DliClient) ListElasticResourcePoolQueues(request *model.ListElasticResourcePoolQueuesRequest) (*model.ListElasticResourcePoolQueuesResponse, error)

ListElasticResourcePoolQueues 查询弹性资源池所属队列

查询弹性资源池所属队列

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) ListElasticResourcePoolQueuesInvoker 

func (c *DliClient) ListElasticResourcePoolQueuesInvoker(request *model.ListElasticResourcePoolQueuesRequest) *ListElasticResourcePoolQueuesInvoker

ListElasticResourcePoolQueuesInvoker 查询弹性资源池所属队列

func (*DliClient) ListElasticResourcePoolScaleRecords 

func (c *DliClient) ListElasticResourcePoolScaleRecords(request *model.ListElasticResourcePoolScaleRecordsRequest) (*model.ListElasticResourcePoolScaleRecordsResponse, error)

ListElasticResourcePoolScaleRecords 弹性资源池扩缩容历史记录

查询当前弹性资源池扩缩容历史记录

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) ListElasticResourcePoolScaleRecordsInvoker 

func (c *DliClient) ListElasticResourcePoolScaleRecordsInvoker(request *model.ListElasticResourcePoolScaleRecordsRequest) *ListElasticResourcePoolScaleRecordsInvoker

ListElasticResourcePoolScaleRecordsInvoker 弹性资源池扩缩容历史记录

func (*DliClient) ListElasticResourcePools 

func (c *DliClient) ListElasticResourcePools(request *model.ListElasticResourcePoolsRequest) (*model.ListElasticResourcePoolsResponse, error)

ListElasticResourcePools 查询所有弹性资源池

查询所有弹性资源池

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) ListElasticResourcePoolsInvoker 

func (c *DliClient) ListElasticResourcePoolsInvoker(request *model.ListElasticResourcePoolsRequest) *ListElasticResourcePoolsInvoker

ListElasticResourcePoolsInvoker 查询所有弹性资源池

func (*DliClient) ListEnhancedConnections 

func (c *DliClient) ListEnhancedConnections(request *model.ListEnhancedConnectionsRequest) (*model.ListEnhancedConnectionsResponse, error)

ListEnhancedConnections 查询增强型跨源连接列表

该API用于查询该用户已创建的增强型跨源连接列表。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) ListEnhancedConnectionsInvoker 

func (c *DliClient) ListEnhancedConnectionsInvoker(request *model.ListEnhancedConnectionsRequest) *ListEnhancedConnectionsInvoker

ListEnhancedConnectionsInvoker 查询增强型跨源连接列表

func (*DliClient) ListFlinkJobs 

func (c *DliClient) ListFlinkJobs(request *model.ListFlinkJobsRequest) (*model.ListFlinkJobsResponse, error)

ListFlinkJobs 查询Flink作业列表

查询当前用户的作业列表，可以根据作业ID作为ID，查询大于ID或小于ID的限定条数的作业，默认查询全部状态的作业，也可以设定运行中或其他状态条件。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) ListFlinkJobsInvoker 

func (c *DliClient) ListFlinkJobsInvoker(request *model.ListFlinkJobsRequest) *ListFlinkJobsInvoker

ListFlinkJobsInvoker 查询Flink作业列表

func (*DliClient) ListFlinkTemplates 

func (c *DliClient) ListFlinkTemplates(request *model.ListFlinkTemplatesRequest) (*model.ListFlinkTemplatesResponse, error)

ListFlinkTemplates 查询Flink作业模板列表

查询Flink作业模板列表。当前只支持查询用户自定义模板。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) ListFlinkTemplatesInvoker 

func (c *DliClient) ListFlinkTemplatesInvoker(request *model.ListFlinkTemplatesRequest) *ListFlinkTemplatesInvoker

ListFlinkTemplatesInvoker 查询Flink作业模板列表

func (*DliClient) ListGlobalValues 

func (c *DliClient) ListGlobalValues(request *model.ListGlobalValuesRequest) (*model.ListGlobalValuesResponse, error)

ListGlobalValues 查询DLI全局变量列表

查询全局变量列表。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) ListGlobalValuesInvoker 

func (c *DliClient) ListGlobalValuesInvoker(request *model.ListGlobalValuesRequest) *ListGlobalValuesInvoker

ListGlobalValuesInvoker 查询DLI全局变量列表

func (*DliClient) ListJobTemplates 

func (c *DliClient) ListJobTemplates(request *model.ListJobTemplatesRequest) (*model.ListJobTemplatesResponse, error)

ListJobTemplates 查询作业模板列表

该API用于查询作业模板列表。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) ListJobTemplatesInvoker 

func (c *DliClient) ListJobTemplatesInvoker(request *model.ListJobTemplatesRequest) *ListJobTemplatesInvoker

ListJobTemplatesInvoker 查询作业模板列表

func (*DliClient) ListQueuePlans 

func (c *DliClient) ListQueuePlans(request *model.ListQueuePlansRequest) (*model.ListQueuePlansResponse, error)

ListQueuePlans 查看队列定时扩缩容计划

查看队列定时扩缩容计划接口，列出指定队列定时规格变更计划。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) ListQueuePlansInvoker 

func (c *DliClient) ListQueuePlansInvoker(request *model.ListQueuePlansRequest) *ListQueuePlansInvoker

ListQueuePlansInvoker 查看队列定时扩缩容计划

func (*DliClient) ListQueueUsers 

func (c *DliClient) ListQueueUsers(request *model.ListQueueUsersRequest) (*model.ListQueueUsersResponse, error)

ListQueueUsers 查看队列的使用者

该API用于查询可以使用的指定队列的所有用户名称。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) ListQueueUsersInvoker 

func (c *DliClient) ListQueueUsersInvoker(request *model.ListQueueUsersRequest) *ListQueueUsersInvoker

ListQueueUsersInvoker 查看队列的使用者

func (*DliClient) ListQueues 

func (c *DliClient) ListQueues(request *model.ListQueuesRequest) (*model.ListQueuesResponse, error)

ListQueues 查询所有队列

该API用于列出该project下所有的队列。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) ListQueuesInvoker 

func (c *DliClient) ListQueuesInvoker(request *model.ListQueuesRequest) *ListQueuesInvoker

ListQueuesInvoker 查询所有队列

func (*DliClient) ListResources 

func (c *DliClient) ListResources(request *model.ListResourcesRequest) (*model.ListResourcesResponse, error)

ListResources 查看分组资源列表

该API用于查看某个project下的所有资源，其中包含Group。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) ListResourcesInvoker 

func (c *DliClient) ListResourcesInvoker(request *model.ListResourcesRequest) *ListResourcesInvoker

ListResourcesInvoker 查看分组资源列表

func (*DliClient) ListSqlJobs 

func (c *DliClient) ListSqlJobs(request *model.ListSqlJobsRequest) (*model.ListSqlJobsResponse, error)

ListSqlJobs 查询所有作业

该API用于查询当前工程下面的所有作业的信息。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) ListSqlJobsInvoker 

func (c *DliClient) ListSqlJobsInvoker(request *model.ListSqlJobsRequest) *ListSqlJobsInvoker

ListSqlJobsInvoker 查询所有作业

func (*DliClient) ListTablePrivileges 

func (c *DliClient) ListTablePrivileges(request *model.ListTablePrivilegesRequest) (*model.ListTablePrivilegesResponse, error)

ListTablePrivileges 查看表的用户权限

该API用于查询指定用户在表上的权限。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) ListTablePrivilegesInvoker 

func (c *DliClient) ListTablePrivilegesInvoker(request *model.ListTablePrivilegesRequest) *ListTablePrivilegesInvoker

ListTablePrivilegesInvoker 查看表的用户权限

func (*DliClient) ListTableUsers 

func (c *DliClient) ListTableUsers(request *model.ListTableUsersRequest) (*model.ListTableUsersResponse, error)

ListTableUsers 查看表的使用者

该API用于查看有权访问指定表或表的列的所有用户。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) ListTableUsersInvoker 

func (c *DliClient) ListTableUsersInvoker(request *model.ListTableUsersRequest) *ListTableUsersInvoker

ListTableUsersInvoker 查看表的使用者

func (*DliClient) PreviewJobResult 

func (c *DliClient) PreviewJobResult(request *model.PreviewJobResultRequest) (*model.PreviewJobResultResponse, error)

PreviewJobResult 预览SQL作业查询结果

该API用于在执行SQL查询语句的作业完成后，查看该作业执行的结果。目前仅支持查看“QUERY”类型作业的执行结果。 该API只能查看前1000条的结果记录，若要查看全部的结果记录，需要先导出查询结果再进行查看。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) PreviewJobResultInvoker 

func (c *DliClient) PreviewJobResultInvoker(request *model.PreviewJobResultRequest) *PreviewJobResultInvoker

PreviewJobResultInvoker 预览SQL作业查询结果

func (*DliClient) RegisterAuthorizedQueue 

func (c *DliClient) RegisterAuthorizedQueue(request *model.RegisterAuthorizedQueueRequest) (*model.RegisterAuthorizedQueueResponse, error)

RegisterAuthorizedQueue 队列赋权

该API用于与其他用户共享指定的队列，可以给用户赋使用指定的队列的权限或者收回使用权限。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) RegisterAuthorizedQueueInvoker 

func (c *DliClient) RegisterAuthorizedQueueInvoker(request *model.RegisterAuthorizedQueueRequest) *RegisterAuthorizedQueueInvoker

RegisterAuthorizedQueueInvoker 队列赋权

func (*DliClient) RegisterBucket 

func (c *DliClient) RegisterBucket(request *model.RegisterBucketRequest) (*model.RegisterBucketResponse, error)

RegisterBucket OBS授权给DLI服务

用户主动授权OBS桶的操作权限给DLI服务, 用于保存用户作业的checkpoint、作业的运行日志等。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) RegisterBucketInvoker 

func (c *DliClient) RegisterBucketInvoker(request *model.RegisterBucketRequest) *RegisterBucketInvoker

RegisterBucketInvoker OBS授权给DLI服务

func (*DliClient) RunIefJobActionCallBack 

func (c *DliClient) RunIefJobActionCallBack(request *model.RunIefJobActionCallBackRequest) (*model.RunIefJobActionCallBackResponse, error)

RunIefJobActionCallBack 边缘Flink作业Action状态回调

该API用于处理IEF Flink作业action回调信息

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) RunIefJobActionCallBackInvoker 

func (c *DliClient) RunIefJobActionCallBackInvoker(request *model.RunIefJobActionCallBackRequest) *RunIefJobActionCallBackInvoker

RunIefJobActionCallBackInvoker 边缘Flink作业Action状态回调

func (*DliClient) RunQueueAction 

func (c *DliClient) RunQueueAction(request *model.RunQueueActionRequest) (*model.RunQueueActionResponse, error)

RunQueueAction 重启/扩容/缩容队列

该功能用于重新启动队列、扩容队列、缩容队列。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) RunQueueActionInvoker 

func (c *DliClient) RunQueueActionInvoker(request *model.RunQueueActionRequest) *RunQueueActionInvoker

RunQueueActionInvoker 重启/扩容/缩容队列

func (*DliClient) ShowBatchInfo 

func (c *DliClient) ShowBatchInfo(request *model.ShowBatchInfoRequest) (*model.ShowBatchInfoResponse, error)

ShowBatchInfo 查询批处理作业详情

该API用于根据批处理作业的id查询作业详情。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) ShowBatchInfoInvoker 

func (c *DliClient) ShowBatchInfoInvoker(request *model.ShowBatchInfoRequest) *ShowBatchInfoInvoker

ShowBatchInfoInvoker 查询批处理作业详情

func (*DliClient) ShowBatchLog 

func (c *DliClient) ShowBatchLog(request *model.ShowBatchLogRequest) (*model.ShowBatchLogResponse, error)

ShowBatchLog 查询批处理作业日志

该API用于查询批处理作业的后台日志。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) ShowBatchLogInvoker 

func (c *DliClient) ShowBatchLogInvoker(request *model.ShowBatchLogRequest) *ShowBatchLogInvoker

ShowBatchLogInvoker 查询批处理作业日志

func (*DliClient) ShowBatchState 

func (c *DliClient) ShowBatchState(request *model.ShowBatchStateRequest) (*model.ShowBatchStateResponse, error)

ShowBatchState 查询批处理作业状态

该API用于查询批处理作业的状态。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) ShowBatchStateInvoker 

func (c *DliClient) ShowBatchStateInvoker(request *model.ShowBatchStateRequest) *ShowBatchStateInvoker

ShowBatchStateInvoker 查询批处理作业状态

func (*DliClient) ShowDatasourceConnection 

func (c *DliClient) ShowDatasourceConnection(request *model.ShowDatasourceConnectionRequest) (*model.ShowDatasourceConnectionResponse, error)

ShowDatasourceConnection 查询经典型跨源连接

该API用于查询该用户指定的已创建的经典型跨源连接。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) ShowDatasourceConnectionInvoker 

func (c *DliClient) ShowDatasourceConnectionInvoker(request *model.ShowDatasourceConnectionRequest) *ShowDatasourceConnectionInvoker

ShowDatasourceConnectionInvoker 查询经典型跨源连接

func (*DliClient) ShowDescribeTable 

func (c *DliClient) ShowDescribeTable(request *model.ShowDescribeTableRequest) (*model.ShowDescribeTableResponse, error)

ShowDescribeTable 描述表信息

该API用于描述指定表的元数据信息。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) ShowDescribeTableInvoker 

func (c *DliClient) ShowDescribeTableInvoker(request *model.ShowDescribeTableRequest) *ShowDescribeTableInvoker

ShowDescribeTableInvoker 描述表信息

func (*DliClient) ShowDliAgency 

func (c *DliClient) ShowDliAgency(request *model.ShowDliAgencyRequest) (*model.ShowDliAgencyResponse, error)

ShowDliAgency 获取dli委托信息

获取dli委托信息

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) ShowDliAgencyInvoker 

func (c *DliClient) ShowDliAgencyInvoker(request *model.ShowDliAgencyRequest) *ShowDliAgencyInvoker

ShowDliAgencyInvoker 获取dli委托信息

func (*DliClient) ShowEnhancedConnection 

func (c *DliClient) ShowEnhancedConnection(request *model.ShowEnhancedConnectionRequest) (*model.ShowEnhancedConnectionResponse, error)

ShowEnhancedConnection 查询增强型跨源连接

该API用于查询该用户指定的已创建的增强型跨源连接。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) ShowEnhancedConnectionInvoker 

func (c *DliClient) ShowEnhancedConnectionInvoker(request *model.ShowEnhancedConnectionRequest) *ShowEnhancedConnectionInvoker

ShowEnhancedConnectionInvoker 查询增强型跨源连接

func (*DliClient) ShowEnhancedPrivilege 

func (c *DliClient) ShowEnhancedPrivilege(request *model.ShowEnhancedPrivilegeRequest) (*model.ShowEnhancedPrivilegeResponse, error)

ShowEnhancedPrivilege 查询增强型跨源授权信息

该API用于查询增强型跨源连接授权的信息。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) ShowEnhancedPrivilegeInvoker 

func (c *DliClient) ShowEnhancedPrivilegeInvoker(request *model.ShowEnhancedPrivilegeRequest) *ShowEnhancedPrivilegeInvoker

ShowEnhancedPrivilegeInvoker 查询增强型跨源授权信息

func (*DliClient) ShowFlinkExecuteGraph 

func (c *DliClient) ShowFlinkExecuteGraph(request *model.ShowFlinkExecuteGraphRequest) (*model.ShowFlinkExecuteGraphResponse, error)

ShowFlinkExecuteGraph 查询Flink作业执行计划

查询Flink作业执行计划。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) ShowFlinkExecuteGraphInvoker 

func (c *DliClient) ShowFlinkExecuteGraphInvoker(request *model.ShowFlinkExecuteGraphRequest) *ShowFlinkExecuteGraphInvoker

ShowFlinkExecuteGraphInvoker 查询Flink作业执行计划

func (*DliClient) ShowFlinkJob 

func (c *DliClient) ShowFlinkJob(request *model.ShowFlinkJobRequest) (*model.ShowFlinkJobResponse, error)

ShowFlinkJob 查询Flink作业详情

查看一个Flink作业的详情信息。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) ShowFlinkJobInvoker 

func (c *DliClient) ShowFlinkJobInvoker(request *model.ShowFlinkJobRequest) *ShowFlinkJobInvoker

ShowFlinkJobInvoker 查询Flink作业详情

func (*DliClient) ShowFlinkMetric 

func (c *DliClient) ShowFlinkMetric(request *model.ShowFlinkMetricRequest) (*model.ShowFlinkMetricResponse, error)

ShowFlinkMetric 查询Flink作业监控信息

查询Flink作业监控信息, 支持同时查询多个Flink作业的监控信息。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) ShowFlinkMetricInvoker 

func (c *DliClient) ShowFlinkMetricInvoker(request *model.ShowFlinkMetricRequest) *ShowFlinkMetricInvoker

ShowFlinkMetricInvoker 查询Flink作业监控信息

func (*DliClient) ShowJobProgress 

func (c *DliClient) ShowJobProgress(request *model.ShowJobProgressRequest) (*model.ShowJobProgressResponse, error)

ShowJobProgress 查询作业执行进度信息

该API用于获取作业执行进度信息，如果作业正在执行，可以获取到子作业的信息，如果作业刚开始或者已经结束，不可以获取到子作业信息。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) ShowJobProgressInvoker 

func (c *DliClient) ShowJobProgressInvoker(request *model.ShowJobProgressRequest) *ShowJobProgressInvoker

ShowJobProgressInvoker 查询作业执行进度信息

func (*DliClient) ShowJobTemplate 

func (c *DliClient) ShowJobTemplate(request *model.ShowJobTemplateRequest) (*model.ShowJobTemplateResponse, error)

ShowJobTemplate 获取作业模板

该API用于获取作业模板。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) ShowJobTemplateInvoker 

func (c *DliClient) ShowJobTemplateInvoker(request *model.ShowJobTemplateRequest) *ShowJobTemplateInvoker

ShowJobTemplateInvoker 获取作业模板

func (*DliClient) ShowNodeConnectivity 

func (c *DliClient) ShowNodeConnectivity(request *model.ShowNodeConnectivityRequest) (*model.ShowNodeConnectivityResponse, error)

ShowNodeConnectivity 查询指定地址连通性测试详情

该API用于在连通性测试提交后查询连通性结果。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) ShowNodeConnectivityInvoker 

func (c *DliClient) ShowNodeConnectivityInvoker(request *model.ShowNodeConnectivityRequest) *ShowNodeConnectivityInvoker

ShowNodeConnectivityInvoker 查询指定地址连通性测试详情

func (*DliClient) ShowObjectUser 

func (c *DliClient) ShowObjectUser(request *model.ShowObjectUserRequest) (*model.ShowObjectUserResponse, error)

ShowObjectUser 查看赋权对象的用者权限信息

获取对象赋权用户的权限信息

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) ShowObjectUserInvoker 

func (c *DliClient) ShowObjectUserInvoker(request *model.ShowObjectUserRequest) *ShowObjectUserInvoker

ShowObjectUserInvoker 查看赋权对象的用者权限信息

func (*DliClient) ShowPartitions 

func (c *DliClient) ShowPartitions(request *model.ShowPartitionsRequest) (*model.ShowPartitionsResponse, error)

ShowPartitions 获取分区信息列表

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) ShowPartitionsInvoker 

func (c *DliClient) ShowPartitionsInvoker(request *model.ShowPartitionsRequest) *ShowPartitionsInvoker

ShowPartitionsInvoker 获取分区信息列表

func (*DliClient) ShowQueueDetail 

func (c *DliClient) ShowQueueDetail(request *model.ShowQueueDetailRequest) (*model.ShowQueueDetailResponse, error)

ShowQueueDetail 查询队列详情

该API用于列出该project下指定的队列详情。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) ShowQueueDetailInvoker 

func (c *DliClient) ShowQueueDetailInvoker(request *model.ShowQueueDetailRequest) *ShowQueueDetailInvoker

ShowQueueDetailInvoker 查询队列详情

func (*DliClient) ShowResourceInfo 

func (c *DliClient) ShowResourceInfo(request *model.ShowResourceInfoRequest) (*model.ShowResourceInfoResponse, error)

ShowResourceInfo 查看组内资源包

该API用于查看某个project某个分组下的具体资源信息。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) ShowResourceInfoInvoker 

func (c *DliClient) ShowResourceInfoInvoker(request *model.ShowResourceInfoRequest) *ShowResourceInfoInvoker

ShowResourceInfoInvoker 查看组内资源包

func (*DliClient) ShowSqlJobDetail 

func (c *DliClient) ShowSqlJobDetail(request *model.ShowSqlJobDetailRequest) (*model.ShowSqlJobDetailResponse, error)

ShowSqlJobDetail 查询作业详细信息

该API用于查询作业的详细信息，如作业的databasename、tablename、file size和export mode等信息。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) ShowSqlJobDetailInvoker 

func (c *DliClient) ShowSqlJobDetailInvoker(request *model.ShowSqlJobDetailRequest) *ShowSqlJobDetailInvoker

ShowSqlJobDetailInvoker 查询作业详细信息

func (*DliClient) ShowSqlJobStatus 

func (c *DliClient) ShowSqlJobStatus(request *model.ShowSqlJobStatusRequest) (*model.ShowSqlJobStatusResponse, error)

ShowSqlJobStatus 查询作业状态

该API用于在作业提交后查询作业状态。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) ShowSqlJobStatusInvoker 

func (c *DliClient) ShowSqlJobStatusInvoker(request *model.ShowSqlJobStatusRequest) *ShowSqlJobStatusInvoker

ShowSqlJobStatusInvoker 查询作业状态

func (*DliClient) ShowSqlSampleTemplates 

func (c *DliClient) ShowSqlSampleTemplates(request *model.ShowSqlSampleTemplatesRequest) (*model.ShowSqlSampleTemplatesResponse, error)

ShowSqlSampleTemplates 查询所有SQL样例模板

该API用于查询所有SQL样例模板。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) ShowSqlSampleTemplatesInvoker 

func (c *DliClient) ShowSqlSampleTemplatesInvoker(request *model.ShowSqlSampleTemplatesRequest) *ShowSqlSampleTemplatesInvoker

ShowSqlSampleTemplatesInvoker 查询所有SQL样例模板

func (*DliClient) ShowSqlTemplates 

func (c *DliClient) ShowSqlTemplates(request *model.ShowSqlTemplatesRequest) (*model.ShowSqlTemplatesResponse, error)

ShowSqlTemplates 查看所有SQL模板

该API用查看用户保存的所有SQL模板。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) ShowSqlTemplatesInvoker 

func (c *DliClient) ShowSqlTemplatesInvoker(request *model.ShowSqlTemplatesRequest) *ShowSqlTemplatesInvoker

ShowSqlTemplatesInvoker 查看所有SQL模板

func (*DliClient) ShowTableContent 

func (c *DliClient) ShowTableContent(request *model.ShowTableContentRequest) (*model.ShowTableContentResponse, error)

ShowTableContent 预览表内容

该API用于用于预览表中前10行的内容。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) ShowTableContentInvoker 

func (c *DliClient) ShowTableContentInvoker(request *model.ShowTableContentRequest) *ShowTableContentInvoker

ShowTableContentInvoker 预览表内容

func (*DliClient) StopFlinkJobs 

func (c *DliClient) StopFlinkJobs(request *model.StopFlinkJobsRequest) (*model.StopFlinkJobsResponse, error)

StopFlinkJobs 批量停止Flink作业

批量停止正在运行的Flink作业。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) StopFlinkJobsInvoker 

func (c *DliClient) StopFlinkJobsInvoker(request *model.StopFlinkJobsRequest) *StopFlinkJobsInvoker

StopFlinkJobsInvoker 批量停止Flink作业

func (*DliClient) UpdateAuthInfo 

func (c *DliClient) UpdateAuthInfo(request *model.UpdateAuthInfoRequest) (*model.UpdateAuthInfoResponse, error)

UpdateAuthInfo 更新跨源认证

该API用于更新跨源认证信息。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) UpdateAuthInfoInvoker 

func (c *DliClient) UpdateAuthInfoInvoker(request *model.UpdateAuthInfoRequest) *UpdateAuthInfoInvoker

UpdateAuthInfoInvoker 更新跨源认证

func (*DliClient) UpdateDatabaseOwner 

func (c *DliClient) UpdateDatabaseOwner(request *model.UpdateDatabaseOwnerRequest) (*model.UpdateDatabaseOwnerResponse, error)

UpdateDatabaseOwner 修改数据库用户

用于修改数据库的owner。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) UpdateDatabaseOwnerInvoker 

func (c *DliClient) UpdateDatabaseOwnerInvoker(request *model.UpdateDatabaseOwnerRequest) *UpdateDatabaseOwnerInvoker

UpdateDatabaseOwnerInvoker 修改数据库用户

func (*DliClient) UpdateElasticResourcePool 

func (c *DliClient) UpdateElasticResourcePool(request *model.UpdateElasticResourcePoolRequest) (*model.UpdateElasticResourcePoolResponse, error)

UpdateElasticResourcePool 修改弹性资源池信息

修改弹性资源池信息

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) UpdateElasticResourcePoolInvoker 

func (c *DliClient) UpdateElasticResourcePoolInvoker(request *model.UpdateElasticResourcePoolRequest) *UpdateElasticResourcePoolInvoker

UpdateElasticResourcePoolInvoker 修改弹性资源池信息

func (*DliClient) UpdateElasticResourcePoolQueueInfo 

func (c *DliClient) UpdateElasticResourcePoolQueueInfo(request *model.UpdateElasticResourcePoolQueueInfoRequest) (*model.UpdateElasticResourcePoolQueueInfoResponse, error)

UpdateElasticResourcePoolQueueInfo 修改弹性资源池关联的队列优先级

设置弹性资源池指定队列的扩缩容策略信息。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) UpdateElasticResourcePoolQueueInfoInvoker 

func (c *DliClient) UpdateElasticResourcePoolQueueInfoInvoker(request *model.UpdateElasticResourcePoolQueueInfoRequest) *UpdateElasticResourcePoolQueueInfoInvoker

UpdateElasticResourcePoolQueueInfoInvoker 修改弹性资源池关联的队列优先级

func (*DliClient) UpdateFlinkJar 

func (c *DliClient) UpdateFlinkJar(request *model.UpdateFlinkJarRequest) (*model.UpdateFlinkJarResponse, error)

UpdateFlinkJar 更新Flink Jar作业

更新用户自定义作业，目前支持jar格式，运行在独享集群中。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) UpdateFlinkJarInvoker 

func (c *DliClient) UpdateFlinkJarInvoker(request *model.UpdateFlinkJarRequest) *UpdateFlinkJarInvoker

UpdateFlinkJarInvoker 更新Flink Jar作业

func (*DliClient) UpdateFlinkSql 

func (c *DliClient) UpdateFlinkSql(request *model.UpdateFlinkSqlRequest) (*model.UpdateFlinkSqlResponse, error)

UpdateFlinkSql 更新Flink SQL作业

Stream SQL的语法扩展了Apache Flink SQL。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) UpdateFlinkSqlInvoker 

func (c *DliClient) UpdateFlinkSqlInvoker(request *model.UpdateFlinkSqlRequest) *UpdateFlinkSqlInvoker

UpdateFlinkSqlInvoker 更新Flink SQL作业

func (*DliClient) UpdateFlinkTemplate 

func (c *DliClient) UpdateFlinkTemplate(request *model.UpdateFlinkTemplateRequest) (*model.UpdateFlinkTemplateResponse, error)

UpdateFlinkTemplate 更新Flink作业模板

对DLI服务中已有的Flink作业模板进行更新。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) UpdateFlinkTemplateInvoker 

func (c *DliClient) UpdateFlinkTemplateInvoker(request *model.UpdateFlinkTemplateRequest) *UpdateFlinkTemplateInvoker

UpdateFlinkTemplateInvoker 更新Flink作业模板

func (*DliClient) UpdateGlobalValue 

func (c *DliClient) UpdateGlobalValue(request *model.UpdateGlobalValueRequest) (*model.UpdateGlobalValueResponse, error)

UpdateGlobalValue 修改DLI全局变量

修改全局变量。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) UpdateGlobalValueInvoker 

func (c *DliClient) UpdateGlobalValueInvoker(request *model.UpdateGlobalValueRequest) *UpdateGlobalValueInvoker

UpdateGlobalValueInvoker 修改DLI全局变量

func (*DliClient) UpdateGroupOrResourceOwner 

func (c *DliClient) UpdateGroupOrResourceOwner(request *model.UpdateGroupOrResourceOwnerRequest) (*model.UpdateGroupOrResourceOwnerResponse, error)

UpdateGroupOrResourceOwner 修改组或者资源包拥有者

用于修改程序包的owner。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) UpdateGroupOrResourceOwnerInvoker 

func (c *DliClient) UpdateGroupOrResourceOwnerInvoker(request *model.UpdateGroupOrResourceOwnerRequest) *UpdateGroupOrResourceOwnerInvoker

UpdateGroupOrResourceOwnerInvoker 修改组或者资源包拥有者

func (*DliClient) UpdateHostMassage 

func (c *DliClient) UpdateHostMassage(request *model.UpdateHostMassageRequest) (*model.UpdateHostMassageResponse, error)

UpdateHostMassage 修改增强型跨源主机信息

该API用于在跨源中修改数据源主机信息，仅支持全量覆盖。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) UpdateHostMassageInvoker 

func (c *DliClient) UpdateHostMassageInvoker(request *model.UpdateHostMassageRequest) *UpdateHostMassageInvoker

UpdateHostMassageInvoker 修改增强型跨源主机信息

func (*DliClient) UpdateJobTemplates 

func (c *DliClient) UpdateJobTemplates(request *model.UpdateJobTemplatesRequest) (*model.UpdateJobTemplatesResponse, error)

UpdateJobTemplates 修改作业模板

该API用于修改作业模板。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) UpdateJobTemplatesInvoker 

func (c *DliClient) UpdateJobTemplatesInvoker(request *model.UpdateJobTemplatesRequest) *UpdateJobTemplatesInvoker

UpdateJobTemplatesInvoker 修改作业模板

func (*DliClient) UpdateQueueCidr 

func (c *DliClient) UpdateQueueCidr(request *model.UpdateQueueCidrRequest) (*model.UpdateQueueCidrResponse, error)

UpdateQueueCidr 修改队列网段

该功能用于修改包年包月队列网段。 说明： 如果待修改网段的队列中有正在提交或正在运行的作业，或者改队列已经绑定了增强型跨源，将不支持修改网段操作。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) UpdateQueueCidrInvoker 

func (c *DliClient) UpdateQueueCidrInvoker(request *model.UpdateQueueCidrRequest) *UpdateQueueCidrInvoker

UpdateQueueCidrInvoker 修改队列网段

func (*DliClient) UpdateSqlTemplates 

func (c *DliClient) UpdateSqlTemplates(request *model.UpdateSqlTemplatesRequest) (*model.UpdateSqlTemplatesResponse, error)

UpdateSqlTemplates 更新SQL模板

该API用于更新SQL模板。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) UpdateSqlTemplatesInvoker 

func (c *DliClient) UpdateSqlTemplatesInvoker(request *model.UpdateSqlTemplatesRequest) *UpdateSqlTemplatesInvoker

UpdateSqlTemplatesInvoker 更新SQL模板

func (*DliClient) UpdateTableOwner 

func (c *DliClient) UpdateTableOwner(request *model.UpdateTableOwnerRequest) (*model.UpdateTableOwnerResponse, error)

UpdateTableOwner 修改表用户

用于修改表的owner。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) UpdateTableOwnerInvoker 

func (c *DliClient) UpdateTableOwnerInvoker(request *model.UpdateTableOwnerRequest) *UpdateTableOwnerInvoker

UpdateTableOwnerInvoker 修改表用户

func (*DliClient) UploadFiles 

func (c *DliClient) UploadFiles(request *model.UploadFilesRequest) (*model.UploadFilesResponse, error)

UploadFiles 上传file类型分组资源

该API用于在project下上传file类型模块。 说明： 上传同名file模块时，新模块将会覆盖旧模块。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) UploadFilesInvoker 

func (c *DliClient) UploadFilesInvoker(request *model.UploadFilesRequest) *UploadFilesInvoker

UploadFilesInvoker 上传file类型分组资源

func (*DliClient) UploadJars 

func (c *DliClient) UploadJars(request *model.UploadJarsRequest) (*model.UploadJarsResponse, error)

UploadJars 上传jar类型分组资源

该API用于在project下上传jar类型分组资源。 说明：上传同名资源模块时，新模块将会覆盖旧模块。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) UploadJarsInvoker 

func (c *DliClient) UploadJarsInvoker(request *model.UploadJarsRequest) *UploadJarsInvoker

UploadJarsInvoker 上传jar类型分组资源

func (*DliClient) UploadPythonFiles 

func (c *DliClient) UploadPythonFiles(request *model.UploadPythonFilesRequest) (*model.UploadPythonFilesResponse, error)

UploadPythonFiles 上传pyfile类型分组资源

该API用于在project下的上传pyfile类型模块。 说明： 上传同名pyfile类型模块时，新模块将会覆盖旧模块。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) UploadPythonFilesInvoker 

func (c *DliClient) UploadPythonFilesInvoker(request *model.UploadPythonFilesRequest) *UploadPythonFilesInvoker

UploadPythonFilesInvoker 上传pyfile类型分组资源

func (*DliClient) UploadResources 

func (c *DliClient) UploadResources(request *model.UploadResourcesRequest) (*model.UploadResourcesResponse, error)

UploadResources 上传分组资源

该API用于上传分组资源到某个project下。

Please refer to HUAWEI cloud API Explorer for details.

func (*DliClient) UploadResourcesInvoker 

func (c *DliClient) UploadResourcesInvoker(request *model.UploadResourcesRequest) *UploadResourcesInvoker

UploadResourcesInvoker 上传分组资源

type ExportFlinkJobInvoker 

type ExportFlinkJobInvoker struct {
	*invoker.BaseInvoker
}

func (*ExportFlinkJobInvoker) Invoke 

func (i *ExportFlinkJobInvoker) Invoke() (*model.ExportFlinkJobResponse, error)

type ExportSqlJobResultInvoker 

type ExportSqlJobResultInvoker struct {
	*invoker.BaseInvoker
}

func (*ExportSqlJobResultInvoker) Invoke 

func (i *ExportSqlJobResultInvoker) Invoke() (*model.ExportSqlJobResultResponse, error)

type ExportTableInvoker 

type ExportTableInvoker struct {
	*invoker.BaseInvoker
}

func (*ExportTableInvoker) Invoke 

func (i *ExportTableInvoker) Invoke() (*model.ExportTableResponse, error)

type ImportFlinkJobInvoker 

type ImportFlinkJobInvoker struct {
	*invoker.BaseInvoker
}

func (*ImportFlinkJobInvoker) Invoke 

func (i *ImportFlinkJobInvoker) Invoke() (*model.ImportFlinkJobResponse, error)

type ImportTableInvoker 

type ImportTableInvoker struct {
	*invoker.BaseInvoker
}

func (*ImportTableInvoker) Invoke 

func (i *ImportTableInvoker) Invoke() (*model.ImportTableResponse, error)

type ListAllTablesInvoker 

type ListAllTablesInvoker struct {
	*invoker.BaseInvoker
}

func (*ListAllTablesInvoker) Invoke 

func (i *ListAllTablesInvoker) Invoke() (*model.ListAllTablesResponse, error)

type ListAuthInfoInvoker 

type ListAuthInfoInvoker struct {
	*invoker.BaseInvoker
}

func (*ListAuthInfoInvoker) Invoke 

func (i *ListAuthInfoInvoker) Invoke() (*model.ListAuthInfoResponse, error)

type ListBatchesInvoker 

type ListBatchesInvoker struct {
	*invoker.BaseInvoker
}

func (*ListBatchesInvoker) Invoke 

func (i *ListBatchesInvoker) Invoke() (*model.ListBatchesResponse, error)

type ListDatabaseUsersInvoker 

type ListDatabaseUsersInvoker struct {
	*invoker.BaseInvoker
}

func (*ListDatabaseUsersInvoker) Invoke 

func (i *ListDatabaseUsersInvoker) Invoke() (*model.ListDatabaseUsersResponse, error)

type ListDatabasesInvoker 

type ListDatabasesInvoker struct {
	*invoker.BaseInvoker
}

func (*ListDatabasesInvoker) Invoke 

func (i *ListDatabasesInvoker) Invoke() (*model.ListDatabasesResponse, error)

type ListDatasourceConnectionsInvoker 

type ListDatasourceConnectionsInvoker struct {
	*invoker.BaseInvoker
}

func (*ListDatasourceConnectionsInvoker) Invoke 

func (i *ListDatasourceConnectionsInvoker) Invoke() (*model.ListDatasourceConnectionsResponse, error)

type ListElasticResourcePoolQueuesInvoker 

type ListElasticResourcePoolQueuesInvoker struct {
	*invoker.BaseInvoker
}

func (*ListElasticResourcePoolQueuesInvoker) Invoke 

func (i *ListElasticResourcePoolQueuesInvoker) Invoke() (*model.ListElasticResourcePoolQueuesResponse, error)

type ListElasticResourcePoolScaleRecordsInvoker 

type ListElasticResourcePoolScaleRecordsInvoker struct {
	*invoker.BaseInvoker
}

func (*ListElasticResourcePoolScaleRecordsInvoker) Invoke 

func (i *ListElasticResourcePoolScaleRecordsInvoker) Invoke() (*model.ListElasticResourcePoolScaleRecordsResponse, error)

type ListElasticResourcePoolsInvoker 

type ListElasticResourcePoolsInvoker struct {
	*invoker.BaseInvoker
}

func (*ListElasticResourcePoolsInvoker) Invoke 

func (i *ListElasticResourcePoolsInvoker) Invoke() (*model.ListElasticResourcePoolsResponse, error)

type ListEnhancedConnectionsInvoker 

type ListEnhancedConnectionsInvoker struct {
	*invoker.BaseInvoker
}

func (*ListEnhancedConnectionsInvoker) Invoke 

func (i *ListEnhancedConnectionsInvoker) Invoke() (*model.ListEnhancedConnectionsResponse, error)

type ListFlinkJobsInvoker 

type ListFlinkJobsInvoker struct {
	*invoker.BaseInvoker
}

func (*ListFlinkJobsInvoker) Invoke 

func (i *ListFlinkJobsInvoker) Invoke() (*model.ListFlinkJobsResponse, error)

type ListFlinkTemplatesInvoker 

type ListFlinkTemplatesInvoker struct {
	*invoker.BaseInvoker
}

func (*ListFlinkTemplatesInvoker) Invoke 

func (i *ListFlinkTemplatesInvoker) Invoke() (*model.ListFlinkTemplatesResponse, error)

type ListGlobalValuesInvoker 

type ListGlobalValuesInvoker struct {
	*invoker.BaseInvoker
}

func (*ListGlobalValuesInvoker) Invoke 

func (i *ListGlobalValuesInvoker) Invoke() (*model.ListGlobalValuesResponse, error)

type ListJobTemplatesInvoker 

type ListJobTemplatesInvoker struct {
	*invoker.BaseInvoker
}

func (*ListJobTemplatesInvoker) Invoke 

func (i *ListJobTemplatesInvoker) Invoke() (*model.ListJobTemplatesResponse, error)

type ListQueuePlansInvoker 

type ListQueuePlansInvoker struct {
	*invoker.BaseInvoker
}

func (*ListQueuePlansInvoker) Invoke 

func (i *ListQueuePlansInvoker) Invoke() (*model.ListQueuePlansResponse, error)

type ListQueueUsersInvoker 

type ListQueueUsersInvoker struct {
	*invoker.BaseInvoker
}

func (*ListQueueUsersInvoker) Invoke 

func (i *ListQueueUsersInvoker) Invoke() (*model.ListQueueUsersResponse, error)

type ListQueuesInvoker 

type ListQueuesInvoker struct {
	*invoker.BaseInvoker
}

func (*ListQueuesInvoker) Invoke 

func (i *ListQueuesInvoker) Invoke() (*model.ListQueuesResponse, error)

type ListResourcesInvoker 

type ListResourcesInvoker struct {
	*invoker.BaseInvoker
}

func (*ListResourcesInvoker) Invoke 

func (i *ListResourcesInvoker) Invoke() (*model.ListResourcesResponse, error)

type ListSqlJobsInvoker 

type ListSqlJobsInvoker struct {
	*invoker.BaseInvoker
}

func (*ListSqlJobsInvoker) Invoke 

func (i *ListSqlJobsInvoker) Invoke() (*model.ListSqlJobsResponse, error)

type ListTablePrivilegesInvoker 

type ListTablePrivilegesInvoker struct {
	*invoker.BaseInvoker
}

func (*ListTablePrivilegesInvoker) Invoke 

func (i *ListTablePrivilegesInvoker) Invoke() (*model.ListTablePrivilegesResponse, error)

type ListTableUsersInvoker 

type ListTableUsersInvoker struct {
	*invoker.BaseInvoker
}

func (*ListTableUsersInvoker) Invoke 

func (i *ListTableUsersInvoker) Invoke() (*model.ListTableUsersResponse, error)

type PreviewJobResultInvoker 

type PreviewJobResultInvoker struct {
	*invoker.BaseInvoker
}

func (*PreviewJobResultInvoker) Invoke 

func (i *PreviewJobResultInvoker) Invoke() (*model.PreviewJobResultResponse, error)

type RegisterAuthorizedQueueInvoker 

type RegisterAuthorizedQueueInvoker struct {
	*invoker.BaseInvoker
}

func (*RegisterAuthorizedQueueInvoker) Invoke 

func (i *RegisterAuthorizedQueueInvoker) Invoke() (*model.RegisterAuthorizedQueueResponse, error)

type RegisterBucketInvoker 

type RegisterBucketInvoker struct {
	*invoker.BaseInvoker
}

func (*RegisterBucketInvoker) Invoke 

func (i *RegisterBucketInvoker) Invoke() (*model.RegisterBucketResponse, error)

type RunIefJobActionCallBackInvoker 

type RunIefJobActionCallBackInvoker struct {
	*invoker.BaseInvoker
}

func (*RunIefJobActionCallBackInvoker) Invoke 

func (i *RunIefJobActionCallBackInvoker) Invoke() (*model.RunIefJobActionCallBackResponse, error)

type RunQueueActionInvoker 

type RunQueueActionInvoker struct {
	*invoker.BaseInvoker
}

func (*RunQueueActionInvoker) Invoke 

func (i *RunQueueActionInvoker) Invoke() (*model.RunQueueActionResponse, error)

type ShowBatchInfoInvoker 

type ShowBatchInfoInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowBatchInfoInvoker) Invoke 

func (i *ShowBatchInfoInvoker) Invoke() (*model.ShowBatchInfoResponse, error)

type ShowBatchLogInvoker 

type ShowBatchLogInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowBatchLogInvoker) Invoke 

func (i *ShowBatchLogInvoker) Invoke() (*model.ShowBatchLogResponse, error)

type ShowBatchStateInvoker 

type ShowBatchStateInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowBatchStateInvoker) Invoke 

func (i *ShowBatchStateInvoker) Invoke() (*model.ShowBatchStateResponse, error)

type ShowDatasourceConnectionInvoker 

type ShowDatasourceConnectionInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowDatasourceConnectionInvoker) Invoke 

func (i *ShowDatasourceConnectionInvoker) Invoke() (*model.ShowDatasourceConnectionResponse, error)

type ShowDescribeTableInvoker 

type ShowDescribeTableInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowDescribeTableInvoker) Invoke 

func (i *ShowDescribeTableInvoker) Invoke() (*model.ShowDescribeTableResponse, error)

type ShowDliAgencyInvoker 

type ShowDliAgencyInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowDliAgencyInvoker) Invoke 

func (i *ShowDliAgencyInvoker) Invoke() (*model.ShowDliAgencyResponse, error)

type ShowEnhancedConnectionInvoker 

type ShowEnhancedConnectionInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowEnhancedConnectionInvoker) Invoke 

func (i *ShowEnhancedConnectionInvoker) Invoke() (*model.ShowEnhancedConnectionResponse, error)

type ShowEnhancedPrivilegeInvoker 

type ShowEnhancedPrivilegeInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowEnhancedPrivilegeInvoker) Invoke 

func (i *ShowEnhancedPrivilegeInvoker) Invoke() (*model.ShowEnhancedPrivilegeResponse, error)

type ShowFlinkExecuteGraphInvoker 

type ShowFlinkExecuteGraphInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowFlinkExecuteGraphInvoker) Invoke 

func (i *ShowFlinkExecuteGraphInvoker) Invoke() (*model.ShowFlinkExecuteGraphResponse, error)

type ShowFlinkJobInvoker 

type ShowFlinkJobInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowFlinkJobInvoker) Invoke 

func (i *ShowFlinkJobInvoker) Invoke() (*model.ShowFlinkJobResponse, error)

type ShowFlinkMetricInvoker 

type ShowFlinkMetricInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowFlinkMetricInvoker) Invoke 

func (i *ShowFlinkMetricInvoker) Invoke() (*model.ShowFlinkMetricResponse, error)

type ShowJobProgressInvoker 

type ShowJobProgressInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowJobProgressInvoker) Invoke 

func (i *ShowJobProgressInvoker) Invoke() (*model.ShowJobProgressResponse, error)

type ShowJobTemplateInvoker 

type ShowJobTemplateInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowJobTemplateInvoker) Invoke 

func (i *ShowJobTemplateInvoker) Invoke() (*model.ShowJobTemplateResponse, error)

type ShowNodeConnectivityInvoker 

type ShowNodeConnectivityInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowNodeConnectivityInvoker) Invoke 

func (i *ShowNodeConnectivityInvoker) Invoke() (*model.ShowNodeConnectivityResponse, error)

type ShowObjectUserInvoker 

type ShowObjectUserInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowObjectUserInvoker) Invoke 

func (i *ShowObjectUserInvoker) Invoke() (*model.ShowObjectUserResponse, error)

type ShowPartitionsInvoker 

type ShowPartitionsInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowPartitionsInvoker) Invoke 

func (i *ShowPartitionsInvoker) Invoke() (*model.ShowPartitionsResponse, error)

type ShowQueueDetailInvoker 

type ShowQueueDetailInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowQueueDetailInvoker) Invoke 

func (i *ShowQueueDetailInvoker) Invoke() (*model.ShowQueueDetailResponse, error)

type ShowResourceInfoInvoker 

type ShowResourceInfoInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowResourceInfoInvoker) Invoke 

func (i *ShowResourceInfoInvoker) Invoke() (*model.ShowResourceInfoResponse, error)

type ShowSqlJobDetailInvoker 

type ShowSqlJobDetailInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowSqlJobDetailInvoker) Invoke 

func (i *ShowSqlJobDetailInvoker) Invoke() (*model.ShowSqlJobDetailResponse, error)

type ShowSqlJobStatusInvoker 

type ShowSqlJobStatusInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowSqlJobStatusInvoker) Invoke 

func (i *ShowSqlJobStatusInvoker) Invoke() (*model.ShowSqlJobStatusResponse, error)

type ShowSqlSampleTemplatesInvoker 

type ShowSqlSampleTemplatesInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowSqlSampleTemplatesInvoker) Invoke 

func (i *ShowSqlSampleTemplatesInvoker) Invoke() (*model.ShowSqlSampleTemplatesResponse, error)

type ShowSqlTemplatesInvoker 

type ShowSqlTemplatesInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowSqlTemplatesInvoker) Invoke 

func (i *ShowSqlTemplatesInvoker) Invoke() (*model.ShowSqlTemplatesResponse, error)

type ShowTableContentInvoker 

type ShowTableContentInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowTableContentInvoker) Invoke 

func (i *ShowTableContentInvoker) Invoke() (*model.ShowTableContentResponse, error)

type StopFlinkJobsInvoker 

type StopFlinkJobsInvoker struct {
	*invoker.BaseInvoker
}

func (*StopFlinkJobsInvoker) Invoke 

func (i *StopFlinkJobsInvoker) Invoke() (*model.StopFlinkJobsResponse, error)

type UpdateAuthInfoInvoker 

type UpdateAuthInfoInvoker struct {
	*invoker.BaseInvoker
}

func (*UpdateAuthInfoInvoker) Invoke 

func (i *UpdateAuthInfoInvoker) Invoke() (*model.UpdateAuthInfoResponse, error)

type UpdateDatabaseOwnerInvoker 

type UpdateDatabaseOwnerInvoker struct {
	*invoker.BaseInvoker
}

func (*UpdateDatabaseOwnerInvoker) Invoke 

func (i *UpdateDatabaseOwnerInvoker) Invoke() (*model.UpdateDatabaseOwnerResponse, error)

type UpdateElasticResourcePoolInvoker 

type UpdateElasticResourcePoolInvoker struct {
	*invoker.BaseInvoker
}

func (*UpdateElasticResourcePoolInvoker) Invoke 

func (i *UpdateElasticResourcePoolInvoker) Invoke() (*model.UpdateElasticResourcePoolResponse, error)

type UpdateElasticResourcePoolQueueInfoInvoker 

type UpdateElasticResourcePoolQueueInfoInvoker struct {
	*invoker.BaseInvoker
}

func (*UpdateElasticResourcePoolQueueInfoInvoker) Invoke 

func (i *UpdateElasticResourcePoolQueueInfoInvoker) Invoke() (*model.UpdateElasticResourcePoolQueueInfoResponse, error)

type UpdateFlinkJarInvoker 

type UpdateFlinkJarInvoker struct {
	*invoker.BaseInvoker
}

func (*UpdateFlinkJarInvoker) Invoke 

func (i *UpdateFlinkJarInvoker) Invoke() (*model.UpdateFlinkJarResponse, error)

type UpdateFlinkSqlInvoker 

type UpdateFlinkSqlInvoker struct {
	*invoker.BaseInvoker
}

func (*UpdateFlinkSqlInvoker) Invoke 

func (i *UpdateFlinkSqlInvoker) Invoke() (*model.UpdateFlinkSqlResponse, error)

type UpdateFlinkTemplateInvoker 

type UpdateFlinkTemplateInvoker struct {
	*invoker.BaseInvoker
}

func (*UpdateFlinkTemplateInvoker) Invoke 

func (i *UpdateFlinkTemplateInvoker) Invoke() (*model.UpdateFlinkTemplateResponse, error)

type UpdateGlobalValueInvoker 

type UpdateGlobalValueInvoker struct {
	*invoker.BaseInvoker
}

func (*UpdateGlobalValueInvoker) Invoke 

func (i *UpdateGlobalValueInvoker) Invoke() (*model.UpdateGlobalValueResponse, error)

type UpdateGroupOrResourceOwnerInvoker 

type UpdateGroupOrResourceOwnerInvoker struct {
	*invoker.BaseInvoker
}

func (*UpdateGroupOrResourceOwnerInvoker) Invoke 

func (i *UpdateGroupOrResourceOwnerInvoker) Invoke() (*model.UpdateGroupOrResourceOwnerResponse, error)

type UpdateHostMassageInvoker 

type UpdateHostMassageInvoker struct {
	*invoker.BaseInvoker
}

func (*UpdateHostMassageInvoker) Invoke 

func (i *UpdateHostMassageInvoker) Invoke() (*model.UpdateHostMassageResponse, error)

type UpdateJobTemplatesInvoker 

type UpdateJobTemplatesInvoker struct {
	*invoker.BaseInvoker
}

func (*UpdateJobTemplatesInvoker) Invoke 

func (i *UpdateJobTemplatesInvoker) Invoke() (*model.UpdateJobTemplatesResponse, error)

type UpdateQueueCidrInvoker 

type UpdateQueueCidrInvoker struct {
	*invoker.BaseInvoker
}

func (*UpdateQueueCidrInvoker) Invoke 

func (i *UpdateQueueCidrInvoker) Invoke() (*model.UpdateQueueCidrResponse, error)

type UpdateSqlTemplatesInvoker 

type UpdateSqlTemplatesInvoker struct {
	*invoker.BaseInvoker
}

func (*UpdateSqlTemplatesInvoker) Invoke 

func (i *UpdateSqlTemplatesInvoker) Invoke() (*model.UpdateSqlTemplatesResponse, error)

type UpdateTableOwnerInvoker 

type UpdateTableOwnerInvoker struct {
	*invoker.BaseInvoker
}

func (*UpdateTableOwnerInvoker) Invoke 

func (i *UpdateTableOwnerInvoker) Invoke() (*model.UpdateTableOwnerResponse, error)

type UploadFilesInvoker 

type UploadFilesInvoker struct {
	*invoker.BaseInvoker
}

func (*UploadFilesInvoker) Invoke 

func (i *UploadFilesInvoker) Invoke() (*model.UploadFilesResponse, error)

type UploadJarsInvoker 

type UploadJarsInvoker struct {
	*invoker.BaseInvoker
}

func (*UploadJarsInvoker) Invoke 

func (i *UploadJarsInvoker) Invoke() (*model.UploadJarsResponse, error)

type UploadPythonFilesInvoker 

type UploadPythonFilesInvoker struct {
	*invoker.BaseInvoker
}

func (*UploadPythonFilesInvoker) Invoke 

func (i *UploadPythonFilesInvoker) Invoke() (*model.UploadPythonFilesResponse, error)

type UploadResourcesInvoker 

type UploadResourcesInvoker struct {
	*invoker.BaseInvoker
}

func (*UploadResourcesInvoker) Invoke 

func (i *UploadResourcesInvoker) Invoke() (*model.UploadResourcesResponse, error)

Source Files

View all Source files

Directories

Path Synopsis

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.