v1

package

Go to main page

Versions in this module

v0

v0.1.121

Nov 7, 2024

v0.1.120

Oct 31, 2024

v0.1.119

Oct 24, 2024

v0.1.118

Oct 17, 2024

Changes in this version

type AssociateQueueToElasticResourcePoolInvoker

+ func (i *AssociateQueueToElasticResourcePoolInvoker) GetBaseInvoker() *invoker.BaseInvoker

type AssociateQueueToEnhancedConnectionInvoker

+ func (i *AssociateQueueToEnhancedConnectionInvoker) GetBaseInvoker() *invoker.BaseInvoker

type BatchDeleteFlinkJobsInvoker

+ func (i *BatchDeleteFlinkJobsInvoker) GetBaseInvoker() *invoker.BaseInvoker

type BatchDeleteQueuePlansInvoker

+ func (i *BatchDeleteQueuePlansInvoker) GetBaseInvoker() *invoker.BaseInvoker

type BatchDeleteSqlJobTemplatesInvoker

+ func (i *BatchDeleteSqlJobTemplatesInvoker) GetBaseInvoker() *invoker.BaseInvoker

type BatchRunFlinkJobsInvoker

+ func (i *BatchRunFlinkJobsInvoker) GetBaseInvoker() *invoker.BaseInvoker

type BatchStopFlinkJobsInvoker

+ func (i *BatchStopFlinkJobsInvoker) GetBaseInvoker() *invoker.BaseInvoker

type CancelSparkJobInvoker

+ func (i *CancelSparkJobInvoker) GetBaseInvoker() *invoker.BaseInvoker

type CancelSqlJobInvoker

+ func (i *CancelSqlJobInvoker) GetBaseInvoker() *invoker.BaseInvoker

type CheckSqlInvoker

+ func (i *CheckSqlInvoker) GetBaseInvoker() *invoker.BaseInvoker

type CreateAuthInfoInvoker

+ func (i *CreateAuthInfoInvoker) GetBaseInvoker() *invoker.BaseInvoker

type CreateConnectivityTaskInvoker

+ func (i *CreateConnectivityTaskInvoker) GetBaseInvoker() *invoker.BaseInvoker

type CreateDatabaseInvoker

+ func (i *CreateDatabaseInvoker) GetBaseInvoker() *invoker.BaseInvoker

type CreateDatasourceConnectionInvoker

+ func (i *CreateDatasourceConnectionInvoker) GetBaseInvoker() *invoker.BaseInvoker

type CreateDliAgencyInvoker

+ func (i *CreateDliAgencyInvoker) GetBaseInvoker() *invoker.BaseInvoker

type CreateElasticResourcePoolInvoker

+ func (i *CreateElasticResourcePoolInvoker) GetBaseInvoker() *invoker.BaseInvoker

type CreateEnhancedConnectionInvoker

+ func (i *CreateEnhancedConnectionInvoker) GetBaseInvoker() *invoker.BaseInvoker

type CreateEnhancedConnectionRoutesInvoker

+ func (i *CreateEnhancedConnectionRoutesInvoker) GetBaseInvoker() *invoker.BaseInvoker

type CreateFlinkJarJobInvoker

+ func (i *CreateFlinkJarJobInvoker) GetBaseInvoker() *invoker.BaseInvoker

type CreateFlinkSqlJobGraphInvoker

+ func (i *CreateFlinkSqlJobGraphInvoker) GetBaseInvoker() *invoker.BaseInvoker

type CreateFlinkSqlJobInvoker

+ func (i *CreateFlinkSqlJobInvoker) GetBaseInvoker() *invoker.BaseInvoker

type CreateFlinkSqlJobTemplateInvoker

+ func (i *CreateFlinkSqlJobTemplateInvoker) GetBaseInvoker() *invoker.BaseInvoker

type CreateGlobalVariableInvoker

+ func (i *CreateGlobalVariableInvoker) GetBaseInvoker() *invoker.BaseInvoker

type CreateIefMessageChannelInvoker

+ func (i *CreateIefMessageChannelInvoker) GetBaseInvoker() *invoker.BaseInvoker

type CreateIefSystemEventsInvoker

+ func (i *CreateIefSystemEventsInvoker) GetBaseInvoker() *invoker.BaseInvoker

type CreateJobAuthInfoInvoker

+ func (i *CreateJobAuthInfoInvoker) GetBaseInvoker() *invoker.BaseInvoker

type CreateQueueInvoker

+ func (i *CreateQueueInvoker) GetBaseInvoker() *invoker.BaseInvoker

type CreateQueuePlanInvoker

+ func (i *CreateQueuePlanInvoker) GetBaseInvoker() *invoker.BaseInvoker

type CreateQueuePropertyInvoker

+ func (i *CreateQueuePropertyInvoker) GetBaseInvoker() *invoker.BaseInvoker

type CreateRouteToEnhancedConnectionInvoker

+ func (i *CreateRouteToEnhancedConnectionInvoker) GetBaseInvoker() *invoker.BaseInvoker

type CreateSparkJobInvoker

+ func (i *CreateSparkJobInvoker) GetBaseInvoker() *invoker.BaseInvoker

type CreateSparkJobTemplateInvoker

+ func (i *CreateSparkJobTemplateInvoker) GetBaseInvoker() *invoker.BaseInvoker

type CreateSqlJobInvoker

+ func (i *CreateSqlJobInvoker) GetBaseInvoker() *invoker.BaseInvoker

type CreateSqlJobTemplateInvoker

+ func (i *CreateSqlJobTemplateInvoker) GetBaseInvoker() *invoker.BaseInvoker

type CreateTableInvoker

+ func (i *CreateTableInvoker) GetBaseInvoker() *invoker.BaseInvoker

type DeleteAuthInfoInvoker

+ func (i *DeleteAuthInfoInvoker) GetBaseInvoker() *invoker.BaseInvoker

type DeleteDatabaseInvoker

+ func (i *DeleteDatabaseInvoker) GetBaseInvoker() *invoker.BaseInvoker

type DeleteDatasourceConnectionInvoker

+ func (i *DeleteDatasourceConnectionInvoker) GetBaseInvoker() *invoker.BaseInvoker

type DeleteElasticResourcePoolInvoker

+ func (i *DeleteElasticResourcePoolInvoker) GetBaseInvoker() *invoker.BaseInvoker

type DeleteEnhancedConnectionInvoker

+ func (i *DeleteEnhancedConnectionInvoker) GetBaseInvoker() *invoker.BaseInvoker

type DeleteEnhancedConnectionRoutesInvoker

+ func (i *DeleteEnhancedConnectionRoutesInvoker) GetBaseInvoker() *invoker.BaseInvoker

type DeleteFlinkJobInvoker

+ func (i *DeleteFlinkJobInvoker) GetBaseInvoker() *invoker.BaseInvoker

type DeleteFlinkSqlJobTemplateInvoker

+ func (i *DeleteFlinkSqlJobTemplateInvoker) GetBaseInvoker() *invoker.BaseInvoker

type DeleteGlobalVariableInvoker

+ func (i *DeleteGlobalVariableInvoker) GetBaseInvoker() *invoker.BaseInvoker

type DeleteJobAuthInfoInvoker

+ func (i *DeleteJobAuthInfoInvoker) GetBaseInvoker() *invoker.BaseInvoker

type DeleteJobResourceInvoker

+ func (i *DeleteJobResourceInvoker) GetBaseInvoker() *invoker.BaseInvoker

type DeleteQueueInvoker

+ func (i *DeleteQueueInvoker) GetBaseInvoker() *invoker.BaseInvoker

type DeleteQueuePlanInvoker

+ func (i *DeleteQueuePlanInvoker) GetBaseInvoker() *invoker.BaseInvoker

type DeleteQueuePropertyInvoker

+ func (i *DeleteQueuePropertyInvoker) GetBaseInvoker() *invoker.BaseInvoker

type DeleteRouteFromEnhancedConnectionInvoker

+ func (i *DeleteRouteFromEnhancedConnectionInvoker) GetBaseInvoker() *invoker.BaseInvoker

type DeleteTableInvoker

+ func (i *DeleteTableInvoker) GetBaseInvoker() *invoker.BaseInvoker

type DisassociateQueueFromEnhancedConnectionInvoker

+ func (i *DisassociateQueueFromEnhancedConnectionInvoker) GetBaseInvoker() *invoker.BaseInvoker

type ExecuteFlinkJobSavepointInvoker

+ func (i *ExecuteFlinkJobSavepointInvoker) GetBaseInvoker() *invoker.BaseInvoker

type ExportFlinkJobsInvoker

+ func (i *ExportFlinkJobsInvoker) GetBaseInvoker() *invoker.BaseInvoker

type ExportSqlJobResultInvoker

+ func (i *ExportSqlJobResultInvoker) GetBaseInvoker() *invoker.BaseInvoker

type ExportTableInvoker

+ func (i *ExportTableInvoker) GetBaseInvoker() *invoker.BaseInvoker

type ImportFlinkJobSavepointInvoker

+ func (i *ImportFlinkJobSavepointInvoker) GetBaseInvoker() *invoker.BaseInvoker

type ImportFlinkJobsInvoker

+ func (i *ImportFlinkJobsInvoker) GetBaseInvoker() *invoker.BaseInvoker

type ImportTableInvoker

+ func (i *ImportTableInvoker) GetBaseInvoker() *invoker.BaseInvoker

type ListAuthInfoInvoker

+ func (i *ListAuthInfoInvoker) GetBaseInvoker() *invoker.BaseInvoker

type ListAuthorizationPrivilegesInvoker

+ func (i *ListAuthorizationPrivilegesInvoker) GetBaseInvoker() *invoker.BaseInvoker

type ListCatalogsInvoker

+ func (i *ListCatalogsInvoker) GetBaseInvoker() *invoker.BaseInvoker

type ListDatabaseUsersInvoker

+ func (i *ListDatabaseUsersInvoker) GetBaseInvoker() *invoker.BaseInvoker

type ListDatabasesInvoker

+ func (i *ListDatabasesInvoker) GetBaseInvoker() *invoker.BaseInvoker

type ListDatasourceConnectionsInvoker

+ func (i *ListDatasourceConnectionsInvoker) GetBaseInvoker() *invoker.BaseInvoker

type ListElasticResourcePoolQueuesInvoker

+ func (i *ListElasticResourcePoolQueuesInvoker) GetBaseInvoker() *invoker.BaseInvoker

type ListElasticResourcePoolScaleRecordsInvoker

+ func (i *ListElasticResourcePoolScaleRecordsInvoker) GetBaseInvoker() *invoker.BaseInvoker

type ListElasticResourcePoolsInvoker

+ func (i *ListElasticResourcePoolsInvoker) GetBaseInvoker() *invoker.BaseInvoker

type ListEnhancedConnectionsInvoker

+ func (i *ListEnhancedConnectionsInvoker) GetBaseInvoker() *invoker.BaseInvoker

type ListFlinkJobsInvoker

+ func (i *ListFlinkJobsInvoker) GetBaseInvoker() *invoker.BaseInvoker

type ListFlinkSqlJobTemplatesInvoker

+ func (i *ListFlinkSqlJobTemplatesInvoker) GetBaseInvoker() *invoker.BaseInvoker

type ListGlobalVariablesInvoker

+ func (i *ListGlobalVariablesInvoker) GetBaseInvoker() *invoker.BaseInvoker

type ListJobAuthInfosInvoker

+ func (i *ListJobAuthInfosInvoker) GetBaseInvoker() *invoker.BaseInvoker

type ListJobResourcesInvoker

+ func (i *ListJobResourcesInvoker) GetBaseInvoker() *invoker.BaseInvoker

type ListPartitionsInvoker

+ func (i *ListPartitionsInvoker) GetBaseInvoker() *invoker.BaseInvoker

type ListQueuePlansInvoker

+ func (i *ListQueuePlansInvoker) GetBaseInvoker() *invoker.BaseInvoker

type ListQueuePropertiesInvoker

+ func (i *ListQueuePropertiesInvoker) GetBaseInvoker() *invoker.BaseInvoker

type ListQueueUsersInvoker

+ func (i *ListQueueUsersInvoker) GetBaseInvoker() *invoker.BaseInvoker

type ListQueuesInvoker

+ func (i *ListQueuesInvoker) GetBaseInvoker() *invoker.BaseInvoker

type ListSparkJobTemplatesInvoker

+ func (i *ListSparkJobTemplatesInvoker) GetBaseInvoker() *invoker.BaseInvoker

type ListSparkJobsInvoker

+ func (i *ListSparkJobsInvoker) GetBaseInvoker() *invoker.BaseInvoker

type ListSqlJobTemplatesInvoker

+ func (i *ListSqlJobTemplatesInvoker) GetBaseInvoker() *invoker.BaseInvoker

type ListSqlJobsInvoker

+ func (i *ListSqlJobsInvoker) GetBaseInvoker() *invoker.BaseInvoker

type ListSqlSampleTemplatesInvoker

+ func (i *ListSqlSampleTemplatesInvoker) GetBaseInvoker() *invoker.BaseInvoker

type ListTablePrivilegesInvoker

+ func (i *ListTablePrivilegesInvoker) GetBaseInvoker() *invoker.BaseInvoker

type ListTableUsersInvoker

+ func (i *ListTableUsersInvoker) GetBaseInvoker() *invoker.BaseInvoker

type ListTablesInvoker

+ func (i *ListTablesInvoker) GetBaseInvoker() *invoker.BaseInvoker

type PreviewSqlJobResultInvoker

+ func (i *PreviewSqlJobResultInvoker) GetBaseInvoker() *invoker.BaseInvoker

type PreviewTableInvoker

+ func (i *PreviewTableInvoker) GetBaseInvoker() *invoker.BaseInvoker

type RegisterAuthorizedQueueInvoker

+ func (i *RegisterAuthorizedQueueInvoker) GetBaseInvoker() *invoker.BaseInvoker

type RegisterBucketInvoker

+ func (i *RegisterBucketInvoker) GetBaseInvoker() *invoker.BaseInvoker

type RunAuthorizationActionInvoker

+ func (i *RunAuthorizationActionInvoker) GetBaseInvoker() *invoker.BaseInvoker

type RunCatalogActionInvoker

+ func (i *RunCatalogActionInvoker) GetBaseInvoker() *invoker.BaseInvoker

type RunDataAuthorizationActionInvoker

+ func (i *RunDataAuthorizationActionInvoker) GetBaseInvoker() *invoker.BaseInvoker

type RunIefJobActionCallBackInvoker

+ func (i *RunIefJobActionCallBackInvoker) GetBaseInvoker() *invoker.BaseInvoker

type RunQueueActionInvoker

+ func (i *RunQueueActionInvoker) GetBaseInvoker() *invoker.BaseInvoker

type ShowCatalogInvoker

+ func (i *ShowCatalogInvoker) GetBaseInvoker() *invoker.BaseInvoker

type ShowConnectivityTaskInvoker

+ func (i *ShowConnectivityTaskInvoker) GetBaseInvoker() *invoker.BaseInvoker

type ShowDatasourceConnectionInvoker

+ func (i *ShowDatasourceConnectionInvoker) GetBaseInvoker() *invoker.BaseInvoker

type ShowDliAgencyInvoker

+ func (i *ShowDliAgencyInvoker) GetBaseInvoker() *invoker.BaseInvoker

type ShowEnhancedConnectionInvoker

+ func (i *ShowEnhancedConnectionInvoker) GetBaseInvoker() *invoker.BaseInvoker

type ShowEnhancedConnectionPrivilegeInvoker

+ func (i *ShowEnhancedConnectionPrivilegeInvoker) GetBaseInvoker() *invoker.BaseInvoker

type ShowFlinkJobExecutionGraphInvoker

+ func (i *ShowFlinkJobExecutionGraphInvoker) GetBaseInvoker() *invoker.BaseInvoker

type ShowFlinkJobInvoker

+ func (i *ShowFlinkJobInvoker) GetBaseInvoker() *invoker.BaseInvoker

type ShowFlinkMetricInvoker

+ func (i *ShowFlinkMetricInvoker) GetBaseInvoker() *invoker.BaseInvoker

type ShowJobResourceInvoker

+ func (i *ShowJobResourceInvoker) GetBaseInvoker() *invoker.BaseInvoker

type ShowQueueInvoker

+ func (i *ShowQueueInvoker) GetBaseInvoker() *invoker.BaseInvoker

type ShowQuotaInvoker

+ func (i *ShowQuotaInvoker) GetBaseInvoker() *invoker.BaseInvoker

type ShowSparkJobInvoker

+ func (i *ShowSparkJobInvoker) GetBaseInvoker() *invoker.BaseInvoker

type ShowSparkJobLogInvoker

+ func (i *ShowSparkJobLogInvoker) GetBaseInvoker() *invoker.BaseInvoker

type ShowSparkJobStatusInvoker

+ func (i *ShowSparkJobStatusInvoker) GetBaseInvoker() *invoker.BaseInvoker

type ShowSparkJobTemplateInvoker

+ func (i *ShowSparkJobTemplateInvoker) GetBaseInvoker() *invoker.BaseInvoker

type ShowSqlJobDetailInvoker

+ func (i *ShowSqlJobDetailInvoker) GetBaseInvoker() *invoker.BaseInvoker

type ShowSqlJobProgressInvoker

+ func (i *ShowSqlJobProgressInvoker) GetBaseInvoker() *invoker.BaseInvoker

type ShowSqlJobStatusInvoker

+ func (i *ShowSqlJobStatusInvoker) GetBaseInvoker() *invoker.BaseInvoker

type ShowTableInvoker

+ func (i *ShowTableInvoker) GetBaseInvoker() *invoker.BaseInvoker

type UpdateAuthInfoInvoker

+ func (i *UpdateAuthInfoInvoker) GetBaseInvoker() *invoker.BaseInvoker

type UpdateDatabaseOwnerInvoker

+ func (i *UpdateDatabaseOwnerInvoker) GetBaseInvoker() *invoker.BaseInvoker

type UpdateElasticResourcePoolInvoker

+ func (i *UpdateElasticResourcePoolInvoker) GetBaseInvoker() *invoker.BaseInvoker

type UpdateElasticResourcePoolQueueInvoker

+ func (i *UpdateElasticResourcePoolQueueInvoker) GetBaseInvoker() *invoker.BaseInvoker

type UpdateEnhancedConnectionInvoker

+ func (i *UpdateEnhancedConnectionInvoker) GetBaseInvoker() *invoker.BaseInvoker

type UpdateFlinkJarJobInvoker

+ func (i *UpdateFlinkJarJobInvoker) GetBaseInvoker() *invoker.BaseInvoker

type UpdateFlinkJobStatusReportInvoker

+ func (i *UpdateFlinkJobStatusReportInvoker) GetBaseInvoker() *invoker.BaseInvoker

type UpdateFlinkSqlJobInvoker

+ func (i *UpdateFlinkSqlJobInvoker) GetBaseInvoker() *invoker.BaseInvoker

type UpdateFlinkSqlJobTemplateInvoker

+ func (i *UpdateFlinkSqlJobTemplateInvoker) GetBaseInvoker() *invoker.BaseInvoker

type UpdateGlobalVariableInvoker

+ func (i *UpdateGlobalVariableInvoker) GetBaseInvoker() *invoker.BaseInvoker

type UpdateJobAuthInfoInvoker

+ func (i *UpdateJobAuthInfoInvoker) GetBaseInvoker() *invoker.BaseInvoker

type UpdateJobResourceOwnerInvoker

+ func (i *UpdateJobResourceOwnerInvoker) GetBaseInvoker() *invoker.BaseInvoker

type UpdateQueueCidrInvoker

+ func (i *UpdateQueueCidrInvoker) GetBaseInvoker() *invoker.BaseInvoker

type UpdateQueuePlanInvoker

+ func (i *UpdateQueuePlanInvoker) GetBaseInvoker() *invoker.BaseInvoker

type UpdateQueuePropertyInvoker

+ func (i *UpdateQueuePropertyInvoker) GetBaseInvoker() *invoker.BaseInvoker

type UpdateSparkJobTemplateInvoker

+ func (i *UpdateSparkJobTemplateInvoker) GetBaseInvoker() *invoker.BaseInvoker

type UpdateSqlJobTemplateInvoker

+ func (i *UpdateSqlJobTemplateInvoker) GetBaseInvoker() *invoker.BaseInvoker

type UpdateTableOwnerInvoker

+ func (i *UpdateTableOwnerInvoker) GetBaseInvoker() *invoker.BaseInvoker

type UploadFileJobResourcesInvoker

+ func (i *UploadFileJobResourcesInvoker) GetBaseInvoker() *invoker.BaseInvoker

type UploadJarJobResourcesInvoker

+ func (i *UploadJarJobResourcesInvoker) GetBaseInvoker() *invoker.BaseInvoker

type UploadJobResourcesInvoker

+ func (i *UploadJobResourcesInvoker) GetBaseInvoker() *invoker.BaseInvoker

type UploadPythonFileJobResourcesInvoker

+ func (i *UploadPythonFileJobResourcesInvoker) GetBaseInvoker() *invoker.BaseInvoker

v0.1.117

Oct 10, 2024

v0.1.116

Sep 26, 2024

v0.1.115

Sep 23, 2024

v0.1.114

Sep 12, 2024

v0.1.113

Sep 5, 2024

v0.1.112

Aug 29, 2024

v0.1.111

Aug 22, 2024

v0.1.110

Aug 15, 2024

v0.1.109

Aug 8, 2024

v0.1.108

Aug 1, 2024

v0.1.107

Jul 25, 2024

v0.1.106

Jul 18, 2024

v0.1.105

Jul 11, 2024

v0.1.104

Jul 4, 2024

v0.1.103

Jun 27, 2024

v0.1.102

Jun 20, 2024

v0.1.101

Jun 14, 2024

v0.1.100

Jun 13, 2024

Changes in this version

+ func GenReqDefForCreateStreamJob() *def.HttpRequestDef

+ type CreateStreamJobInvoker struct

+ func (i *CreateStreamJobInvoker) Invoke() (*model.CreateStreamJobResponse, error)

type DliClient

+ func (c *DliClient) CreateStreamJob(request *model.CreateStreamJobRequest) (*model.CreateStreamJobResponse, error)

+ func (c *DliClient) CreateStreamJobInvoker(request *model.CreateStreamJobRequest) *CreateStreamJobInvoker

v0.1.99

Jun 6, 2024

v0.1.98

May 30, 2024

v0.1.97

May 23, 2024

v0.1.96

May 16, 2024

v0.1.95

May 9, 2024

Changes in this version

+ func GenReqDefForExecuteFlinkJobSavepoint() *def.HttpRequestDef

+ func GenReqDefForImportFlinkJobSavepoint() *def.HttpRequestDef

type DliClient

+ func (c *DliClient) ExecuteFlinkJobSavepoint(request *model.ExecuteFlinkJobSavepointRequest) (*model.ExecuteFlinkJobSavepointResponse, error)

+ func (c *DliClient) ExecuteFlinkJobSavepointInvoker(request *model.ExecuteFlinkJobSavepointRequest) *ExecuteFlinkJobSavepointInvoker

+ func (c *DliClient) ImportFlinkJobSavepoint(request *model.ImportFlinkJobSavepointRequest) (*model.ImportFlinkJobSavepointResponse, error)

+ func (c *DliClient) ImportFlinkJobSavepointInvoker(request *model.ImportFlinkJobSavepointRequest) *ImportFlinkJobSavepointInvoker

+ type ExecuteFlinkJobSavepointInvoker struct

+ func (i *ExecuteFlinkJobSavepointInvoker) Invoke() (*model.ExecuteFlinkJobSavepointResponse, error)

+ type ImportFlinkJobSavepointInvoker struct

+ func (i *ImportFlinkJobSavepointInvoker) Invoke() (*model.ImportFlinkJobSavepointResponse, error)

v0.1.94

Apr 30, 2024

v0.1.93

Apr 25, 2024

v0.1.92

Apr 18, 2024

v0.1.92-patch

Apr 23, 2024

v0.1.91

Apr 11, 2024

v0.1.90

Apr 3, 2024

v0.1.89

Apr 1, 2024

v0.1.88

Mar 28, 2024

Changes in this version

+ func GenReqDefForBatchStopFlinkJobs() *def.HttpRequestDef

+ func GenReqDefForDeleteJobResource() *def.HttpRequestDef

+ func GenReqDefForListJobResources() *def.HttpRequestDef

+ func GenReqDefForListPartitions() *def.HttpRequestDef

+ func GenReqDefForListSqlSampleTemplates() *def.HttpRequestDef

+ func GenReqDefForListTables() *def.HttpRequestDef

+ func GenReqDefForPreviewTable() *def.HttpRequestDef

+ func GenReqDefForRunDataAuthorizationAction() *def.HttpRequestDef

+ func GenReqDefForShowJobResource() *def.HttpRequestDef

+ func GenReqDefForShowSparkJobLog() *def.HttpRequestDef

+ func GenReqDefForShowTable() *def.HttpRequestDef

+ func GenReqDefForUpdateFlinkJobStatusReport() *def.HttpRequestDef

+ func GenReqDefForUpdateJobResourceOwner() *def.HttpRequestDef

+ func GenReqDefForUpdateQueuePlan() *def.HttpRequestDef

+ func GenReqDefForUploadFileJobResources() *def.HttpRequestDef

+ func GenReqDefForUploadJarJobResources() *def.HttpRequestDef

+ func GenReqDefForUploadJobResources() *def.HttpRequestDef

+ func GenReqDefForUploadPythonFileJobResources() *def.HttpRequestDef

+ type BatchStopFlinkJobsInvoker struct

+ func (i *BatchStopFlinkJobsInvoker) Invoke() (*model.BatchStopFlinkJobsResponse, error)

+ type DeleteJobResourceInvoker struct

+ func (i *DeleteJobResourceInvoker) Invoke() (*model.DeleteJobResourceResponse, error)

type DliClient

+ func (c *DliClient) BatchStopFlinkJobs(request *model.BatchStopFlinkJobsRequest) (*model.BatchStopFlinkJobsResponse, error)

+ func (c *DliClient) BatchStopFlinkJobsInvoker(request *model.BatchStopFlinkJobsRequest) *BatchStopFlinkJobsInvoker

+ func (c *DliClient) DeleteJobResource(request *model.DeleteJobResourceRequest) (*model.DeleteJobResourceResponse, error)

+ func (c *DliClient) DeleteJobResourceInvoker(request *model.DeleteJobResourceRequest) *DeleteJobResourceInvoker

+ func (c *DliClient) ListJobResources(request *model.ListJobResourcesRequest) (*model.ListJobResourcesResponse, error)

+ func (c *DliClient) ListJobResourcesInvoker(request *model.ListJobResourcesRequest) *ListJobResourcesInvoker

+ func (c *DliClient) ListPartitions(request *model.ListPartitionsRequest) (*model.ListPartitionsResponse, error)

+ func (c *DliClient) ListPartitionsInvoker(request *model.ListPartitionsRequest) *ListPartitionsInvoker

+ func (c *DliClient) ListSqlSampleTemplates(request *model.ListSqlSampleTemplatesRequest) (*model.ListSqlSampleTemplatesResponse, error)

+ func (c *DliClient) ListSqlSampleTemplatesInvoker(request *model.ListSqlSampleTemplatesRequest) *ListSqlSampleTemplatesInvoker

+ func (c *DliClient) ListTables(request *model.ListTablesRequest) (*model.ListTablesResponse, error)

+ func (c *DliClient) ListTablesInvoker(request *model.ListTablesRequest) *ListTablesInvoker

+ func (c *DliClient) PreviewTable(request *model.PreviewTableRequest) (*model.PreviewTableResponse, error)

+ func (c *DliClient) PreviewTableInvoker(request *model.PreviewTableRequest) *PreviewTableInvoker

+ func (c *DliClient) RunDataAuthorizationAction(request *model.RunDataAuthorizationActionRequest) (*model.RunDataAuthorizationActionResponse, error)

+ func (c *DliClient) RunDataAuthorizationActionInvoker(request *model.RunDataAuthorizationActionRequest) *RunDataAuthorizationActionInvoker

+ func (c *DliClient) ShowJobResource(request *model.ShowJobResourceRequest) (*model.ShowJobResourceResponse, error)

+ func (c *DliClient) ShowJobResourceInvoker(request *model.ShowJobResourceRequest) *ShowJobResourceInvoker

+ func (c *DliClient) ShowSparkJobLog(request *model.ShowSparkJobLogRequest) (*model.ShowSparkJobLogResponse, error)

+ func (c *DliClient) ShowSparkJobLogInvoker(request *model.ShowSparkJobLogRequest) *ShowSparkJobLogInvoker

+ func (c *DliClient) ShowTable(request *model.ShowTableRequest) (*model.ShowTableResponse, error)

+ func (c *DliClient) ShowTableInvoker(request *model.ShowTableRequest) *ShowTableInvoker

+ func (c *DliClient) UpdateFlinkJobStatusReport(request *model.UpdateFlinkJobStatusReportRequest) (*model.UpdateFlinkJobStatusReportResponse, error)

+ func (c *DliClient) UpdateFlinkJobStatusReportInvoker(request *model.UpdateFlinkJobStatusReportRequest) *UpdateFlinkJobStatusReportInvoker

+ func (c *DliClient) UpdateJobResourceOwner(request *model.UpdateJobResourceOwnerRequest) (*model.UpdateJobResourceOwnerResponse, error)

+ func (c *DliClient) UpdateJobResourceOwnerInvoker(request *model.UpdateJobResourceOwnerRequest) *UpdateJobResourceOwnerInvoker

+ func (c *DliClient) UpdateQueuePlan(request *model.UpdateQueuePlanRequest) (*model.UpdateQueuePlanResponse, error)

+ func (c *DliClient) UpdateQueuePlanInvoker(request *model.UpdateQueuePlanRequest) *UpdateQueuePlanInvoker

+ func (c *DliClient) UploadFileJobResources(request *model.UploadFileJobResourcesRequest) (*model.UploadFileJobResourcesResponse, error)

+ func (c *DliClient) UploadFileJobResourcesInvoker(request *model.UploadFileJobResourcesRequest) *UploadFileJobResourcesInvoker

+ func (c *DliClient) UploadJarJobResources(request *model.UploadJarJobResourcesRequest) (*model.UploadJarJobResourcesResponse, error)

+ func (c *DliClient) UploadJarJobResourcesInvoker(request *model.UploadJarJobResourcesRequest) *UploadJarJobResourcesInvoker

+ func (c *DliClient) UploadJobResources(request *model.UploadJobResourcesRequest) (*model.UploadJobResourcesResponse, error)

+ func (c *DliClient) UploadJobResourcesInvoker(request *model.UploadJobResourcesRequest) *UploadJobResourcesInvoker

+ func (c *DliClient) UploadPythonFileJobResources(request *model.UploadPythonFileJobResourcesRequest) (*model.UploadPythonFileJobResourcesResponse, error)

+ func (c *DliClient) UploadPythonFileJobResourcesInvoker(request *model.UploadPythonFileJobResourcesRequest) *UploadPythonFileJobResourcesInvoker

+ type ListJobResourcesInvoker struct

+ func (i *ListJobResourcesInvoker) Invoke() (*model.ListJobResourcesResponse, error)

+ type ListPartitionsInvoker struct

+ func (i *ListPartitionsInvoker) Invoke() (*model.ListPartitionsResponse, error)

+ type ListSqlSampleTemplatesInvoker struct

+ func (i *ListSqlSampleTemplatesInvoker) Invoke() (*model.ListSqlSampleTemplatesResponse, error)

+ type ListTablesInvoker struct

+ func (i *ListTablesInvoker) Invoke() (*model.ListTablesResponse, error)

+ type PreviewTableInvoker struct

+ func (i *PreviewTableInvoker) Invoke() (*model.PreviewTableResponse, error)

+ type RunDataAuthorizationActionInvoker struct

+ func (i *RunDataAuthorizationActionInvoker) Invoke() (*model.RunDataAuthorizationActionResponse, error)

+ type ShowJobResourceInvoker struct

+ func (i *ShowJobResourceInvoker) Invoke() (*model.ShowJobResourceResponse, error)

+ type ShowSparkJobLogInvoker struct

+ func (i *ShowSparkJobLogInvoker) Invoke() (*model.ShowSparkJobLogResponse, error)

+ type ShowTableInvoker struct

+ func (i *ShowTableInvoker) Invoke() (*model.ShowTableResponse, error)

+ type UpdateFlinkJobStatusReportInvoker struct

+ func (i *UpdateFlinkJobStatusReportInvoker) Invoke() (*model.UpdateFlinkJobStatusReportResponse, error)

+ type UpdateJobResourceOwnerInvoker struct

+ func (i *UpdateJobResourceOwnerInvoker) Invoke() (*model.UpdateJobResourceOwnerResponse, error)

+ type UpdateQueuePlanInvoker struct

+ func (i *UpdateQueuePlanInvoker) Invoke() (*model.UpdateQueuePlanResponse, error)

+ type UploadFileJobResourcesInvoker struct

+ func (i *UploadFileJobResourcesInvoker) Invoke() (*model.UploadFileJobResourcesResponse, error)

+ type UploadJarJobResourcesInvoker struct

+ func (i *UploadJarJobResourcesInvoker) Invoke() (*model.UploadJarJobResourcesResponse, error)

+ type UploadJobResourcesInvoker struct

+ func (i *UploadJobResourcesInvoker) Invoke() (*model.UploadJobResourcesResponse, error)

+ type UploadPythonFileJobResourcesInvoker struct

+ func (i *UploadPythonFileJobResourcesInvoker) Invoke() (*model.UploadPythonFileJobResourcesResponse, error)

v0.1.87

Mar 21, 2024

Changes in this version

+ func GenReqDefForListCatalogs() *def.HttpRequestDef

+ func GenReqDefForRunCatalogAction() *def.HttpRequestDef

+ func GenReqDefForShowCatalog() *def.HttpRequestDef

type DliClient

+ func (c *DliClient) ListCatalogs(request *model.ListCatalogsRequest) (*model.ListCatalogsResponse, error)

+ func (c *DliClient) ListCatalogsInvoker(request *model.ListCatalogsRequest) *ListCatalogsInvoker

+ func (c *DliClient) RunCatalogAction(request *model.RunCatalogActionRequest) (*model.RunCatalogActionResponse, error)

+ func (c *DliClient) RunCatalogActionInvoker(request *model.RunCatalogActionRequest) *RunCatalogActionInvoker

+ func (c *DliClient) ShowCatalog(request *model.ShowCatalogRequest) (*model.ShowCatalogResponse, error)

+ func (c *DliClient) ShowCatalogInvoker(request *model.ShowCatalogRequest) *ShowCatalogInvoker

+ type ListCatalogsInvoker struct

+ func (i *ListCatalogsInvoker) Invoke() (*model.ListCatalogsResponse, error)

+ type RunCatalogActionInvoker struct

+ func (i *RunCatalogActionInvoker) Invoke() (*model.RunCatalogActionResponse, error)

+ type ShowCatalogInvoker struct

+ func (i *ShowCatalogInvoker) Invoke() (*model.ShowCatalogResponse, error)

v0.1.86

Mar 14, 2024

v0.1.85

Mar 7, 2024

v0.1.84

Feb 29, 2024

v0.1.83

Feb 22, 2024

v0.1.82

Feb 20, 2024

v0.1.81

Feb 7, 2024

v0.1.80

Feb 1, 2024

v0.1.79

Jan 25, 2024

v0.1.78

Jan 18, 2024

v0.1.77

Jan 11, 2024

v0.1.76

Jan 4, 2024

v0.1.75

Dec 27, 2023

v0.1.74

Dec 22, 2023

v0.1.73

Dec 21, 2023

v0.1.72

Dec 14, 2023

Changes in this version

+ func GenReqDefForCreateRouteToEnhancedConnection() *def.HttpRequestDef

+ func GenReqDefForDeleteRouteFromEnhancedConnection() *def.HttpRequestDef

+ type CreateRouteToEnhancedConnectionInvoker struct

+ func (i *CreateRouteToEnhancedConnectionInvoker) Invoke() (*model.CreateRouteToEnhancedConnectionResponse, error)

+ type DeleteRouteFromEnhancedConnectionInvoker struct

+ func (i *DeleteRouteFromEnhancedConnectionInvoker) Invoke() (*model.DeleteRouteFromEnhancedConnectionResponse, error)

type DliClient

+ func (c *DliClient) CreateRouteToEnhancedConnection(request *model.CreateRouteToEnhancedConnectionRequest) (*model.CreateRouteToEnhancedConnectionResponse, error)

+ func (c *DliClient) CreateRouteToEnhancedConnectionInvoker(request *model.CreateRouteToEnhancedConnectionRequest) *CreateRouteToEnhancedConnectionInvoker

+ func (c *DliClient) DeleteRouteFromEnhancedConnection(request *model.DeleteRouteFromEnhancedConnectionRequest) (*model.DeleteRouteFromEnhancedConnectionResponse, error)

+ func (c *DliClient) DeleteRouteFromEnhancedConnectionInvoker(request *model.DeleteRouteFromEnhancedConnectionRequest) *DeleteRouteFromEnhancedConnectionInvoker

v0.1.71

Dec 7, 2023

Changes in this version

+ func GenReqDefForCreateJobAuthInfo() *def.HttpRequestDef

+ func GenReqDefForDeleteJobAuthInfo() *def.HttpRequestDef

+ func GenReqDefForListJobAuthInfos() *def.HttpRequestDef

+ func GenReqDefForUpdateJobAuthInfo() *def.HttpRequestDef

+ type CreateJobAuthInfoInvoker struct

+ func (i *CreateJobAuthInfoInvoker) Invoke() (*model.CreateJobAuthInfoResponse, error)

+ type DeleteJobAuthInfoInvoker struct

+ func (i *DeleteJobAuthInfoInvoker) Invoke() (*model.DeleteJobAuthInfoResponse, error)

type DliClient

+ func (c *DliClient) CreateJobAuthInfo(request *model.CreateJobAuthInfoRequest) (*model.CreateJobAuthInfoResponse, error)

+ func (c *DliClient) CreateJobAuthInfoInvoker(request *model.CreateJobAuthInfoRequest) *CreateJobAuthInfoInvoker

+ func (c *DliClient) DeleteJobAuthInfo(request *model.DeleteJobAuthInfoRequest) (*model.DeleteJobAuthInfoResponse, error)

+ func (c *DliClient) DeleteJobAuthInfoInvoker(request *model.DeleteJobAuthInfoRequest) *DeleteJobAuthInfoInvoker

+ func (c *DliClient) ListJobAuthInfos(request *model.ListJobAuthInfosRequest) (*model.ListJobAuthInfosResponse, error)

+ func (c *DliClient) ListJobAuthInfosInvoker(request *model.ListJobAuthInfosRequest) *ListJobAuthInfosInvoker

+ func (c *DliClient) UpdateJobAuthInfo(request *model.UpdateJobAuthInfoRequest) (*model.UpdateJobAuthInfoResponse, error)

+ func (c *DliClient) UpdateJobAuthInfoInvoker(request *model.UpdateJobAuthInfoRequest) *UpdateJobAuthInfoInvoker

+ type ListJobAuthInfosInvoker struct

+ func (i *ListJobAuthInfosInvoker) Invoke() (*model.ListJobAuthInfosResponse, error)

+ type UpdateJobAuthInfoInvoker struct

+ func (i *UpdateJobAuthInfoInvoker) Invoke() (*model.UpdateJobAuthInfoResponse, error)

v0.1.70

Nov 30, 2023

Changes in this version

+ func GenReqDefForShowQuota() *def.HttpRequestDef

type DliClient

+ func (c *DliClient) ShowQuota(request *model.ShowQuotaRequest) (*model.ShowQuotaResponse, error)

+ func (c *DliClient) ShowQuotaInvoker(request *model.ShowQuotaRequest) *ShowQuotaInvoker

+ type ShowQuotaInvoker struct

+ func (i *ShowQuotaInvoker) Invoke() (*model.ShowQuotaResponse, error)

v0.1.69

Nov 23, 2023

v0.1.68

Nov 23, 2023

Changes in this version

+ func GenReqDefForAssociateQueueToEnhancedConnection() *def.HttpRequestDef

+ func GenReqDefForBatchDeleteSqlJobTemplates() *def.HttpRequestDef

+ func GenReqDefForCancelSparkJob() *def.HttpRequestDef

+ func GenReqDefForCreateConnectivityTask() *def.HttpRequestDef

+ func GenReqDefForCreateFlinkJarJob() *def.HttpRequestDef

+ func GenReqDefForCreateFlinkSqlJobGraph() *def.HttpRequestDef

+ func GenReqDefForCreateFlinkSqlJobTemplate() *def.HttpRequestDef

+ func GenReqDefForCreateGlobalVariable() *def.HttpRequestDef

+ func GenReqDefForCreateSparkJob() *def.HttpRequestDef

+ func GenReqDefForCreateSparkJobTemplate() *def.HttpRequestDef

+ func GenReqDefForCreateSqlJobTemplate() *def.HttpRequestDef

+ func GenReqDefForDeleteFlinkSqlJobTemplate() *def.HttpRequestDef

+ func GenReqDefForDeleteGlobalVariable() *def.HttpRequestDef

+ func GenReqDefForDisassociateQueueFromEnhancedConnection() *def.HttpRequestDef

+ func GenReqDefForExportFlinkJobs() *def.HttpRequestDef

+ func GenReqDefForImportFlinkJobs() *def.HttpRequestDef

+ func GenReqDefForListAuthorizationPrivileges() *def.HttpRequestDef

+ func GenReqDefForListFlinkSqlJobTemplates() *def.HttpRequestDef

+ func GenReqDefForListGlobalVariables() *def.HttpRequestDef

+ func GenReqDefForListQueueProperties() *def.HttpRequestDef

+ func GenReqDefForListSparkJobTemplates() *def.HttpRequestDef

+ func GenReqDefForListSparkJobs() *def.HttpRequestDef

+ func GenReqDefForListSqlJobTemplates() *def.HttpRequestDef

+ func GenReqDefForPreviewSqlJobResult() *def.HttpRequestDef

+ func GenReqDefForRunAuthorizationAction() *def.HttpRequestDef

+ func GenReqDefForShowConnectivityTask() *def.HttpRequestDef

+ func GenReqDefForShowEnhancedConnectionPrivilege() *def.HttpRequestDef

+ func GenReqDefForShowFlinkJobExecutionGraph() *def.HttpRequestDef

+ func GenReqDefForShowQueue() *def.HttpRequestDef

+ func GenReqDefForShowSparkJob() *def.HttpRequestDef

+ func GenReqDefForShowSparkJobStatus() *def.HttpRequestDef

+ func GenReqDefForShowSparkJobTemplate() *def.HttpRequestDef

+ func GenReqDefForShowSqlJobProgress() *def.HttpRequestDef

+ func GenReqDefForUpdateElasticResourcePoolQueue() *def.HttpRequestDef

+ func GenReqDefForUpdateEnhancedConnection() *def.HttpRequestDef

+ func GenReqDefForUpdateFlinkJarJob() *def.HttpRequestDef

+ func GenReqDefForUpdateFlinkSqlJob() *def.HttpRequestDef

+ func GenReqDefForUpdateFlinkSqlJobTemplate() *def.HttpRequestDef

+ func GenReqDefForUpdateGlobalVariable() *def.HttpRequestDef

+ func GenReqDefForUpdateSparkJobTemplate() *def.HttpRequestDef

+ func GenReqDefForUpdateSqlJobTemplate() *def.HttpRequestDef

+ type AssociateQueueToEnhancedConnectionInvoker struct

+ func (i *AssociateQueueToEnhancedConnectionInvoker) Invoke() (*model.AssociateQueueToEnhancedConnectionResponse, error)

+ type BatchDeleteSqlJobTemplatesInvoker struct

+ func (i *BatchDeleteSqlJobTemplatesInvoker) Invoke() (*model.BatchDeleteSqlJobTemplatesResponse, error)

+ type CancelSparkJobInvoker struct

+ func (i *CancelSparkJobInvoker) Invoke() (*model.CancelSparkJobResponse, error)

+ type CreateConnectivityTaskInvoker struct

+ func (i *CreateConnectivityTaskInvoker) Invoke() (*model.CreateConnectivityTaskResponse, error)

+ type CreateFlinkJarJobInvoker struct

+ func (i *CreateFlinkJarJobInvoker) Invoke() (*model.CreateFlinkJarJobResponse, error)

+ type CreateFlinkSqlJobGraphInvoker struct

+ func (i *CreateFlinkSqlJobGraphInvoker) Invoke() (*model.CreateFlinkSqlJobGraphResponse, error)

+ type CreateFlinkSqlJobTemplateInvoker struct

+ func (i *CreateFlinkSqlJobTemplateInvoker) Invoke() (*model.CreateFlinkSqlJobTemplateResponse, error)

+ type CreateGlobalVariableInvoker struct

+ func (i *CreateGlobalVariableInvoker) Invoke() (*model.CreateGlobalVariableResponse, error)

+ type CreateSparkJobInvoker struct

+ func (i *CreateSparkJobInvoker) Invoke() (*model.CreateSparkJobResponse, error)

+ type CreateSparkJobTemplateInvoker struct

+ func (i *CreateSparkJobTemplateInvoker) Invoke() (*model.CreateSparkJobTemplateResponse, error)

+ type CreateSqlJobTemplateInvoker struct

+ func (i *CreateSqlJobTemplateInvoker) Invoke() (*model.CreateSqlJobTemplateResponse, error)

+ type DeleteFlinkSqlJobTemplateInvoker struct

+ func (i *DeleteFlinkSqlJobTemplateInvoker) Invoke() (*model.DeleteFlinkSqlJobTemplateResponse, error)

+ type DeleteGlobalVariableInvoker struct

+ func (i *DeleteGlobalVariableInvoker) Invoke() (*model.DeleteGlobalVariableResponse, error)

+ type DisassociateQueueFromEnhancedConnectionInvoker struct

+ func (i *DisassociateQueueFromEnhancedConnectionInvoker) Invoke() (*model.DisassociateQueueFromEnhancedConnectionResponse, error)

type DliClient

+ func (c *DliClient) AssociateQueueToEnhancedConnection(request *model.AssociateQueueToEnhancedConnectionRequest) (*model.AssociateQueueToEnhancedConnectionResponse, error)

+ func (c *DliClient) AssociateQueueToEnhancedConnectionInvoker(request *model.AssociateQueueToEnhancedConnectionRequest) *AssociateQueueToEnhancedConnectionInvoker

+ func (c *DliClient) BatchDeleteSqlJobTemplates(request *model.BatchDeleteSqlJobTemplatesRequest) (*model.BatchDeleteSqlJobTemplatesResponse, error)

+ func (c *DliClient) BatchDeleteSqlJobTemplatesInvoker(request *model.BatchDeleteSqlJobTemplatesRequest) *BatchDeleteSqlJobTemplatesInvoker

+ func (c *DliClient) CancelSparkJob(request *model.CancelSparkJobRequest) (*model.CancelSparkJobResponse, error)

+ func (c *DliClient) CancelSparkJobInvoker(request *model.CancelSparkJobRequest) *CancelSparkJobInvoker

+ func (c *DliClient) CreateConnectivityTask(request *model.CreateConnectivityTaskRequest) (*model.CreateConnectivityTaskResponse, error)

+ func (c *DliClient) CreateConnectivityTaskInvoker(request *model.CreateConnectivityTaskRequest) *CreateConnectivityTaskInvoker

+ func (c *DliClient) CreateFlinkJarJob(request *model.CreateFlinkJarJobRequest) (*model.CreateFlinkJarJobResponse, error)

+ func (c *DliClient) CreateFlinkJarJobInvoker(request *model.CreateFlinkJarJobRequest) *CreateFlinkJarJobInvoker

+ func (c *DliClient) CreateFlinkSqlJobGraph(request *model.CreateFlinkSqlJobGraphRequest) (*model.CreateFlinkSqlJobGraphResponse, error)

+ func (c *DliClient) CreateFlinkSqlJobGraphInvoker(request *model.CreateFlinkSqlJobGraphRequest) *CreateFlinkSqlJobGraphInvoker

+ func (c *DliClient) CreateFlinkSqlJobTemplate(request *model.CreateFlinkSqlJobTemplateRequest) (*model.CreateFlinkSqlJobTemplateResponse, error)

+ func (c *DliClient) CreateFlinkSqlJobTemplateInvoker(request *model.CreateFlinkSqlJobTemplateRequest) *CreateFlinkSqlJobTemplateInvoker

+ func (c *DliClient) CreateGlobalVariable(request *model.CreateGlobalVariableRequest) (*model.CreateGlobalVariableResponse, error)

+ func (c *DliClient) CreateGlobalVariableInvoker(request *model.CreateGlobalVariableRequest) *CreateGlobalVariableInvoker

+ func (c *DliClient) CreateSparkJob(request *model.CreateSparkJobRequest) (*model.CreateSparkJobResponse, error)

+ func (c *DliClient) CreateSparkJobInvoker(request *model.CreateSparkJobRequest) *CreateSparkJobInvoker

+ func (c *DliClient) CreateSparkJobTemplate(request *model.CreateSparkJobTemplateRequest) (*model.CreateSparkJobTemplateResponse, error)

+ func (c *DliClient) CreateSparkJobTemplateInvoker(request *model.CreateSparkJobTemplateRequest) *CreateSparkJobTemplateInvoker

+ func (c *DliClient) CreateSqlJobTemplate(request *model.CreateSqlJobTemplateRequest) (*model.CreateSqlJobTemplateResponse, error)

+ func (c *DliClient) CreateSqlJobTemplateInvoker(request *model.CreateSqlJobTemplateRequest) *CreateSqlJobTemplateInvoker

+ func (c *DliClient) DeleteFlinkSqlJobTemplate(request *model.DeleteFlinkSqlJobTemplateRequest) (*model.DeleteFlinkSqlJobTemplateResponse, error)

+ func (c *DliClient) DeleteFlinkSqlJobTemplateInvoker(request *model.DeleteFlinkSqlJobTemplateRequest) *DeleteFlinkSqlJobTemplateInvoker

+ func (c *DliClient) DeleteGlobalVariable(request *model.DeleteGlobalVariableRequest) (*model.DeleteGlobalVariableResponse, error)

+ func (c *DliClient) DeleteGlobalVariableInvoker(request *model.DeleteGlobalVariableRequest) *DeleteGlobalVariableInvoker

+ func (c *DliClient) DisassociateQueueFromEnhancedConnection(request *model.DisassociateQueueFromEnhancedConnectionRequest) (*model.DisassociateQueueFromEnhancedConnectionResponse, error)

+ func (c *DliClient) DisassociateQueueFromEnhancedConnectionInvoker(request *model.DisassociateQueueFromEnhancedConnectionRequest) *DisassociateQueueFromEnhancedConnectionInvoker

+ func (c *DliClient) ExportFlinkJobs(request *model.ExportFlinkJobsRequest) (*model.ExportFlinkJobsResponse, error)

+ func (c *DliClient) ExportFlinkJobsInvoker(request *model.ExportFlinkJobsRequest) *ExportFlinkJobsInvoker

+ func (c *DliClient) ImportFlinkJobs(request *model.ImportFlinkJobsRequest) (*model.ImportFlinkJobsResponse, error)

+ func (c *DliClient) ImportFlinkJobsInvoker(request *model.ImportFlinkJobsRequest) *ImportFlinkJobsInvoker

+ func (c *DliClient) ListAuthorizationPrivileges(request *model.ListAuthorizationPrivilegesRequest) (*model.ListAuthorizationPrivilegesResponse, error)

+ func (c *DliClient) ListAuthorizationPrivilegesInvoker(request *model.ListAuthorizationPrivilegesRequest) *ListAuthorizationPrivilegesInvoker

+ func (c *DliClient) ListFlinkSqlJobTemplates(request *model.ListFlinkSqlJobTemplatesRequest) (*model.ListFlinkSqlJobTemplatesResponse, error)

+ func (c *DliClient) ListFlinkSqlJobTemplatesInvoker(request *model.ListFlinkSqlJobTemplatesRequest) *ListFlinkSqlJobTemplatesInvoker

+ func (c *DliClient) ListGlobalVariables(request *model.ListGlobalVariablesRequest) (*model.ListGlobalVariablesResponse, error)

+ func (c *DliClient) ListGlobalVariablesInvoker(request *model.ListGlobalVariablesRequest) *ListGlobalVariablesInvoker

+ func (c *DliClient) ListQueueProperties(request *model.ListQueuePropertiesRequest) (*model.ListQueuePropertiesResponse, error)

+ func (c *DliClient) ListQueuePropertiesInvoker(request *model.ListQueuePropertiesRequest) *ListQueuePropertiesInvoker

+ func (c *DliClient) ListSparkJobTemplates(request *model.ListSparkJobTemplatesRequest) (*model.ListSparkJobTemplatesResponse, error)

+ func (c *DliClient) ListSparkJobTemplatesInvoker(request *model.ListSparkJobTemplatesRequest) *ListSparkJobTemplatesInvoker

+ func (c *DliClient) ListSparkJobs(request *model.ListSparkJobsRequest) (*model.ListSparkJobsResponse, error)

+ func (c *DliClient) ListSparkJobsInvoker(request *model.ListSparkJobsRequest) *ListSparkJobsInvoker

+ func (c *DliClient) ListSqlJobTemplates(request *model.ListSqlJobTemplatesRequest) (*model.ListSqlJobTemplatesResponse, error)

+ func (c *DliClient) ListSqlJobTemplatesInvoker(request *model.ListSqlJobTemplatesRequest) *ListSqlJobTemplatesInvoker

+ func (c *DliClient) PreviewSqlJobResult(request *model.PreviewSqlJobResultRequest) (*model.PreviewSqlJobResultResponse, error)

+ func (c *DliClient) PreviewSqlJobResultInvoker(request *model.PreviewSqlJobResultRequest) *PreviewSqlJobResultInvoker

+ func (c *DliClient) RunAuthorizationAction(request *model.RunAuthorizationActionRequest) (*model.RunAuthorizationActionResponse, error)

+ func (c *DliClient) RunAuthorizationActionInvoker(request *model.RunAuthorizationActionRequest) *RunAuthorizationActionInvoker

+ func (c *DliClient) ShowConnectivityTask(request *model.ShowConnectivityTaskRequest) (*model.ShowConnectivityTaskResponse, error)

+ func (c *DliClient) ShowConnectivityTaskInvoker(request *model.ShowConnectivityTaskRequest) *ShowConnectivityTaskInvoker

+ func (c *DliClient) ShowEnhancedConnectionPrivilege(request *model.ShowEnhancedConnectionPrivilegeRequest) (*model.ShowEnhancedConnectionPrivilegeResponse, error)

+ func (c *DliClient) ShowEnhancedConnectionPrivilegeInvoker(request *model.ShowEnhancedConnectionPrivilegeRequest) *ShowEnhancedConnectionPrivilegeInvoker

+ func (c *DliClient) ShowFlinkJobExecutionGraph(request *model.ShowFlinkJobExecutionGraphRequest) (*model.ShowFlinkJobExecutionGraphResponse, error)

+ func (c *DliClient) ShowFlinkJobExecutionGraphInvoker(request *model.ShowFlinkJobExecutionGraphRequest) *ShowFlinkJobExecutionGraphInvoker

+ func (c *DliClient) ShowQueue(request *model.ShowQueueRequest) (*model.ShowQueueResponse, error)

+ func (c *DliClient) ShowQueueInvoker(request *model.ShowQueueRequest) *ShowQueueInvoker

+ func (c *DliClient) ShowSparkJob(request *model.ShowSparkJobRequest) (*model.ShowSparkJobResponse, error)

+ func (c *DliClient) ShowSparkJobInvoker(request *model.ShowSparkJobRequest) *ShowSparkJobInvoker

+ func (c *DliClient) ShowSparkJobStatus(request *model.ShowSparkJobStatusRequest) (*model.ShowSparkJobStatusResponse, error)

+ func (c *DliClient) ShowSparkJobStatusInvoker(request *model.ShowSparkJobStatusRequest) *ShowSparkJobStatusInvoker

+ func (c *DliClient) ShowSparkJobTemplate(request *model.ShowSparkJobTemplateRequest) (*model.ShowSparkJobTemplateResponse, error)

+ func (c *DliClient) ShowSparkJobTemplateInvoker(request *model.ShowSparkJobTemplateRequest) *ShowSparkJobTemplateInvoker

+ func (c *DliClient) ShowSqlJobProgress(request *model.ShowSqlJobProgressRequest) (*model.ShowSqlJobProgressResponse, error)

+ func (c *DliClient) ShowSqlJobProgressInvoker(request *model.ShowSqlJobProgressRequest) *ShowSqlJobProgressInvoker

+ func (c *DliClient) UpdateElasticResourcePoolQueue(request *model.UpdateElasticResourcePoolQueueRequest) (*model.UpdateElasticResourcePoolQueueResponse, error)

+ func (c *DliClient) UpdateElasticResourcePoolQueueInvoker(request *model.UpdateElasticResourcePoolQueueRequest) *UpdateElasticResourcePoolQueueInvoker

+ func (c *DliClient) UpdateEnhancedConnection(request *model.UpdateEnhancedConnectionRequest) (*model.UpdateEnhancedConnectionResponse, error)

+ func (c *DliClient) UpdateEnhancedConnectionInvoker(request *model.UpdateEnhancedConnectionRequest) *UpdateEnhancedConnectionInvoker

+ func (c *DliClient) UpdateFlinkJarJob(request *model.UpdateFlinkJarJobRequest) (*model.UpdateFlinkJarJobResponse, error)

+ func (c *DliClient) UpdateFlinkJarJobInvoker(request *model.UpdateFlinkJarJobRequest) *UpdateFlinkJarJobInvoker

+ func (c *DliClient) UpdateFlinkSqlJob(request *model.UpdateFlinkSqlJobRequest) (*model.UpdateFlinkSqlJobResponse, error)

+ func (c *DliClient) UpdateFlinkSqlJobInvoker(request *model.UpdateFlinkSqlJobRequest) *UpdateFlinkSqlJobInvoker

+ func (c *DliClient) UpdateFlinkSqlJobTemplate(request *model.UpdateFlinkSqlJobTemplateRequest) (*model.UpdateFlinkSqlJobTemplateResponse, error)

+ func (c *DliClient) UpdateFlinkSqlJobTemplateInvoker(request *model.UpdateFlinkSqlJobTemplateRequest) *UpdateFlinkSqlJobTemplateInvoker

+ func (c *DliClient) UpdateGlobalVariable(request *model.UpdateGlobalVariableRequest) (*model.UpdateGlobalVariableResponse, error)

+ func (c *DliClient) UpdateGlobalVariableInvoker(request *model.UpdateGlobalVariableRequest) *UpdateGlobalVariableInvoker

+ func (c *DliClient) UpdateSparkJobTemplate(request *model.UpdateSparkJobTemplateRequest) (*model.UpdateSparkJobTemplateResponse, error)

+ func (c *DliClient) UpdateSparkJobTemplateInvoker(request *model.UpdateSparkJobTemplateRequest) *UpdateSparkJobTemplateInvoker

+ func (c *DliClient) UpdateSqlJobTemplate(request *model.UpdateSqlJobTemplateRequest) (*model.UpdateSqlJobTemplateResponse, error)

+ func (c *DliClient) UpdateSqlJobTemplateInvoker(request *model.UpdateSqlJobTemplateRequest) *UpdateSqlJobTemplateInvoker

+ type ExportFlinkJobsInvoker struct

+ func (i *ExportFlinkJobsInvoker) Invoke() (*model.ExportFlinkJobsResponse, error)

+ type ImportFlinkJobsInvoker struct

+ func (i *ImportFlinkJobsInvoker) Invoke() (*model.ImportFlinkJobsResponse, error)

+ type ListAuthorizationPrivilegesInvoker struct

+ func (i *ListAuthorizationPrivilegesInvoker) Invoke() (*model.ListAuthorizationPrivilegesResponse, error)

+ type ListFlinkSqlJobTemplatesInvoker struct

+ func (i *ListFlinkSqlJobTemplatesInvoker) Invoke() (*model.ListFlinkSqlJobTemplatesResponse, error)

+ type ListGlobalVariablesInvoker struct

+ func (i *ListGlobalVariablesInvoker) Invoke() (*model.ListGlobalVariablesResponse, error)

+ type ListQueuePropertiesInvoker struct

+ func (i *ListQueuePropertiesInvoker) Invoke() (*model.ListQueuePropertiesResponse, error)

+ type ListSparkJobTemplatesInvoker struct

+ func (i *ListSparkJobTemplatesInvoker) Invoke() (*model.ListSparkJobTemplatesResponse, error)

+ type ListSparkJobsInvoker struct

+ func (i *ListSparkJobsInvoker) Invoke() (*model.ListSparkJobsResponse, error)

+ type ListSqlJobTemplatesInvoker struct

+ func (i *ListSqlJobTemplatesInvoker) Invoke() (*model.ListSqlJobTemplatesResponse, error)

+ type PreviewSqlJobResultInvoker struct

+ func (i *PreviewSqlJobResultInvoker) Invoke() (*model.PreviewSqlJobResultResponse, error)

+ type RunAuthorizationActionInvoker struct

+ func (i *RunAuthorizationActionInvoker) Invoke() (*model.RunAuthorizationActionResponse, error)

+ type ShowConnectivityTaskInvoker struct

+ func (i *ShowConnectivityTaskInvoker) Invoke() (*model.ShowConnectivityTaskResponse, error)

+ type ShowEnhancedConnectionPrivilegeInvoker struct

+ func (i *ShowEnhancedConnectionPrivilegeInvoker) Invoke() (*model.ShowEnhancedConnectionPrivilegeResponse, error)

+ type ShowFlinkJobExecutionGraphInvoker struct

+ func (i *ShowFlinkJobExecutionGraphInvoker) Invoke() (*model.ShowFlinkJobExecutionGraphResponse, error)

+ type ShowQueueInvoker struct

+ func (i *ShowQueueInvoker) Invoke() (*model.ShowQueueResponse, error)

+ type ShowSparkJobInvoker struct

+ func (i *ShowSparkJobInvoker) Invoke() (*model.ShowSparkJobResponse, error)

+ type ShowSparkJobStatusInvoker struct

+ func (i *ShowSparkJobStatusInvoker) Invoke() (*model.ShowSparkJobStatusResponse, error)

+ type ShowSparkJobTemplateInvoker struct

+ func (i *ShowSparkJobTemplateInvoker) Invoke() (*model.ShowSparkJobTemplateResponse, error)

+ type ShowSqlJobProgressInvoker struct

+ func (i *ShowSqlJobProgressInvoker) Invoke() (*model.ShowSqlJobProgressResponse, error)

+ type UpdateElasticResourcePoolQueueInvoker struct

+ func (i *UpdateElasticResourcePoolQueueInvoker) Invoke() (*model.UpdateElasticResourcePoolQueueResponse, error)

+ type UpdateEnhancedConnectionInvoker struct

+ func (i *UpdateEnhancedConnectionInvoker) Invoke() (*model.UpdateEnhancedConnectionResponse, error)

+ type UpdateFlinkJarJobInvoker struct

+ func (i *UpdateFlinkJarJobInvoker) Invoke() (*model.UpdateFlinkJarJobResponse, error)

+ type UpdateFlinkSqlJobInvoker struct

+ func (i *UpdateFlinkSqlJobInvoker) Invoke() (*model.UpdateFlinkSqlJobResponse, error)

+ type UpdateFlinkSqlJobTemplateInvoker struct

+ func (i *UpdateFlinkSqlJobTemplateInvoker) Invoke() (*model.UpdateFlinkSqlJobTemplateResponse, error)

+ type UpdateGlobalVariableInvoker struct

+ func (i *UpdateGlobalVariableInvoker) Invoke() (*model.UpdateGlobalVariableResponse, error)

+ type UpdateSparkJobTemplateInvoker struct

+ func (i *UpdateSparkJobTemplateInvoker) Invoke() (*model.UpdateSparkJobTemplateResponse, error)

+ type UpdateSqlJobTemplateInvoker struct

+ func (i *UpdateSqlJobTemplateInvoker) Invoke() (*model.UpdateSqlJobTemplateResponse, error)

v0.1.67

Nov 16, 2023

v0.1.66

Nov 13, 2023

v0.1.65

Nov 9, 2023

Changes in this version

+ func GenReqDefForCreateQueueProperty() *def.HttpRequestDef

+ func GenReqDefForDeleteQueueProperty() *def.HttpRequestDef

+ func GenReqDefForListQueueProperty() *def.HttpRequestDef

+ func GenReqDefForUpdateQueueProperty() *def.HttpRequestDef

+ type CreateQueuePropertyInvoker struct

+ func (i *CreateQueuePropertyInvoker) Invoke() (*model.CreateQueuePropertyResponse, error)

+ type DeleteQueuePropertyInvoker struct

+ func (i *DeleteQueuePropertyInvoker) Invoke() (*model.DeleteQueuePropertyResponse, error)

type DliClient

+ func (c *DliClient) CreateQueueProperty(request *model.CreateQueuePropertyRequest) (*model.CreateQueuePropertyResponse, error)

+ func (c *DliClient) CreateQueuePropertyInvoker(request *model.CreateQueuePropertyRequest) *CreateQueuePropertyInvoker

+ func (c *DliClient) DeleteQueueProperty(request *model.DeleteQueuePropertyRequest) (*model.DeleteQueuePropertyResponse, error)

+ func (c *DliClient) DeleteQueuePropertyInvoker(request *model.DeleteQueuePropertyRequest) *DeleteQueuePropertyInvoker

+ func (c *DliClient) ListQueueProperty(request *model.ListQueuePropertyRequest) (*model.ListQueuePropertyResponse, error)

+ func (c *DliClient) ListQueuePropertyInvoker(request *model.ListQueuePropertyRequest) *ListQueuePropertyInvoker

+ func (c *DliClient) UpdateQueueProperty(request *model.UpdateQueuePropertyRequest) (*model.UpdateQueuePropertyResponse, error)

+ func (c *DliClient) UpdateQueuePropertyInvoker(request *model.UpdateQueuePropertyRequest) *UpdateQueuePropertyInvoker

+ type ListQueuePropertyInvoker struct

+ func (i *ListQueuePropertyInvoker) Invoke() (*model.ListQueuePropertyResponse, error)

+ type UpdateQueuePropertyInvoker struct

+ func (i *UpdateQueuePropertyInvoker) Invoke() (*model.UpdateQueuePropertyResponse, error)

v0.1.64

Nov 2, 2023

v0.1.63

Oct 26, 2023

v0.1.62

Oct 19, 2023

v0.1.61

Oct 12, 2023

v0.1.60

Sep 19, 2023

v0.1.59

Sep 14, 2023

v0.1.58

Sep 7, 2023

v0.1.57

Aug 31, 2023

v0.1.56

Aug 24, 2023

v0.1.55

Aug 21, 2023

v0.1.54

Aug 17, 2023

v0.1.53

Aug 10, 2023

v0.1.52

Aug 3, 2023

v0.1.51

Jul 31, 2023

v0.1.50

Jul 27, 2023

v0.1.49

Jul 20, 2023

Changes in this version

+ func DliClientBuilder() *http_client.HcHttpClientBuilder

+ func GenReqDefForAssociateConnectionQueue() *def.HttpRequestDef

+ func GenReqDefForAssociateQueueToElasticResourcePool() *def.HttpRequestDef

+ func GenReqDefForAuthorizeResource() *def.HttpRequestDef

+ func GenReqDefForBatchDeleteFlinkJobs() *def.HttpRequestDef

+ func GenReqDefForBatchDeleteQueuePlans() *def.HttpRequestDef

+ func GenReqDefForBatchRunFlinkJobs() *def.HttpRequestDef

+ func GenReqDefForCancelBatchJob() *def.HttpRequestDef

+ func GenReqDefForCancelSqlJob() *def.HttpRequestDef

+ func GenReqDefForChangeAuthorization() *def.HttpRequestDef

+ func GenReqDefForChangeFlinkJobStatusReport() *def.HttpRequestDef

+ func GenReqDefForChangeQueuePlan() *def.HttpRequestDef

+ func GenReqDefForCheckConnection() *def.HttpRequestDef

+ func GenReqDefForCheckSql() *def.HttpRequestDef

+ func GenReqDefForCreateAuthInfo() *def.HttpRequestDef

+ func GenReqDefForCreateBatchJob() *def.HttpRequestDef

+ func GenReqDefForCreateDatabase() *def.HttpRequestDef

+ func GenReqDefForCreateDatasourceConnection() *def.HttpRequestDef

+ func GenReqDefForCreateDliAgency() *def.HttpRequestDef

+ func GenReqDefForCreateElasticResourcePool() *def.HttpRequestDef

+ func GenReqDefForCreateEnhancedConnection() *def.HttpRequestDef

+ func GenReqDefForCreateEnhancedConnectionRoutes() *def.HttpRequestDef

+ func GenReqDefForCreateFlinkJar() *def.HttpRequestDef

+ func GenReqDefForCreateFlinkSqlJob() *def.HttpRequestDef

+ func GenReqDefForCreateFlinkTemplate() *def.HttpRequestDef

+ func GenReqDefForCreateGlobalValue() *def.HttpRequestDef

+ func GenReqDefForCreateIefMessageChannel() *def.HttpRequestDef

+ func GenReqDefForCreateIefSystemEvents() *def.HttpRequestDef

+ func GenReqDefForCreateJobTemplates() *def.HttpRequestDef

+ func GenReqDefForCreateQueue() *def.HttpRequestDef

+ func GenReqDefForCreateQueuePlan() *def.HttpRequestDef

+ func GenReqDefForCreateSqlJob() *def.HttpRequestDef

+ func GenReqDefForCreateSqlTemplates() *def.HttpRequestDef

+ func GenReqDefForCreateStreamGraph() *def.HttpRequestDef

+ func GenReqDefForCreateTable() *def.HttpRequestDef

+ func GenReqDefForDeleteAuthInfo() *def.HttpRequestDef

+ func GenReqDefForDeleteDatabase() *def.HttpRequestDef

+ func GenReqDefForDeleteDatasourceConnection() *def.HttpRequestDef

+ func GenReqDefForDeleteElasticResourcePool() *def.HttpRequestDef

+ func GenReqDefForDeleteEnhancedConnection() *def.HttpRequestDef

+ func GenReqDefForDeleteEnhancedConnectionRoutes() *def.HttpRequestDef

+ func GenReqDefForDeleteFlinkJob() *def.HttpRequestDef

+ func GenReqDefForDeleteFlinkTemplate() *def.HttpRequestDef

+ func GenReqDefForDeleteGlobalValue() *def.HttpRequestDef

+ func GenReqDefForDeleteQueue() *def.HttpRequestDef

+ func GenReqDefForDeleteQueuePlan() *def.HttpRequestDef

+ func GenReqDefForDeleteResource() *def.HttpRequestDef

+ func GenReqDefForDeleteSqlTemplates() *def.HttpRequestDef

+ func GenReqDefForDeleteTable() *def.HttpRequestDef

+ func GenReqDefForDisassociateConnectionQueue() *def.HttpRequestDef

+ func GenReqDefForExportFlinkJob() *def.HttpRequestDef

+ func GenReqDefForExportSqlJobResult() *def.HttpRequestDef

+ func GenReqDefForExportTable() *def.HttpRequestDef

+ func GenReqDefForImportFlinkJob() *def.HttpRequestDef

+ func GenReqDefForImportTable() *def.HttpRequestDef

+ func GenReqDefForListAllTables() *def.HttpRequestDef

+ func GenReqDefForListAuthInfo() *def.HttpRequestDef

+ func GenReqDefForListBatches() *def.HttpRequestDef

+ func GenReqDefForListDatabaseUsers() *def.HttpRequestDef

+ func GenReqDefForListDatabases() *def.HttpRequestDef

+ func GenReqDefForListDatasourceConnections() *def.HttpRequestDef

+ func GenReqDefForListElasticResourcePoolQueues() *def.HttpRequestDef

+ func GenReqDefForListElasticResourcePoolScaleRecords() *def.HttpRequestDef

+ func GenReqDefForListElasticResourcePools() *def.HttpRequestDef

+ func GenReqDefForListEnhancedConnections() *def.HttpRequestDef

+ func GenReqDefForListFlinkJobs() *def.HttpRequestDef

+ func GenReqDefForListFlinkTemplates() *def.HttpRequestDef

+ func GenReqDefForListGlobalValues() *def.HttpRequestDef

+ func GenReqDefForListJobTemplates() *def.HttpRequestDef

+ func GenReqDefForListQueuePlans() *def.HttpRequestDef

+ func GenReqDefForListQueueUsers() *def.HttpRequestDef

+ func GenReqDefForListQueues() *def.HttpRequestDef

+ func GenReqDefForListResources() *def.HttpRequestDef

+ func GenReqDefForListSqlJobs() *def.HttpRequestDef

+ func GenReqDefForListTablePrivileges() *def.HttpRequestDef

+ func GenReqDefForListTableUsers() *def.HttpRequestDef

+ func GenReqDefForPreviewJobResult() *def.HttpRequestDef

+ func GenReqDefForRegisterAuthorizedQueue() *def.HttpRequestDef

+ func GenReqDefForRegisterBucket() *def.HttpRequestDef

+ func GenReqDefForRunIefJobActionCallBack() *def.HttpRequestDef

+ func GenReqDefForRunQueueAction() *def.HttpRequestDef

+ func GenReqDefForShowBatchInfo() *def.HttpRequestDef

+ func GenReqDefForShowBatchLog() *def.HttpRequestDef

+ func GenReqDefForShowBatchState() *def.HttpRequestDef

+ func GenReqDefForShowDatasourceConnection() *def.HttpRequestDef

+ func GenReqDefForShowDescribeTable() *def.HttpRequestDef

+ func GenReqDefForShowDliAgency() *def.HttpRequestDef

+ func GenReqDefForShowEnhancedConnection() *def.HttpRequestDef

+ func GenReqDefForShowEnhancedPrivilege() *def.HttpRequestDef

+ func GenReqDefForShowFlinkExecuteGraph() *def.HttpRequestDef

+ func GenReqDefForShowFlinkJob() *def.HttpRequestDef

+ func GenReqDefForShowFlinkMetric() *def.HttpRequestDef

+ func GenReqDefForShowJobProgress() *def.HttpRequestDef

+ func GenReqDefForShowJobTemplate() *def.HttpRequestDef

+ func GenReqDefForShowNodeConnectivity() *def.HttpRequestDef

+ func GenReqDefForShowObjectUser() *def.HttpRequestDef

+ func GenReqDefForShowPartitions() *def.HttpRequestDef

+ func GenReqDefForShowQueueDetail() *def.HttpRequestDef

+ func GenReqDefForShowResourceInfo() *def.HttpRequestDef

+ func GenReqDefForShowSqlJobDetail() *def.HttpRequestDef

+ func GenReqDefForShowSqlJobStatus() *def.HttpRequestDef

+ func GenReqDefForShowSqlSampleTemplates() *def.HttpRequestDef

+ func GenReqDefForShowSqlTemplates() *def.HttpRequestDef

+ func GenReqDefForShowTableContent() *def.HttpRequestDef

+ func GenReqDefForStopFlinkJobs() *def.HttpRequestDef

+ func GenReqDefForUpdateAuthInfo() *def.HttpRequestDef

+ func GenReqDefForUpdateDatabaseOwner() *def.HttpRequestDef

+ func GenReqDefForUpdateElasticResourcePool() *def.HttpRequestDef

+ func GenReqDefForUpdateElasticResourcePoolQueueInfo() *def.HttpRequestDef

+ func GenReqDefForUpdateFlinkJar() *def.HttpRequestDef

+ func GenReqDefForUpdateFlinkSql() *def.HttpRequestDef

+ func GenReqDefForUpdateFlinkTemplate() *def.HttpRequestDef

+ func GenReqDefForUpdateGlobalValue() *def.HttpRequestDef

+ func GenReqDefForUpdateGroupOrResourceOwner() *def.HttpRequestDef

+ func GenReqDefForUpdateHostMassage() *def.HttpRequestDef

+ func GenReqDefForUpdateJobTemplates() *def.HttpRequestDef

+ func GenReqDefForUpdateQueueCidr() *def.HttpRequestDef

+ func GenReqDefForUpdateSqlTemplates() *def.HttpRequestDef

+ func GenReqDefForUpdateTableOwner() *def.HttpRequestDef

+ func GenReqDefForUploadFiles() *def.HttpRequestDef

+ func GenReqDefForUploadJars() *def.HttpRequestDef

+ func GenReqDefForUploadPythonFiles() *def.HttpRequestDef

+ func GenReqDefForUploadResources() *def.HttpRequestDef

+ type AssociateConnectionQueueInvoker struct

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

+ type AssociateQueueToElasticResourcePoolInvoker struct

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

+ type AuthorizeResourceInvoker struct

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

+ type BatchDeleteFlinkJobsInvoker struct

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

+ type BatchDeleteQueuePlansInvoker struct

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

+ type BatchRunFlinkJobsInvoker struct

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

+ type CancelBatchJobInvoker struct

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

+ type CancelSqlJobInvoker struct

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

+ type ChangeAuthorizationInvoker struct

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

+ type ChangeFlinkJobStatusReportInvoker struct

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

+ type ChangeQueuePlanInvoker struct

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

+ type CheckConnectionInvoker struct

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

+ type CheckSqlInvoker struct

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

+ type CreateAuthInfoInvoker struct

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

+ type CreateBatchJobInvoker struct

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

+ type CreateDatabaseInvoker struct

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

+ type CreateDatasourceConnectionInvoker struct

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

+ type CreateDliAgencyInvoker struct

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

+ type CreateElasticResourcePoolInvoker struct

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

+ type CreateEnhancedConnectionInvoker struct

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

+ type CreateEnhancedConnectionRoutesInvoker struct

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

+ type CreateFlinkJarInvoker struct

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

+ type CreateFlinkSqlJobInvoker struct

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

+ type CreateFlinkTemplateInvoker struct

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

+ type CreateGlobalValueInvoker struct

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

+ type CreateIefMessageChannelInvoker struct

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

+ type CreateIefSystemEventsInvoker struct

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

+ type CreateJobTemplatesInvoker struct

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

+ type CreateQueueInvoker struct

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

+ type CreateQueuePlanInvoker struct

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

+ type CreateSqlJobInvoker struct

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

+ type CreateSqlTemplatesInvoker struct

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

+ type CreateStreamGraphInvoker struct

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

+ type CreateTableInvoker struct

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

+ type DeleteAuthInfoInvoker struct

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

+ type DeleteDatabaseInvoker struct

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

+ type DeleteDatasourceConnectionInvoker struct

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

+ type DeleteElasticResourcePoolInvoker struct

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

+ type DeleteEnhancedConnectionInvoker struct

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

+ type DeleteEnhancedConnectionRoutesInvoker struct

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

+ type DeleteFlinkJobInvoker struct

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

+ type DeleteFlinkTemplateInvoker struct

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

+ type DeleteGlobalValueInvoker struct

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

+ type DeleteQueueInvoker struct

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

+ type DeleteQueuePlanInvoker struct

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

+ type DeleteResourceInvoker struct

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

+ type DeleteSqlTemplatesInvoker struct

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

+ type DeleteTableInvoker struct

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

+ type DisassociateConnectionQueueInvoker struct

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

+ type DliClient struct

+ HcClient *http_client.HcHttpClient

+ func NewDliClient(hcClient *http_client.HcHttpClient) *DliClient

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ type ExportFlinkJobInvoker struct

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

+ type ExportSqlJobResultInvoker struct

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

+ type ExportTableInvoker struct

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

+ type ImportFlinkJobInvoker struct

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

+ type ImportTableInvoker struct

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

+ type ListAllTablesInvoker struct

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

+ type ListAuthInfoInvoker struct

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

+ type ListBatchesInvoker struct

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

+ type ListDatabaseUsersInvoker struct

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

+ type ListDatabasesInvoker struct

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

+ type ListDatasourceConnectionsInvoker struct

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

+ type ListElasticResourcePoolQueuesInvoker struct

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

+ type ListElasticResourcePoolScaleRecordsInvoker struct

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

+ type ListElasticResourcePoolsInvoker struct

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

+ type ListEnhancedConnectionsInvoker struct

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

+ type ListFlinkJobsInvoker struct

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

+ type ListFlinkTemplatesInvoker struct

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

+ type ListGlobalValuesInvoker struct

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

+ type ListJobTemplatesInvoker struct

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

+ type ListQueuePlansInvoker struct

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

+ type ListQueueUsersInvoker struct

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

+ type ListQueuesInvoker struct

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

+ type ListResourcesInvoker struct

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

+ type ListSqlJobsInvoker struct

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

+ type ListTablePrivilegesInvoker struct

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

+ type ListTableUsersInvoker struct

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

+ type PreviewJobResultInvoker struct

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

+ type RegisterAuthorizedQueueInvoker struct

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

+ type RegisterBucketInvoker struct

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

+ type RunIefJobActionCallBackInvoker struct

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

+ type RunQueueActionInvoker struct

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

+ type ShowBatchInfoInvoker struct

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

+ type ShowBatchLogInvoker struct

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

+ type ShowBatchStateInvoker struct

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

+ type ShowDatasourceConnectionInvoker struct

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

+ type ShowDescribeTableInvoker struct

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

+ type ShowDliAgencyInvoker struct

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

+ type ShowEnhancedConnectionInvoker struct

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

+ type ShowEnhancedPrivilegeInvoker struct

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

+ type ShowFlinkExecuteGraphInvoker struct

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

+ type ShowFlinkJobInvoker struct

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

+ type ShowFlinkMetricInvoker struct

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

+ type ShowJobProgressInvoker struct

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

+ type ShowJobTemplateInvoker struct

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

+ type ShowNodeConnectivityInvoker struct

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

+ type ShowObjectUserInvoker struct

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

+ type ShowPartitionsInvoker struct

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

+ type ShowQueueDetailInvoker struct

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

+ type ShowResourceInfoInvoker struct

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

+ type ShowSqlJobDetailInvoker struct

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

+ type ShowSqlJobStatusInvoker struct

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

+ type ShowSqlSampleTemplatesInvoker struct

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

+ type ShowSqlTemplatesInvoker struct

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

+ type ShowTableContentInvoker struct

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

+ type StopFlinkJobsInvoker struct

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

+ type UpdateAuthInfoInvoker struct

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

+ type UpdateDatabaseOwnerInvoker struct

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

+ type UpdateElasticResourcePoolInvoker struct

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

+ type UpdateElasticResourcePoolQueueInfoInvoker struct

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

+ type UpdateFlinkJarInvoker struct

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

+ type UpdateFlinkSqlInvoker struct

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

+ type UpdateFlinkTemplateInvoker struct

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

+ type UpdateGlobalValueInvoker struct

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

+ type UpdateGroupOrResourceOwnerInvoker struct

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

+ type UpdateHostMassageInvoker struct

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

+ type UpdateJobTemplatesInvoker struct

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

+ type UpdateQueueCidrInvoker struct

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

+ type UpdateSqlTemplatesInvoker struct

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

+ type UpdateTableOwnerInvoker struct

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

+ type UploadFilesInvoker struct

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

+ type UploadJarsInvoker struct

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

+ type UploadPythonFilesInvoker struct

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

+ type UploadResourcesInvoker struct

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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL