model

package

Go to main page

Versions in this module

v0

v0.1.122

Nov 14, 2024

v0.1.121

Nov 7, 2024

v0.1.120

Oct 31, 2024

v0.1.119

Oct 24, 2024

v0.1.118

Oct 17, 2024

v0.1.117

Oct 10, 2024

v0.1.116

Sep 26, 2024

v0.1.115

Sep 23, 2024

v0.1.114

Sep 12, 2024

Changes in this version

type CreateElasticResourcePoolRequestBody

+ Label map[string]string

v0.1.113

Sep 5, 2024

Changes in this version

type ShowSqlJobStatusResponse

+ ExecutionDetailsPath *string

v0.1.112

Aug 29, 2024

v0.1.111

Aug 22, 2024

v0.1.110

Aug 15, 2024

Changes in this version

type Queue

+ DefaultFlinkJarVersion *string

+ DefaultFlinkSqlVersion *string

+ DefaultHetuEngineVersion *string

+ DefaultSparkVersion *string

+ SupportFlinkJarVersions *[]string

+ SupportFlinkSqlVersions *[]string

+ SupportHetuEngineVersions *[]string

+ SupportSparkVersions *[]string

type ShowQueueResponse

+ DefaultFlinkJarVersion *string

+ DefaultFlinkSqlVersion *string

+ DefaultHetuEngineVersion *string

+ DefaultSparkVersion *string

+ SupportFlinkJarVersions *[]string

+ SupportFlinkSqlVersions *[]string

+ SupportHetuEngineVersions *[]string

+ SupportSparkVersions *[]string

v0.1.109

Aug 8, 2024

v0.1.108

Aug 1, 2024

v0.1.107

Jul 25, 2024

Changes in this version

type CreateSqlJobRequestBodyEngineTypeEnum

+ HETU_ENGINE CreateSqlJobRequestBodyEngineType

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

+ type CreateStreamJobRequest struct

+ Body *CreateStreamJobRequestBody

+ func (o CreateStreamJobRequest) String() string

+ type CreateStreamJobRequestBody struct

+ Description *string

+ EnvironmentConfig *StreamEnvironmentConfig

+ FlinkJarParameter *FlinkJarParameter

+ FlinkSqlParameter *FlinkSqlParameter

+ JobType *string

+ RuntimeConfig *StreamRuntimeConfig

+ Tags *[]Tag

+ TransactionId string

+ func (o CreateStreamJobRequestBody) String() string

+ type CreateStreamJobResponse struct

+ HttpStatusCode int

+ IsSuccess *string

+ Job *StreamJobStatus

+ Message *string

+ func (o CreateStreamJobResponse) String() string

+ type FlinkJarParameter struct

+ DependencyFiles *[]string

+ DependencyJars *[]string

+ MainArgs *string

+ MainClass *string

+ MainJar *string

+ func (o FlinkJarParameter) String() string

+ type FlinkResourceConfig struct

+ JobmanagerResourceSpec *ResourceSpec

+ MaxSlot *int32

+ ParallelNumber *int32

+ TaskmanagerResourceSpec *ResourceSpec

+ func (o FlinkResourceConfig) String() string

+ type FlinkRestoreStrategy struct

+ AllowNonRestoredState *bool

+ JobStartTimeInMs *int32

+ RestoreType *string

+ SavepointId *string

+ func (o FlinkRestoreStrategy) String() string

+ type FlinkRuntimeConfig struct

+ ResourceConfig *FlinkResourceConfig

+ RestoreStrategy *FlinkRestoreStrategy

+ Version *string

+ func (o FlinkRuntimeConfig) String() string

+ type FlinkSqlParameter struct

+ DependencyJars *string

+ SqlBody *string

+ func (o FlinkSqlParameter) String() string

+ type Properties struct

+ func (o Properties) String() string

+ type ResourceSpec struct

+ Cpu *float64

+ Memory *string

+ func (o ResourceSpec) String() string

+ type StreamClassLoggerLevel struct

+ LoggerLevel *string

+ LoggerName *string

+ func (o StreamClassLoggerLevel) String() string

+ type StreamEnvironmentConfig struct

+ ExecutionAgencyUrn *string

+ ImageFeature *string

+ ImageUri *string

+ QueueName *string

+ func (o StreamEnvironmentConfig) String() string

+ type StreamJobStatus struct

+ StatusDesc *string

+ StatusName *string

+ StreamId *int64

+ func (o StreamJobStatus) String() string

+ type StreamLoggingConfig struct

+ LogEnabled *bool

+ LoggersLevelOfClass *[]StreamClassLoggerLevel

+ ObsBucket *string

+ RootLoggerLevel *string

+ func (o StreamLoggingConfig) String() string

+ type StreamRuntimeConfig struct

+ FlinkRuntimeConfig *FlinkRuntimeConfig

+ Logging *StreamLoggingConfig

+ Properties *Properties

+ StagingUri *string

+ func (o StreamRuntimeConfig) String() string

v0.1.99

Jun 6, 2024

Changes in this version

type ExportSqlJobResultRequestBody

+ EscapeChar *string

+ QuoteChar *string

v0.1.98

May 30, 2024

v0.1.97

May 23, 2024

v0.1.96

May 16, 2024

Changes in this version

type CreateSqlJobRequestBody

+ CurrentCatalog *string

v0.1.95

May 9, 2024

Changes in this version

type BatchDeleteFlinkJobsResponse

+ Body *[]FlinkSuccessResponse

+ type ExecuteFlinkJobSavepointRequest struct

+ Body *ExecuteFlinkJobSavepointRequestBody

+ JobId string

+ func (o ExecuteFlinkJobSavepointRequest) String() string

+ type ExecuteFlinkJobSavepointRequestBody struct

+ Action ExecuteFlinkJobSavepointRequestBodyAction

+ SavepointPath string

+ func (o ExecuteFlinkJobSavepointRequestBody) String() string

+ type ExecuteFlinkJobSavepointRequestBodyAction struct

+ func (c *ExecuteFlinkJobSavepointRequestBodyAction) UnmarshalJSON(b []byte) error

+ func (c ExecuteFlinkJobSavepointRequestBodyAction) MarshalJSON() ([]byte, error)

+ func (c ExecuteFlinkJobSavepointRequestBodyAction) Value() string

+ type ExecuteFlinkJobSavepointRequestBodyActionEnum struct

+ TRIGGER ExecuteFlinkJobSavepointRequestBodyAction

+ func GetExecuteFlinkJobSavepointRequestBodyActionEnum() ExecuteFlinkJobSavepointRequestBodyActionEnum

+ type ExecuteFlinkJobSavepointResponse struct

+ HttpStatusCode int

+ IsSuccess *string

+ Message *string

+ func (o ExecuteFlinkJobSavepointResponse) String() string

+ type FlinkSuccessResponse struct

+ IsSuccess *string

+ Message *string

+ func (o FlinkSuccessResponse) String() string

+ type ImportFlinkJobSavepointRequest struct

+ Body *ImportFlinkJobSavepointRequestBody

+ JobId string

+ func (o ImportFlinkJobSavepointRequest) String() string

+ type ImportFlinkJobSavepointRequestBody struct

+ JobId int64

+ SavepointPath string

+ func (o ImportFlinkJobSavepointRequestBody) String() string

+ type ImportFlinkJobSavepointResponse struct

+ HttpStatusCode int

+ IsSuccess *string

+ Message *string

+ func (o ImportFlinkJobSavepointResponse) String() string

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

Changes in this version

+ type AdvancedQueueProperty struct

+ ComputeEngineMaxInstance *int32

+ ComputeEngineMaxPrefetchInstance *int32

+ JobMaxConcurrent *int32

+ NetworkCidrInVpc *string

+ func (o AdvancedQueueProperty) String() string

+ type CommonQueueProperty struct

+ ComputeEngineMaxInstance *int32

+ ComputeEngineMaxPrefetchInstance *int32

+ JobMaxConcurrent *int32

+ func (o CommonQueueProperty) String() string

+ type CreateSqlJobRequestBodyEngineType struct

+ func (c *CreateSqlJobRequestBodyEngineType) UnmarshalJSON(b []byte) error

+ func (c CreateSqlJobRequestBodyEngineType) MarshalJSON() ([]byte, error)

+ func (c CreateSqlJobRequestBodyEngineType) Value() string

+ type CreateSqlJobRequestBodyEngineTypeEnum struct

+ SPARK CreateSqlJobRequestBodyEngineType

+ TRINO CreateSqlJobRequestBodyEngineType

+ func GetCreateSqlJobRequestBodyEngineTypeEnum() CreateSqlJobRequestBodyEngineTypeEnum

+ type DeleteQueuePropertyRequestBody struct

+ Keys []string

+ func (o DeleteQueuePropertyRequestBody) String() string

type FlinkJob

+ CreateTime int64

+ Desc *string

+ Duration *int64

+ EdgeGroupIds *[]string

+ EntrypointArgs *string

+ ExecutionGraph *string

+ GraphEditorEnabled *bool

+ HasSavepoint *bool

+ JobConfig *FlinkJobConfig

+ JobType *string

+ MainClass *string

+ Name *string

+ ProjectId *string

+ QueueName *string

+ RestartTimes *int64

+ RootId *int64

+ RunMode *string

+ SavepointPath *string

+ SqlBody *string

+ StartTime *int64

+ Status *string

+ UpdateTime *int64

+ UserId *string

+ UserName *string

type FlinkJobConfig

+ RealCuNumber *int32

+ type FlinkJobStatus struct

+ JobId *int64

+ StatusDesc *string

+ StatusName *string

+ func (o FlinkJobStatus) String() string

+ type JobResource struct

+ Name *string

+ Type *string

+ func (o JobResource) String() string

+ type JobResourcesGroup struct

+ Name *string

+ Resources *[]JobResource

+ func (o JobResourcesGroup) String() string

+ type PackageResourceGroup struct

+ CreateTime *int64

+ Details *[]PackageResource

+ GroupName *string

+ IsAsync *bool

+ Owner *string

+ Resources *[]string

+ Status *string

+ UpdateTime *int64

+ func (o PackageResourceGroup) String() string

type Partition

+ CreateTime int64

+ LastAccessTime int64

+ LastDdlTime *int64

+ Locations *[]string

+ NumFiles *int64

+ NumRows *int64

+ PartitionName string

+ TotalSize *int64

+ type PartitionList struct

+ PartitionInfos []Partition

+ TotalCount int64

+ func (o PartitionList) String() string

+ type QueueProperty struct

+ Key QueuePropertyKey

+ Value string

+ func (o QueueProperty) String() string

+ type QueuePropertyKey struct

+ func (c *QueuePropertyKey) UnmarshalJSON(b []byte) error

+ func (c QueuePropertyKey) MarshalJSON() ([]byte, error)

+ func (c QueuePropertyKey) Value() string

+ type QueuePropertyKeyEnum struct

+ COMPUTE_ENGINE_MAX_INSTANCES QueuePropertyKey

+ COMPUTE_ENGINE_MAX_PREFETCH_INSTANCE QueuePropertyKey

+ JOB_MAX_CONCURRENT QueuePropertyKey

+ MULTIPLE_SC_SUPPORT QueuePropertyKey

+ func GetQueuePropertyKeyEnum() QueuePropertyKeyEnum

+ type QuotaList struct

+ Resources *[]QuotaInfo

+ func (o QuotaList) String() string

type ShowQuotaResponse

+ IsSuccess *bool

+ type SparkJob struct

+ AppId *string

+ ClusterName *string

+ CreateTime *int64

+ Duration *int64

+ Id *string

+ Image *string

+ Kind *string

+ Log *[]string

+ Name *string

+ Owner *string

+ ProxyUser *string

+ Queue *string

+ ReqBody *string

+ ScType *string

+ State *string

+ UpdateTime *int64

+ func (o SparkJob) String() string

v0.1.89

Apr 1, 2024

v0.1.88

Mar 28, 2024

Changes in this version

+ type AssociateQueueToEnhancedConnectionRequestBody struct

+ ElasticResourcePools *[]string

+ Queues *[]string

+ func (o AssociateQueueToEnhancedConnectionRequestBody) String() string

+ type AuthInfo struct

+ AuthInfoName *string

+ CertificateLocation *string

+ CreateTime *int64

+ DatasourceType *string

+ KeystoreLocation *string

+ Keytab *string

+ Krb5Conf *string

+ Owner *string

+ TruststoreLocation *string

+ UpdateTime *int64

+ UserName *string

+ func (o AuthInfo) String() string

+ type BatchDeleteQueuePlansRequestBody struct

+ PlanIds []int64

+ func (o BatchDeleteQueuePlansRequestBody) String() string

+ type BatchDeleteSqlJobTemplatesRequestBody struct

+ SqlIds []string

+ func (o BatchDeleteSqlJobTemplatesRequestBody) String() string

+ type BatchStopFlinkJobsRequest struct

+ Body *StopFlinkJobsRequestBody

+ func (o BatchStopFlinkJobsRequest) String() string

+ type BatchStopFlinkJobsResponse struct

+ Body *[]SuccessResponse

+ HttpStatusCode int

+ func (o BatchStopFlinkJobsResponse) String() string

+ type Catalog struct

+ CreateTime *int64

+ Description *string

+ Name *string

+ Parameters map[string]string

+ func (o Catalog) String() string

+ type ChangeFlinkJobStatusReportRequestBody struct

+ Jobs []Job

+ MessageId string

+ MsgConfirmTopic *string

+ func (o ChangeFlinkJobStatusReportRequestBody) String() string

+ type Column struct

+ ColumnName string

+ Description *string

+ IsPartitionColumn *bool

+ Type string

+ func (o Column) String() string

+ type CreateAuthInfoRequestBody struct

+ AuthInfoName string

+ CertificateLocation *string

+ DatasourceType string

+ KeyPassword *string

+ KeystoreLocation *string

+ KeystorePassword *string

+ Keytab *string

+ Krb5Conf *string

+ Password *string

+ TruststoreLocation *string

+ TruststorePassword *string

+ UserName *string

+ func (o CreateAuthInfoRequestBody) String() string

+ type CreateConnectivityTaskRequestBody struct

+ Address string

+ func (o CreateConnectivityTaskRequestBody) String() string

+ type CreateDatasourceConnectionRequestBody struct

+ Name string

+ NetworkId string

+ SecurityGroupId string

+ Service string

+ Tags *[]Tag

+ Url string

+ func (o CreateDatasourceConnectionRequestBody) String() string

+ type CreateDliAgencyRequestBody struct

+ Roles []string

+ func (o CreateDliAgencyRequestBody) String() string

+ type CreateEnhancedConnectionRequestBody struct

+ DestNetworkId string

+ DestVpcId string

+ ElasticResourcePools *[]string

+ Hosts *[]EnhancedConnectionHost

+ Name string

+ Queues *[]string

+ RoutetableId *string

+ Tags *[]Tag

+ func (o CreateEnhancedConnectionRequestBody) String() string

+ type CreateEnhancedConnectionRoutesRequestBody struct

+ Cidr string

+ Name string

+ func (o CreateEnhancedConnectionRoutesRequestBody) String() string

+ type CreateFlinkJarJobRequestBody struct

+ CheckpointPath *string

+ CuNumber *int32

+ DependencyFiles *[]string

+ DependencyJars *[]string

+ Desc *string

+ Entrypoint *string

+ EntrypointArgs *string

+ Feature *string

+ FlinkVersion *string

+ Image *string

+ LogEnabled *bool

+ MainClass *string

+ ManagerCuNumber *int32

+ Name string

+ ObsBucket *string

+ ParallelNumber *int32

+ QueueName *string

+ RestartWhenException *bool

+ ResumeCheckpoint *bool

+ ResumeMaxNum *int32

+ RuntimeConfig *string

+ SmnTopic *string

+ Tags *[]Tag

+ TmCus *int32

+ TmSlotNum *int32

+ func (o CreateFlinkJarJobRequestBody) String() string

+ type CreateFlinkSqlJobGraphRequestBody struct

+ CuNumber *int32

+ FlinkVersion *CreateFlinkSqlJobGraphRequestBodyFlinkVersion

+ GraphType *CreateFlinkSqlJobGraphRequestBodyGraphType

+ JobType *string

+ ManagerCuNumber *int32

+ OperatorConfig *string

+ ParallelNumber *int32

+ SqlBody string

+ StaticEstimator *bool

+ StaticEstimatorConfig *string

+ TmCus *int32

+ TmSlotNum *int32

+ func (o CreateFlinkSqlJobGraphRequestBody) String() string

+ type CreateFlinkSqlJobGraphRequestBodyFlinkVersion struct

+ func (c *CreateFlinkSqlJobGraphRequestBodyFlinkVersion) UnmarshalJSON(b []byte) error

+ func (c CreateFlinkSqlJobGraphRequestBodyFlinkVersion) MarshalJSON() ([]byte, error)

+ func (c CreateFlinkSqlJobGraphRequestBodyFlinkVersion) Value() string

+ type CreateFlinkSqlJobGraphRequestBodyFlinkVersionEnum struct

+ E_1_1 CreateFlinkSqlJobGraphRequestBodyFlinkVersion

+ E_1_12 CreateFlinkSqlJobGraphRequestBodyFlinkVersion

+ func GetCreateFlinkSqlJobGraphRequestBodyFlinkVersionEnum() CreateFlinkSqlJobGraphRequestBodyFlinkVersionEnum

+ type CreateFlinkSqlJobGraphRequestBodyGraphType struct

+ func (c *CreateFlinkSqlJobGraphRequestBodyGraphType) UnmarshalJSON(b []byte) error

+ func (c CreateFlinkSqlJobGraphRequestBodyGraphType) MarshalJSON() ([]byte, error)

+ func (c CreateFlinkSqlJobGraphRequestBodyGraphType) Value() string

+ type CreateFlinkSqlJobGraphRequestBodyGraphTypeEnum struct

+ JOB_GRAPH CreateFlinkSqlJobGraphRequestBodyGraphType

+ SIMPLE_GRAPH CreateFlinkSqlJobGraphRequestBodyGraphType

+ func GetCreateFlinkSqlJobGraphRequestBodyGraphTypeEnum() CreateFlinkSqlJobGraphRequestBodyGraphTypeEnum

+ type CreateFlinkSqlJobTemplateRequestBody struct

+ Desc *string

+ JobType *CreateFlinkSqlJobTemplateRequestBodyJobType

+ Name string

+ SqlBody *string

+ Tags *[]Tag

+ func (o CreateFlinkSqlJobTemplateRequestBody) String() string

+ type CreateFlinkSqlJobTemplateRequestBodyJobType struct

+ func (c *CreateFlinkSqlJobTemplateRequestBodyJobType) UnmarshalJSON(b []byte) error

+ func (c CreateFlinkSqlJobTemplateRequestBodyJobType) MarshalJSON() ([]byte, error)

+ func (c CreateFlinkSqlJobTemplateRequestBodyJobType) Value() string

+ type CreateFlinkSqlJobTemplateRequestBodyJobTypeEnum struct

+ FLINK_OPENSOURCE_SQL_JOB CreateFlinkSqlJobTemplateRequestBodyJobType

+ FLINK_SQL_JOB CreateFlinkSqlJobTemplateRequestBodyJobType

+ func GetCreateFlinkSqlJobTemplateRequestBodyJobTypeEnum() CreateFlinkSqlJobTemplateRequestBodyJobTypeEnum

+ type CreateGlobalVariableRequestBody struct

+ IsSensitive *bool

+ VarName string

+ VarValue string

+ func (o CreateGlobalVariableRequestBody) String() string

+ type CreateIefMessageChannelRequestBody struct

+ NodeId string

+ func (o CreateIefMessageChannelRequestBody) String() string

+ type CreateIefSystemEventsRequestBody struct

+ Data *IefEvent

+ func (o CreateIefSystemEventsRequestBody) String() string

+ type CreateQueuePropertyRequestBody struct

+ Properties *CreateQueuePropertyRequestBodyProperties

+ func (o CreateQueuePropertyRequestBody) String() string

+ type CreateQueuePropertyRequestBodyProperties struct

+ ComputeEngineMaxInstance *int32

+ ComputeEngineMaxPrefetchInstance *int32

+ JobMaxConcurrent *int32

+ func (o CreateQueuePropertyRequestBodyProperties) String() string

+ type CreateQueueRequestBody struct

+ ChargingMode *int32

+ CuCount int32

+ Description *string

+ ElasticResourcePoolName *string

+ EnterpriseProjectId *string

+ Feature *string

+ Labels *[]interface{}

+ Platform *string

+ QueueName string

+ QueueType *string

+ ResourceMode *int32

+ Tags *[]Tag

+ func (o CreateQueueRequestBody) String() string

+ type CreateSparkJobRequestBody struct

+ Args *[]string

+ AutoRecovery *bool

+ CatalogName *string

+ ClassName string

+ ClusterName *string

+ Conf map[string]interface{}

+ DriverCores *int32

+ DriverMemory *string

+ ExecutorCores *int32

+ ExecutorMemory *string

+ Feature *CreateSparkJobRequestBodyFeature

+ File string

+ Files *[]string

+ Groups *[]SparkJobGroup

+ Image *string

+ Jars *[]string

+ MaxRetryTimes *int32

+ Modules *[]string

+ Name *string

+ NumExecutors *int32

+ ObsBucket *string

+ PyFiles *[]string

+ Queue *string

+ Resources *[]SparkJobResource

+ ScType *string

+ SparkVersion *string

+ func (o CreateSparkJobRequestBody) String() string

+ type CreateSparkJobRequestBodyFeature struct

+ func (c *CreateSparkJobRequestBodyFeature) UnmarshalJSON(b []byte) error

+ func (c CreateSparkJobRequestBodyFeature) MarshalJSON() ([]byte, error)

+ func (c CreateSparkJobRequestBodyFeature) Value() string

+ type CreateSparkJobRequestBodyFeatureEnum struct

+ AI CreateSparkJobRequestBodyFeature

+ BASIC CreateSparkJobRequestBodyFeature

+ CUSTOM CreateSparkJobRequestBodyFeature

+ func GetCreateSparkJobRequestBodyFeatureEnum() CreateSparkJobRequestBodyFeatureEnum

+ type CreateSparkJobTemplateRequestBody struct

+ Body string

+ Description *string

+ Group *string

+ Language *string

+ Name string

+ Type string

+ func (o CreateSparkJobTemplateRequestBody) String() string

type CreateSqlJobRequestBody

+ EngineType *string

+ type CreateSqlJobTemplateRequestBody struct

+ Description *string

+ Group *string

+ Sql string

+ SqlName string

+ func (o CreateSqlJobTemplateRequestBody) String() string

+ type CreateTableRequestBody struct

+ Columns []Column

+ DataLocation string

+ DataPath *string

+ DataType *string

+ DateFormat *string

+ Delimiter *string

+ Description *string

+ EscapeChar *string

+ QuoteChar *string

+ SelectStatement *string

+ TableName string

+ Tags *[]Tag

+ TimestampFormat *string

+ WithColumnHeader *bool

+ func (o CreateTableRequestBody) String() string

+ type DataAuthorizationPrivilege struct

+ Object string

+ Privileges []string

+ func (o DataAuthorizationPrivilege) String() string

+ type DatabaseUserPrivilege struct

+ IsAdmin *bool

+ Privileges *[]string

+ UserName *string

+ func (o DatabaseUserPrivilege) String() string

+ type DatasourceConnection struct

+ ClusterName *string

+ ConnectionId *string

+ ConnectionUrl *string

+ CreateTime *int64

+ Destination *string

+ IsSuccess *bool

+ Message *string

+ Name *string

+ Process *float64

+ QueueList *[]string

+ Service *string

+ State *string

+ func (o DatasourceConnection) String() string

+ type DeleteJobResourceRequest struct

+ Group *string

+ ResourceName string

+ func (o DeleteJobResourceRequest) String() string

+ type DeleteJobResourceResponse struct

+ HttpStatusCode int

+ func (o DeleteJobResourceResponse) String() string

+ type DisassociateQueueFromEnhancedConnectionRequestBody struct

+ ElasticResourcePools *[]string

+ Queues *[]string

+ func (o DisassociateQueueFromEnhancedConnectionRequestBody) String() string

+ type ElasticResourcePool struct

+ ActualCu *int32

+ ChargingMode *int32

+ CidrInVpc *string

+ CreateTime *int64

+ CurrentCu *int32

+ Description *string

+ ElasticResourcePoolName *string

+ EnterpriseProjectId *string

+ FailReason *string

+ Id *int32

+ Label map[string]string

+ Manager *string

+ MaxCu *int32

+ MinCu *int32

+ Owner *string

+ PrepayCu *int32

+ Queues *[]string

+ ResourceId *string

+ Status *string

+ UpdateTime *int64

+ func (o ElasticResourcePool) String() string

+ type ElasticResourcePoolQueue struct

+ CreateTime *int64

+ Engine *string

+ EnterpriseProjectId *string

+ Owner *string

+ QueueName *string

+ QueueScalingPolicies *[]QueueScalingPolicy

+ QueueType *string

+ func (o ElasticResourcePoolQueue) String() string

+ type EnhancedConnection struct

+ AvailableQueueInfo *[]EnhancedConnectionResource

+ CreateTime *int64

+ DestNetworkId *string

+ DestVpcId *string

+ ElasticResourcePools *[]EnhancedConnectionResource

+ Hosts *[]EnhancedConnectionHost

+ Id *string

+ IsPrivis *bool

+ Name *string

+ Status *string

+ func (o EnhancedConnection) String() string

+ type EnhancedConnectionHost struct

+ Ip *string

+ Name *string

+ func (o EnhancedConnectionHost) String() string

+ type EnhancedConnectionPrivilege struct

+ ApplicantProjectId *string

+ Object *string

+ Privileges *[]string

+ func (o EnhancedConnectionPrivilege) String() string

+ type EnhancedConnectionResource struct

+ ErrMsg *string

+ Name *string

+ PeerId *string

+ Status *string

+ UpdateTime *int64

+ func (o EnhancedConnectionResource) String() string

+ type ExportFlinkJobsRequestBody struct

+ IsSelected bool

+ JobSelected *[]int64

+ ObsDir string

+ func (o ExportFlinkJobsRequestBody) String() string

+ type ExportSqlJobResultRequestBody struct

+ Compress *string

+ DataPath string

+ DataType string

+ EncodingType *string

+ ExportMode *ExportSqlJobResultRequestBodyExportMode

+ LimitNum *int32

+ QueueName *string

+ WithColumnHeader *bool

+ func (o ExportSqlJobResultRequestBody) String() string

+ type ExportSqlJobResultRequestBodyExportMode struct

+ func (c *ExportSqlJobResultRequestBodyExportMode) UnmarshalJSON(b []byte) error

+ func (c ExportSqlJobResultRequestBodyExportMode) MarshalJSON() ([]byte, error)

+ func (c ExportSqlJobResultRequestBodyExportMode) Value() string

+ type ExportSqlJobResultRequestBodyExportModeEnum struct

+ ERROR_IF_EXISTS ExportSqlJobResultRequestBodyExportMode

+ OVERWRITE ExportSqlJobResultRequestBodyExportMode

+ func GetExportSqlJobResultRequestBodyExportModeEnum() ExportSqlJobResultRequestBodyExportModeEnum

+ type FlinkJob struct

+ JobId *int64

+ StatusDesc *string

+ StatusName *string

+ func (o FlinkJob) String() string

+ type FlinkJobConfigDetail struct

+ CheckpointEnabled *bool

+ CheckpointInterval *int32

+ CheckpointMode *string

+ CheckpointPath *string

+ ConfigUrl *string

+ CuNumber *int32

+ DependencyFiles *[]string

+ DependencyJars *[]string

+ DirtyDataStrategy *string

+ EdgeGroupIds *[]string

+ Entrypoint *string

+ ExecutorCuNumber *int32

+ ExecutorNumber *int32

+ Feature *string

+ FlinkVersion *string

+ GraphEditorData *string

+ GraphEditorEnabled *bool

+ IdleStateRetention *int32

+ Image *string

+ LogEnabled *bool

+ ManagerCuNumber *int32

+ ObsBucket *string

+ OperatorConfig *string

+ ParallelNumber *int32

+ RestartWhenException *bool

+ ResumeCheckpoint *bool

+ ResumeMaxNum *int64

+ RootId *int32

+ RuntimeConfig *string

+ SmnTopic *string

+ StaticEstimatorConfig *string

+ TmCus *int32

+ TmSlotNum *int32

+ UdfJarUrl *string

+ func (o FlinkJobConfigDetail) String() string

+ type FlinkJobExecutionGraph struct

+ Duration *int64

+ EndTime *int64

+ IsStoppable *bool

+ Jid *string

+ Name *string

+ StartTime *int64

+ State *string

+ func (o FlinkJobExecutionGraph) String() string

+ type FlinkJobMetricInfo struct

+ CorruptedRecords *int64

+ Name *string

+ Records *int64

+ func (o FlinkJobMetricInfo) String() string

+ type FlinkJobUpdateTime struct

+ UpdateTime *int64

+ func (o FlinkJobUpdateTime) String() string

+ type FlinkMetric struct

+ Jobs *[]FlinkMetricList

+ func (o FlinkMetric) String() string

+ type FlinkMetricList struct

+ JobId *int64

+ Metrics *Metric

+ func (o FlinkMetricList) String() string

+ type FlinkSqlJobTemplate struct

+ CreateTime *int64

+ Desc *string

+ JobType *string

+ Name *string

+ SqlBody *string

+ TemplateId *int32

+ UpdateTime *int64

+ func (o FlinkSqlJobTemplate) String() string

+ type FlinkSqlJobTemplateId struct

+ TemplateId *int64

+ func (o FlinkSqlJobTemplateId) String() string

+ type FlinkSqlJobTemplateList struct

+ Templates *[]FlinkSqlJobTemplate

+ TotalCount *int32

+ func (o FlinkSqlJobTemplateList) String() string

+ type GlobalVariable struct

+ CreateTime *int64

+ Id *int64

+ IsSensitive *bool

+ ProjectId *string

+ UpdateTime *int64

+ UserId *string

+ UserName *string

+ VarName *string

+ VarValue *string

+ func (o GlobalVariable) String() string

+ type IefEvent struct

+ Attributes *string

+ EventType string

+ Name string

+ Operation string

+ Timestamp int64

+ Topic string

+ func (o IefEvent) String() string

+ type ImportFlinkJobsRequestBody struct

+ IsCover *bool

+ ZipFile string

+ func (o ImportFlinkJobsRequestBody) String() string

+ type Job struct

+ CreateTime int64

+ Exceptions *string

+ JobId *int32

+ Metrics *string

+ Plan *string

+ Status string

+ func (o Job) String() string

+ type JobMap struct

+ NewJobId *int64

+ OldJobId *int64

+ Remark *string

+ func (o JobMap) String() string

+ type ListJobResourcesRequest struct

+ Kind *string

+ Tags *string

+ func (o ListJobResourcesRequest) String() string

+ type ListJobResourcesResponse struct

+ Groups *[]interface{}

+ HttpStatusCode int

+ Modules *[]PackageResourceMoudle

+ Resources *[]PackageResource

+ Total *int32

+ func (o ListJobResourcesResponse) String() string

+ type ListPartitionsRequest struct

+ DatabaseName string

+ Limit *int32

+ Offset *int32

+ TableName string

+ func (o ListPartitionsRequest) String() string

+ type ListPartitionsResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ Partitions *Partition

+ func (o ListPartitionsResponse) String() string

type ListSqlJobsRequestJobTypeEnum

+ ALL ListSqlJobsRequestJobType

+ type ListSqlSampleTemplatesRequest struct

+ func (o ListSqlSampleTemplatesRequest) String() string

+ type ListSqlSampleTemplatesResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ SqlCount *int32

+ Sqls *[]SqlSampleTemplate

+ func (o ListSqlSampleTemplatesResponse) String() string

+ type ListTablesRequest struct

+ CurrentPage *int32

+ DatabaseName string

+ Keyword *string

+ PageSize *int32

+ TableType *string

+ WithDetail *bool

+ WithPriv *bool

+ func (o ListTablesRequest) String() string

+ type ListTablesResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ TableCount *int32

+ Tables *[]Table

+ func (o ListTablesResponse) String() string

+ type Metric struct

+ Sinks *[]FlinkJobMetricInfo

+ Sources *[]FlinkJobMetricInfo

+ TotalReadRate *float64

+ TotalWriteRate *float64

+ func (o Metric) String() string

+ type PackageResource struct

+ CreateTime *int64

+ Owner *string

+ ResourceName *string

+ ResourceType *string

+ Status *string

+ UnderlyingName *string

+ UpdateTime *int64

+ func (o PackageResource) String() string

+ type PackageResourceMoudle struct

+ CreateTime *int64

+ Description *string

+ ModuleName *string

+ ModuleType *string

+ Resources *[]string

+ Status *string

+ UpdateTime *int64

+ func (o PackageResourceMoudle) String() string

+ type Partition struct

+ PartitionInfos []PartitionInfo

+ TotalCount int64

+ func (o Partition) String() string

+ type PartitionInfo struct

+ CreateTime int64

+ LastAccessTime int64

+ LastDdlTime *int64

+ Locations *[]string

+ NumFiles *int64

+ NumRows *int64

+ PartitionName string

+ TotalSize *int64

+ func (o PartitionInfo) String() string

+ type PreviewTableRequest struct

+ DatabaseName string

+ Mode *string

+ TableName string

+ func (o PreviewTableRequest) String() string

+ type PreviewTableResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ Rows *[]interface{}

+ Schema *[]interface{}

+ func (o PreviewTableResponse) String() string

+ type Property struct

+ Key PropertyKey

+ Value string

+ func (o Property) String() string

+ type PropertyKey struct

+ func (c *PropertyKey) UnmarshalJSON(b []byte) error

+ func (c PropertyKey) MarshalJSON() ([]byte, error)

+ func (c PropertyKey) Value() string

+ type PropertyKeyEnum struct

+ COMPUTE_ENGINE_MAX_INSTANCES PropertyKey

+ COMPUTE_ENGINE_MAX_PREFETCH_INSTANCE PropertyKey

+ JOB_MAX_CONCURRENT PropertyKey

+ MULTIPLE_SC_SUPPORT PropertyKey

+ func GetPropertyKeyEnum() PropertyKeyEnum

+ type Queue struct

+ ChargingMode *int32

+ CidrInMgntsubnet *string

+ CidrInSubnet *string

+ CidrInVpc *string

+ CreateTime *int64

+ CuCount *int32

+ CuScaleInLimit *int32

+ CuScaleOutLimit *int32

+ CuSpec *int32

+ Description *string

+ ElasticResourcePoolName *string

+ EnterpriseProjectId *string

+ Feature *string

+ IsRestarting *bool

+ Labels *string

+ Owner *string

+ Platform *string

+ QueueId *int64

+ QueueName *string

+ QueueType *string

+ ResourceId *string

+ ResourceMode *int32

+ ResourceType *string

+ func (o Queue) String() string

+ type QueuePlan struct

+ Activate *bool

+ Id *int64

+ LastExecuteTime *int64

+ PlanName *string

+ RepeatDay []QueuePlanRepeatDay

+ StartHour *int32

+ StartMinute *int32

+ TargetCu *int32

+ ValidDateBegin *int64

+ ValidDateEnd *int64

+ func (o QueuePlan) String() string

+ type QueuePlanRepeatDay struct

+ func (c *QueuePlanRepeatDay) UnmarshalJSON(b []byte) error

+ func (c QueuePlanRepeatDay) MarshalJSON() ([]byte, error)

+ func (c QueuePlanRepeatDay) Value() string

+ type QueuePlanRepeatDayEnum struct

+ FRIDAY QueuePlanRepeatDay

+ MONDAY QueuePlanRepeatDay

+ SATURDAY QueuePlanRepeatDay

+ SUNDAY QueuePlanRepeatDay

+ THURSDAY QueuePlanRepeatDay

+ TUESDAY QueuePlanRepeatDay

+ WEDNESDAY QueuePlanRepeatDay

+ func GetQueuePlanRepeatDayEnum() QueuePlanRepeatDayEnum

+ type QueuePlanRequestBody struct

+ Activate *bool

+ PlanName string

+ RepeatDay []QueuePlanRequestBodyRepeatDay

+ StartHour int32

+ StartMinute int32

+ TargetCu int32

+ ValidDateBegin *int64

+ ValidDateEnd *int64

+ func (o QueuePlanRequestBody) String() string

+ type QueuePlanRequestBodyRepeatDay struct

+ func (c *QueuePlanRequestBodyRepeatDay) UnmarshalJSON(b []byte) error

+ func (c QueuePlanRequestBodyRepeatDay) MarshalJSON() ([]byte, error)

+ func (c QueuePlanRequestBodyRepeatDay) Value() string

+ type QueuePlanRequestBodyRepeatDayEnum struct

+ FRIDAY QueuePlanRequestBodyRepeatDay

+ MONDAY QueuePlanRequestBodyRepeatDay

+ SATURDAY QueuePlanRequestBodyRepeatDay

+ SUNDAY QueuePlanRequestBodyRepeatDay

+ THURSDAY QueuePlanRequestBodyRepeatDay

+ TUESDAY QueuePlanRequestBodyRepeatDay

+ WEDNESDAY QueuePlanRequestBodyRepeatDay

+ func GetQueuePlanRequestBodyRepeatDayEnum() QueuePlanRequestBodyRepeatDayEnum

+ type QueueScalingPolicy struct

+ ImpactStartTime string

+ ImpactStopTime string

+ MaxCu int32

+ MinCu int32

+ Priority int32

+ func (o QueueScalingPolicy) String() string

+ type QueueUserPrivilege struct

+ IsAdmin *bool

+ Privileges *[]string

+ UserName *string

+ func (o QueueUserPrivilege) String() string

+ type QuotaInfo struct

+ Max *int32

+ Min *int32

+ Quota *int32

+ Type *string

+ Used *int32

+ func (o QuotaInfo) String() string

+ type RegisterAuthorizedQueueRequestBody struct

+ Action string

+ Privileges []string

+ QueueName string

+ UserName string

+ func (o RegisterAuthorizedQueueRequestBody) String() string

+ type RegisterBucketRequestBody struct

+ ObsBuckets []string

+ func (o RegisterBucketRequestBody) String() string

+ type RunAuthorizationActionRequestBody struct

+ Action RunAuthorizationActionRequestBodyAction

+ GrantProjectId *string

+ Privileges []Privilege

+ UserName *string

+ func (o RunAuthorizationActionRequestBody) String() string

+ type RunAuthorizationActionRequestBodyAction struct

+ func (c *RunAuthorizationActionRequestBodyAction) UnmarshalJSON(b []byte) error

+ func (c RunAuthorizationActionRequestBodyAction) MarshalJSON() ([]byte, error)

+ func (c RunAuthorizationActionRequestBodyAction) Value() string

+ type RunAuthorizationActionRequestBodyActionEnum struct

+ GRANT RunAuthorizationActionRequestBodyAction

+ REVOKE RunAuthorizationActionRequestBodyAction

+ UPDATE RunAuthorizationActionRequestBodyAction

+ func GetRunAuthorizationActionRequestBodyActionEnum() RunAuthorizationActionRequestBodyActionEnum

+ type RunDataAuthorizationActionRequest struct

+ Body *RunDataAuthorizationActionRequestBody

+ func (o RunDataAuthorizationActionRequest) String() string

+ type RunDataAuthorizationActionRequestBody struct

+ Action string

+ Privileges []DataAuthorizationPrivilege

+ UserName string

+ func (o RunDataAuthorizationActionRequestBody) String() string

+ type RunDataAuthorizationActionResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ func (o RunDataAuthorizationActionResponse) String() string

+ type RunIefJobActionCallBackRequestBody struct

+ MessageId string

+ State *State

+ func (o RunIefJobActionCallBackRequestBody) String() string

+ type RunQueueActionRequestBody struct

+ Action string

+ CuCount *int32

+ Force *bool

+ func (o RunQueueActionRequestBody) String() string

+ type ShowFlinkMetricRequestBody struct

+ JobIds []int64

+ func (o ShowFlinkMetricRequestBody) String() string

+ type ShowJobResourceRequest struct

+ Group *string

+ ResourceName string

+ func (o ShowJobResourceRequest) String() string

+ type ShowJobResourceResponse struct

+ CreateTime *int64

+ HttpStatusCode int

+ Owner *string

+ ResourceName *string

+ ResourceType *string

+ Status *string

+ UnderlyingName *string

+ UpdateTime *int64

+ func (o ShowJobResourceResponse) String() string

+ type ShowSparkJobLogRequest struct

+ BatchId string

+ From *int32

+ Index *int32

+ Size *int32

+ Type *string

+ func (o ShowSparkJobLogRequest) String() string

+ type ShowSparkJobLogResponse struct

+ From *string

+ HttpStatusCode int

+ Id *string

+ Log *[]string

+ Total *int64

+ func (o ShowSparkJobLogResponse) String() string

+ type ShowTableRequest struct

+ DatabaseName string

+ TableName string

+ func (o ShowTableRequest) String() string

+ type ShowTableResponse struct

+ ColumnCount *int32

+ Columns *[]Column

+ CreateTableSql *string

+ DataLocation *string

+ DataType *string

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ StorageProperties *[]interface{}

+ TableComment *string

+ TableType *string

+ func (o ShowTableResponse) String() string

+ type SparkJobGroup struct

+ Name *string

+ Resources *[]SparkJobResource

+ func (o SparkJobGroup) String() string

+ type SparkJobResource struct

+ Name *string

+ Type *string

+ func (o SparkJobResource) String() string

+ type SparkJobSession struct

+ AppId *string

+ ClusterName *string

+ CreateTime *int64

+ Duration *int64

+ Id *string

+ Image *string

+ Kind *string

+ Log *[]string

+ Name *string

+ Owner *string

+ ProxyUser *string

+ Queue *string

+ ReqBody *string

+ ScType *string

+ State *string

+ UpdateTime *int64

+ func (o SparkJobSession) String() string

+ type SparkJobTemplate struct

+ Body *SparkJobTemplateDetail

+ Description *string

+ Group *string

+ Id *string

+ Language *string

+ Name *string

+ Owner *string

+ Type *string

+ func (o SparkJobTemplate) String() string

+ type SparkJobTemplateDetail struct

+ Args *[]string

+ AutoRecovery *bool

+ CatalogName *string

+ ClassName string

+ ClusterName *string

+ Conf map[string]interface{}

+ DriverCores *int32

+ DriverMemory *string

+ ExecutorCores *int32

+ ExecutorMemory *string

+ Feature *SparkJobTemplateDetailFeature

+ File string

+ Files *[]string

+ Groups *[]SparkJobGroup

+ Image *string

+ Jars *[]string

+ MaxRetryTimes *int32

+ Modules *[]string

+ Name *string

+ NumExecutors *int32

+ ObsBucket *string

+ PyFiles *[]string

+ Queue *string

+ Resources *[]SparkJobResource

+ ScType *string

+ SparkVersion *string

+ func (o SparkJobTemplateDetail) String() string

+ type SparkJobTemplateDetailFeature struct

+ func (c *SparkJobTemplateDetailFeature) UnmarshalJSON(b []byte) error

+ func (c SparkJobTemplateDetailFeature) MarshalJSON() ([]byte, error)

+ func (c SparkJobTemplateDetailFeature) Value() string

+ type SparkJobTemplateDetailFeatureEnum struct

+ AI SparkJobTemplateDetailFeature

+ BASIC SparkJobTemplateDetailFeature

+ CUSTOM SparkJobTemplateDetailFeature

+ func GetSparkJobTemplateDetailFeatureEnum() SparkJobTemplateDetailFeatureEnum

+ type SqlJob struct

+ BadRowCount *int64

+ CpuCost *string

+ DatabaseName *string

+ Detail string

+ Duration *int64

+ EndTime *int64

+ InputRowCount *int64

+ InputSize int64

+ JobId string

+ JobType string

+ Message *string

+ OutputByte *string

+ Owner string

+ QueueName string

+ ResultCount int64

+ StartTime int64

+ Statement string

+ Status SqlJobStatus

+ TableName *string

+ Tags *[]Tag

+ WithColumnHeader *bool

+ func (o SqlJob) String() string

+ type SqlJobStatus struct

+ func (c *SqlJobStatus) UnmarshalJSON(b []byte) error

+ func (c SqlJobStatus) MarshalJSON() ([]byte, error)

+ func (c SqlJobStatus) Value() string

+ type SqlJobStatusEnum struct

+ CANCELLED SqlJobStatus

+ FAILED SqlJobStatus

+ FINISHED SqlJobStatus

+ LAUNCHING SqlJobStatus

+ RUNNING SqlJobStatus

+ func GetSqlJobStatusEnum() SqlJobStatusEnum

+ type SqlJobTemplate struct

+ Description *string

+ Group *string

+ Owner *string

+ Sql *string

+ SqlId *string

+ SqlName *string

+ func (o SqlJobTemplate) String() string

+ type SqlSampleTemplate struct

+ Description *string

+ Group *string

+ Lang *string

+ Name *string

+ Sql *string

+ func (o SqlSampleTemplate) String() string

+ type SubJob struct

+ CompletionTime *string

+ Description *string

+ Id *int32

+ JobGroup *string

+ KilledTasksSummary map[string]int32

+ Name *string

+ NumActiveStages *int32

+ NumActiveTasks *int32

+ NumCompletedIndices *int32

+ NumCompletedStages *int32

+ NumCompletedTasks *int32

+ NumFailedStages *int32

+ NumFailedTasks *int32

+ NumKilledTasks *int32

+ NumSkippedStages *int32

+ NumSkippedTasks *int32

+ NumTasks *int32

+ StageIds *[]int32

+ Status *string

+ SubmissionTime *string

+ func (o SubJob) String() string

+ type SuccessResponse struct

+ IsSuccess *bool

+ Message *string

+ func (o SuccessResponse) String() string

+ type TablePrivilege struct

+ Object *string

+ Privileges *[]string

+ func (o TablePrivilege) String() string

+ type TableUserPrivilege struct

+ IsAdmin *bool

+ Object *string

+ Privileges *[]string

+ UserName *string

+ func (o TableUserPrivilege) String() string

+ type Tag struct

+ Key string

+ Value string

+ func (o Tag) String() string

+ type UpdateElasticResourcePoolQueueRequestBody struct

+ QueueScalingPolicies []QueueScalingPolicy

+ func (o UpdateElasticResourcePoolQueueRequestBody) String() string

+ type UpdateEnhancedConnectionRequestBody struct

+ Hosts []EnhancedConnectionHost

+ func (o UpdateEnhancedConnectionRequestBody) String() string

+ type UpdateFlinkJarJobRequestBody struct

+ CheckpointPath *string

+ CuNumber *int32

+ DependencyFiles *[]string

+ DependencyJars *[]string

+ Desc *string

+ Entrypoint *string

+ EntrypointArgs *string

+ Feature *string

+ FlinkVersion *string

+ Image *string

+ JobType *string

+ LogEnabled *bool

+ MainClass *string

+ ManagerCuNumber *int32

+ Name *string

+ ObsBucket *string

+ ParallelNumber *int32

+ QueueName *string

+ RestartWhenException *bool

+ ResumeCheckpoint *bool

+ ResumeMaxNum *int32

+ RuntimeConfig *string

+ SmnTopic *string

+ TmCus *int32

+ TmSlotNum *int32

+ func (o UpdateFlinkJarJobRequestBody) String() string

+ type UpdateFlinkJobStatusReportRequest struct

+ Body *ChangeFlinkJobStatusReportRequestBody

+ func (o UpdateFlinkJobStatusReportRequest) String() string

+ type UpdateFlinkJobStatusReportResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ func (o UpdateFlinkJobStatusReportResponse) String() string

+ type UpdateFlinkSqlJobRequestBody struct

+ CheckpointEnabled *bool

+ CheckpointInterval *int32

+ CheckpointMode *int32

+ CuNumber *int32

+ Desc *string

+ DirtyDataStrategy *string

+ EdgeGroupIds *[]string

+ FlinkVersion *string

+ IdleStateRetention *int32

+ LogEnabled *bool

+ ManagerCuNumber *int32

+ Name *string

+ ObsBucket *string

+ OperatorConfig *string

+ ParallelNumber *int32

+ QueueName *string

+ RestartWhenException *bool

+ ResumeCheckpoint *bool

+ ResumeMaxNum *int32

+ RunMode *string

+ RuntimeConfig *string

+ SmnTopic *string

+ SqlBody *string

+ StaticEstimatorConfig *string

+ TmCus *int32

+ TmSlotNum *int32

+ UdfJarUrl *string

+ func (o UpdateFlinkSqlJobRequestBody) String() string

+ type UpdateFlinkSqlJobTemplateRequestBody struct

+ Desc *string

+ Name *string

+ SqlBody *string

+ func (o UpdateFlinkSqlJobTemplateRequestBody) String() string

+ type UpdateGlobalVariableRequestBody struct

+ VarValue string

+ func (o UpdateGlobalVariableRequestBody) String() string

+ type UpdateJobResourceOwnerRequest struct

+ Body *UpdateJobResourceOwnerRequestBody

+ func (o UpdateJobResourceOwnerRequest) String() string

+ type UpdateJobResourceOwnerRequestBody struct

+ GroupName string

+ NewOwner string

+ ResourceName *string

+ func (o UpdateJobResourceOwnerRequestBody) String() string

+ type UpdateJobResourceOwnerResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ func (o UpdateJobResourceOwnerResponse) String() string

+ type UpdateQueueCidrRequestBody struct

+ CidrInVpc *string

+ func (o UpdateQueueCidrRequestBody) String() string

+ type UpdateQueuePlanRequest struct

+ Body *QueuePlanRequestBody

+ PlanId string

+ QueueName string

+ func (o UpdateQueuePlanRequest) String() string

+ type UpdateQueuePlanResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ PlanId *string

+ QueueName *string

+ func (o UpdateQueuePlanResponse) String() string

+ type UpdateSparkJobTemplateRequestBody struct

+ Body string

+ Description *string

+ Group *string

+ Name string

+ func (o UpdateSparkJobTemplateRequestBody) String() string

+ type UpdateSqlJobTemplateRequestBody struct

+ Description *string

+ Group *string

+ Sql *string

+ SqlName *string

+ func (o UpdateSqlJobTemplateRequestBody) String() string

+ type UploadFileJobResourcesRequest struct

+ Body *UploadResourcesRequestBody

+ UserId *string

+ func (o UploadFileJobResourcesRequest) String() string

+ type UploadFileJobResourcesResponse struct

+ CreateTime *int64

+ Description *string

+ Details *[]UploadJobResourcesDetail

+ GroupName *string

+ HttpStatusCode int

+ IsAsync *bool

+ ModuleName *string

+ ModuleType *string

+ Owner *string

+ Resources *[]string

+ Status *string

+ UpdateTime *int64

+ func (o UploadFileJobResourcesResponse) String() string

+ type UploadJarJobResourcesRequest struct

+ Body *UploadResourcesRequestBody

+ UserId *string

+ func (o UploadJarJobResourcesRequest) String() string

+ type UploadJarJobResourcesResponse struct

+ CreateTime *int64

+ Description *string

+ Details *[]UploadJobResourcesDetail

+ GroupName *string

+ HttpStatusCode int

+ IsAsync *bool

+ ModuleName *string

+ ModuleType *string

+ Owner *string

+ Resources *[]string

+ Status *string

+ UpdateTime *int64

+ func (o UploadJarJobResourcesResponse) String() string

+ type UploadJobResourcesDetail struct

+ CreateTime int64

+ IsAsync *bool

+ ResourceName *string

+ ResourceType string

+ Status *string

+ UnderlyingName *string

+ UpdateTime *int64

+ func (o UploadJobResourcesDetail) String() string

+ type UploadJobResourcesRequest struct

+ Body *UploadJobResourcesRequestBody

+ UserId *string

+ func (o UploadJobResourcesRequest) String() string

+ type UploadJobResourcesRequestBody struct

+ Group string

+ IsAsync *bool

+ Kind string

+ Paths []string

+ Tags *[]Tag

+ func (o UploadJobResourcesRequestBody) String() string

+ type UploadJobResourcesResponse struct

+ CreateTime *int64

+ Details *[]UploadJobResourcesDetail

+ GroupName *string

+ HttpStatusCode int

+ IsAsync *bool

+ Owner *string

+ Resources *[]string

+ Status *string

+ UpdateTime *int64

+ func (o UploadJobResourcesResponse) String() string

+ type UploadPythonFileJobResourcesRequest struct

+ Body *UploadResourcesRequestBody

+ UserId *string

+ func (o UploadPythonFileJobResourcesRequest) String() string

+ type UploadPythonFileJobResourcesResponse struct

+ CreateTime *int64

+ Description *string

+ Details *[]UploadJobResourcesDetail

+ GroupName *string

+ HttpStatusCode int

+ IsAsync *bool

+ ModuleName *string

+ ModuleType *string

+ Owner *string

+ Resources *[]string

+ Status *string

+ UpdateTime *int64

+ func (o UploadPythonFileJobResourcesResponse) String() string

+ type UploadResourcesRequestBody struct

+ Group string

+ Paths []string

+ func (o UploadResourcesRequestBody) String() string

v0.1.87

Mar 21, 2024

Changes in this version

type AuthorizeResourceRequestBody

+ GrantProjectId *string

+ type CatalogEntity struct

+ CreateTime *int64

+ Description *string

+ Name *string

+ Parameters map[string]string

+ func (o CatalogEntity) String() string

+ type ElasticResourcePoolScaleRecord struct

+ CurrentCu int32

+ FailReason *string

+ MaxCu int32

+ MinCu int32

+ OriginCu int32

+ RecordTime int64

+ Status string

+ TargetCu int32

+ func (o ElasticResourcePoolScaleRecord) String() string

+ type ListCatalogsRequest struct

+ Limit *int32

+ Offset *int32

+ func (o ListCatalogsRequest) String() string

+ type ListCatalogsResponse struct

+ Catalogs *[]CatalogEntity

+ HttpStatusCode int

+ IsSuccess *bool

+ TotalCount *int64

+ func (o ListCatalogsResponse) String() string

+ type RunCatalogActionRequest struct

+ Body *RunCatalogActionRequestBody

+ func (o RunCatalogActionRequest) String() string

+ type RunCatalogActionRequestBody struct

+ Action RunCatalogActionRequestBodyAction

+ Name string

+ Parameters map[string]string

+ func (o RunCatalogActionRequestBody) String() string

+ type RunCatalogActionRequestBodyAction struct

+ func (c *RunCatalogActionRequestBodyAction) UnmarshalJSON(b []byte) error

+ func (c RunCatalogActionRequestBodyAction) MarshalJSON() ([]byte, error)

+ func (c RunCatalogActionRequestBodyAction) Value() string

+ type RunCatalogActionRequestBodyActionEnum struct

+ BIND RunCatalogActionRequestBodyAction

+ UNBIND RunCatalogActionRequestBodyAction

+ func GetRunCatalogActionRequestBodyActionEnum() RunCatalogActionRequestBodyActionEnum

+ type RunCatalogActionResponse struct

+ Body *string

+ HttpStatusCode int

+ func (o RunCatalogActionResponse) String() string

+ type ShowCatalogRequest struct

+ CatalogName string

+ func (o ShowCatalogRequest) String() string

+ type ShowCatalogResponse struct

+ CreateTime *int64

+ HttpStatusCode int

+ IsSuccess *bool

+ Name *string

+ Parameters map[string]string

+ func (o ShowCatalogResponse) String() string

v0.1.86

Mar 14, 2024

v0.1.85

Mar 7, 2024

Changes in this version

+ type AuthorizationPrivilege struct

+ IsAdmin *bool

+ Object *string

+ Privileges *[]string

+ UserName *string

+ func (o AuthorizationPrivilege) String() string

v0.1.84

Feb 29, 2024

Changes in this version

type CreateEnhancedConnectionsReq

+ ElasticResourcePools *[]string

type GenStreamGraphReq

+ FlinkVersion *string

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

+ type CreateRouteToEnhancedConnectionRequest struct

+ Body *CreateRouteToEnhancedConnectionRequestBody

+ ConnectionId string

+ func (o CreateRouteToEnhancedConnectionRequest) String() string

+ type CreateRouteToEnhancedConnectionRequestBody struct

+ Cidr string

+ Name string

+ func (o CreateRouteToEnhancedConnectionRequestBody) String() string

+ type CreateRouteToEnhancedConnectionResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ func (o CreateRouteToEnhancedConnectionResponse) String() string

+ type DeleteRouteFromEnhancedConnectionRequest struct

+ ConnectionId string

+ Name string

+ func (o DeleteRouteFromEnhancedConnectionRequest) String() string

+ type DeleteRouteFromEnhancedConnectionResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ func (o DeleteRouteFromEnhancedConnectionResponse) String() string

v0.1.71

Dec 7, 2023

Changes in this version

+ type CreateJobAuthInfoRequest struct

+ Body *CreateJobAuthInfoRequestBody

+ func (o CreateJobAuthInfoRequest) String() string

+ type CreateJobAuthInfoRequestBody struct

+ AuthInfoName string

+ CertificateLocation *string

+ DatasourceType string

+ KeyPassword *string

+ KeystoreLocation *string

+ KeystorePassword *string

+ Keytab *string

+ Krb5Conf *string

+ Password *string

+ TruststoreLocation *string

+ TruststorePassword *string

+ UserName *string

+ func (o CreateJobAuthInfoRequestBody) String() string

+ type CreateJobAuthInfoResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ func (o CreateJobAuthInfoResponse) String() string

+ type DeleteJobAuthInfoRequest struct

+ AuthInfoName string

+ func (o DeleteJobAuthInfoRequest) String() string

+ type DeleteJobAuthInfoResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ func (o DeleteJobAuthInfoResponse) String() string

+ type ListJobAuthInfosRequest struct

+ AuthInfoName *string

+ Limit *int32

+ Offset *int32

+ func (o ListJobAuthInfosRequest) String() string

+ type ListJobAuthInfosResponse struct

+ AuthInfos *[]AuthInfos

+ Count *int32

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ func (o ListJobAuthInfosResponse) String() string

+ type UpdateJobAuthInfoRequest struct

+ Body *UpdateJobAuthInfoRequestBody

+ func (o UpdateJobAuthInfoRequest) String() string

+ type UpdateJobAuthInfoRequestBody struct

+ AuthInfoName string

+ KeystoreLocation *string

+ KeystorePassword *string

+ Keytab *string

+ Krb5Conf *string

+ Password *string

+ TruststoreLocation *string

+ TruststorePassword *string

+ UserName *string

+ func (o UpdateJobAuthInfoRequestBody) String() string

+ type UpdateJobAuthInfoResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ func (o UpdateJobAuthInfoResponse) String() string

v0.1.70

Nov 30, 2023

Changes in this version

type ListQueuePropertiesRequest

+ Limit *int32

+ Offset *int32

+ type ShowQuotaPropertiesBody struct

+ Max *int32

+ Min *int32

+ Quota *int32

+ Type *string

+ Used *int32

+ func (o ShowQuotaPropertiesBody) String() string

+ type ShowQuotaRequest struct

+ func (o ShowQuotaRequest) String() string

+ type ShowQuotaResponse struct

+ HttpStatusCode int

+ Quotas *ShowQuotaResponseBodyQuotas

+ func (o ShowQuotaResponse) String() string

+ type ShowQuotaResponseBodyQuotas struct

+ ProjectId *string

+ Resources *[]ShowQuotaPropertiesBody

+ func (o ShowQuotaResponseBodyQuotas) String() string

v0.1.69

Nov 23, 2023

v0.1.68

Nov 23, 2023

Changes in this version

+ type AssociateQueueToEnhancedConnectionRequest struct

+ Body *AssociateConnectionQueueReq

+ ConnectionId string

+ func (o AssociateQueueToEnhancedConnectionRequest) String() string

+ type AssociateQueueToEnhancedConnectionResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ func (o AssociateQueueToEnhancedConnectionResponse) String() string

+ type BatchDeleteSqlJobTemplatesRequest struct

+ Body *DeleteSqlTemplatesRequestBody

+ func (o BatchDeleteSqlJobTemplatesRequest) String() string

+ type BatchDeleteSqlJobTemplatesResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ func (o BatchDeleteSqlJobTemplatesResponse) String() string

+ type CancelSparkJobRequest struct

+ BatchId string

+ func (o CancelSparkJobRequest) String() string

+ type CancelSparkJobResponse struct

+ HttpStatusCode int

+ Msg *string

+ func (o CancelSparkJobResponse) String() string

+ type CreateConnectivityTaskRequest struct

+ Body *VerityConnectivityReq

+ QueueName string

+ func (o CreateConnectivityTaskRequest) String() string

+ type CreateConnectivityTaskResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ TaskId *string

+ func (o CreateConnectivityTaskResponse) String() string

+ type CreateFlinkJarJobRequest struct

+ Body *CreateFlinkJarRequestBody

+ func (o CreateFlinkJarJobRequest) String() string

+ type CreateFlinkJarJobResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Job *CreateJobRespJob

+ Message *string

+ func (o CreateFlinkJarJobResponse) String() string

+ type CreateFlinkSqlJobGraphRequest struct

+ Body *GenStreamGraphReq

+ JobId string

+ func (o CreateFlinkSqlJobGraphRequest) String() string

+ type CreateFlinkSqlJobGraphResponse struct

+ ErrorCode *string

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ StreamGraph *string

+ func (o CreateFlinkSqlJobGraphResponse) String() string

+ type CreateFlinkSqlJobTemplateRequest struct

+ Body *CreateFlinkTemplateRequestBody

+ func (o CreateFlinkSqlJobTemplateRequest) String() string

+ type CreateFlinkSqlJobTemplateResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ Template *FlinkTemplate

+ func (o CreateFlinkSqlJobTemplateResponse) String() string

+ type CreateGlobalVariableRequest struct

+ Body *CreateGlobalValueReq

+ func (o CreateGlobalVariableRequest) String() string

+ type CreateGlobalVariableResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ func (o CreateGlobalVariableResponse) String() string

+ type CreateSparkJobRequest struct

+ Body *BatchJobInfo

+ UserId *string

+ func (o CreateSparkJobRequest) String() string

+ type CreateSparkJobResponse struct

+ AppId *string

+ ClusterName *string

+ CreateTime *int64

+ Duration *int64

+ HttpStatusCode int

+ Id *string

+ Image *string

+ Kind *string

+ Log *[]string

+ Name *string

+ Owner *string

+ ProxyUser *string

+ Queue *string

+ ScType *string

+ State *string

+ UpdateTime *int64

+ func (o CreateSparkJobResponse) String() string

+ type CreateSparkJobTemplateRequest struct

+ Body *CreateJobTemplatesRequestBody

+ func (o CreateSparkJobTemplateRequest) String() string

+ type CreateSparkJobTemplateResponse struct

+ HttpStatusCode int

+ Id *string

+ func (o CreateSparkJobTemplateResponse) String() string

+ type CreateSqlJobTemplateRequest struct

+ Body *CreateSqlTemplatesRequestBody

+ func (o CreateSqlJobTemplateRequest) String() string

+ type CreateSqlJobTemplateResponse struct

+ Group *string

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ SqlId *string

+ func (o CreateSqlJobTemplateResponse) String() string

+ type DeleteFlinkSqlJobTemplateRequest struct

+ TemplateId int64

+ func (o DeleteFlinkSqlJobTemplateRequest) String() string

+ type DeleteFlinkSqlJobTemplateResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ Template *DeleteTemplateRespTemplate

+ func (o DeleteFlinkSqlJobTemplateResponse) String() string

+ type DeleteGlobalVariableRequest struct

+ VarName string

+ func (o DeleteGlobalVariableRequest) String() string

+ type DeleteGlobalVariableResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ func (o DeleteGlobalVariableResponse) String() string

+ type DisassociateQueueFromEnhancedConnectionRequest struct

+ Body *DisassociateConnectionQueueReq

+ ConnectionId string

+ func (o DisassociateQueueFromEnhancedConnectionRequest) String() string

+ type DisassociateQueueFromEnhancedConnectionResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ func (o DisassociateQueueFromEnhancedConnectionResponse) String() string

+ type ExportFlinkJobsRequest struct

+ Body *ExportFlinkJobRequestBody

+ func (o ExportFlinkJobsRequest) String() string

+ type ExportFlinkJobsResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ ZipFile *[]string

+ func (o ExportFlinkJobsResponse) String() string

+ type ImportFlinkJobsRequest struct

+ Body *ImportFlinkJobRequestBody

+ func (o ImportFlinkJobsRequest) String() string

+ type ImportFlinkJobsResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ JobMapping *[]JobMapInfo

+ Message *string

+ func (o ImportFlinkJobsResponse) String() string

+ type ListAuthorizationPrivilegesRequest struct

+ Object string

+ func (o ListAuthorizationPrivilegesRequest) String() string

+ type ListAuthorizationPrivilegesResponse struct

+ Count *int32

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ ObjectName *string

+ ObjectType *string

+ Privileges *[]ShowDatabaseUsersPrivilege

+ func (o ListAuthorizationPrivilegesResponse) String() string

+ type ListFlinkSqlJobTemplatesRequest struct

+ Limit *int32

+ Name *string

+ Offset *int64

+ Order *string

+ Tags *string

+ func (o ListFlinkSqlJobTemplatesRequest) String() string

+ type ListFlinkSqlJobTemplatesResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ TemplateList *FlinkTemplateList

+ func (o ListFlinkSqlJobTemplatesResponse) String() string

+ type ListGlobalVariablesRequest struct

+ Limit *int32

+ Offset *int32

+ func (o ListGlobalVariablesRequest) String() string

+ type ListGlobalVariablesResponse struct

+ Count *int32

+ GlobalVars *[]ListGlobalValue

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ func (o ListGlobalVariablesResponse) String() string

+ type ListQueuePropertiesRequest struct

+ Page *int32

+ PageSize *int32

+ QueueName string

+ func (o ListQueuePropertiesRequest) String() string

+ type ListQueuePropertiesResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ Properties *[]ListQueuePropertyRespProperties

+ func (o ListQueuePropertiesResponse) String() string

+ type ListSparkJobTemplatesRequest struct

+ CurrentPage *int32

+ Keyword *string

+ PageSize *int32

+ Type *string

+ func (o ListSparkJobTemplatesRequest) String() string

+ type ListSparkJobTemplatesResponse struct

+ Count *int32

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ Templates *[]JobTemplateInfo

+ func (o ListSparkJobTemplatesResponse) String() string

+ type ListSparkJobsRequest struct

+ ClusterName *string

+ End *int64

+ From *int32

+ JobId *string

+ JobName *string

+ Order *string

+ QueueName *string

+ Size *int32

+ Start *int64

+ State *string

+ func (o ListSparkJobsRequest) String() string

+ type ListSparkJobsResponse struct

+ CreateTime *int64

+ From *int32

+ HttpStatusCode int

+ Sessions *[]ShowBatchJobDetailResp

+ Total *int32

+ func (o ListSparkJobsResponse) String() string

+ type ListSqlJobTemplatesRequest struct

+ Keyword *string

+ func (o ListSqlJobTemplatesRequest) String() string

+ type ListSqlJobTemplatesResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ SqlCount *int32

+ Sqls *[]SqlsResp

+ func (o ListSqlJobTemplatesResponse) String() string

+ type PreviewSqlJobResultRequest struct

+ JobId string

+ QueueName *string

+ func (o PreviewSqlJobResultRequest) String() string

+ type PreviewSqlJobResultResponse struct

+ HttpStatusCode int

+ InputSize *int64

+ IsSuccess *bool

+ JobId *string

+ JobType *PreviewSqlJobResultResponseJobType

+ Message *string

+ RowCount *int32

+ Rows *[][]string

+ Schema *[]interface{}

+ func (o PreviewSqlJobResultResponse) String() string

+ type PreviewSqlJobResultResponseJobType struct

+ func (c *PreviewSqlJobResultResponseJobType) UnmarshalJSON(b []byte) error

+ func (c PreviewSqlJobResultResponseJobType) MarshalJSON() ([]byte, error)

+ func (c PreviewSqlJobResultResponseJobType) Value() string

+ type PreviewSqlJobResultResponseJobTypeEnum struct

+ DCL PreviewSqlJobResultResponseJobType

+ DDL PreviewSqlJobResultResponseJobType

+ EXPORT PreviewSqlJobResultResponseJobType

+ IMPORT PreviewSqlJobResultResponseJobType

+ INSERT PreviewSqlJobResultResponseJobType

+ QUERY PreviewSqlJobResultResponseJobType

+ func GetPreviewSqlJobResultResponseJobTypeEnum() PreviewSqlJobResultResponseJobTypeEnum

+ type RunAuthorizationActionRequest struct

+ Body *AuthorizeResourceRequestBody

+ func (o RunAuthorizationActionRequest) String() string

+ type RunAuthorizationActionResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ func (o RunAuthorizationActionResponse) String() string

+ type ShowConnectivityTaskRequest struct

+ QueueName string

+ TaskId string

+ func (o ShowConnectivityTaskRequest) String() string

+ type ShowConnectivityTaskResponse struct

+ Connectivity *string

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ func (o ShowConnectivityTaskResponse) String() string

+ type ShowEnhancedConnectionPrivilegeRequest struct

+ ConnectionId string

+ func (o ShowEnhancedConnectionPrivilegeRequest) String() string

+ type ShowEnhancedConnectionPrivilegeResponse struct

+ ConnectionId *string

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ Privileges *[]ProjectPrivilege

+ func (o ShowEnhancedConnectionPrivilegeResponse) String() string

+ type ShowFlinkJobExecutionGraphRequest struct

+ JobId int64

+ func (o ShowFlinkJobExecutionGraphRequest) String() string

+ type ShowFlinkJobExecutionGraphResponse struct

+ ExecuteGraph *StreamGraphInfo

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ func (o ShowFlinkJobExecutionGraphResponse) String() string

+ type ShowQueueRequest struct

+ QueueName string

+ func (o ShowQueueRequest) String() string

+ type ShowQueueResponse struct

+ ChargingMode *int32

+ CreateTime *int64

+ CuCount *int32

+ CuScaleInLimit *int32

+ CuScaleOutLimit *int32

+ CuSpec *int32

+ Description *string

+ ElasticResourcePoolName *string

+ EnterpriseProjectId *string

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ Owner *string

+ QueueId *int64

+ QueueName *string

+ QueueType *string

+ ResourceId *string

+ ResourceMode *int32

+ ResourceType *string

+ func (o ShowQueueResponse) String() string

+ type ShowSparkJobRequest struct

+ BatchId string

+ func (o ShowSparkJobRequest) String() string

+ type ShowSparkJobResponse struct

+ AppId *string

+ ClusterName *string

+ CreateTime *int64

+ Feature *string

+ HttpStatusCode int

+ Id *string

+ Image *string

+ Kind *string

+ Log *[]string

+ Name *string

+ Owner *string

+ ProxyUser *string

+ Queue *string

+ ReqBody *string

+ ScType *string

+ SparkVersion *string

+ State *string

+ UpdateTime *int64

+ func (o ShowSparkJobResponse) String() string

+ type ShowSparkJobStatusRequest struct

+ BatchId string

+ func (o ShowSparkJobStatusRequest) String() string

+ type ShowSparkJobStatusResponse struct

+ HttpStatusCode int

+ Id *string

+ State *string

+ func (o ShowSparkJobStatusResponse) String() string

+ type ShowSparkJobTemplateRequest struct

+ TemplateId string

+ func (o ShowSparkJobTemplateRequest) String() string

+ type ShowSparkJobTemplateResponse struct

+ Body *BatchJobInfo

+ Description *string

+ Group *string

+ HttpStatusCode int

+ Id *string

+ Language *string

+ Name *string

+ Owner *string

+ Type *string

+ func (o ShowSparkJobTemplateResponse) String() string

+ type ShowSqlJobProgressRequest struct

+ JobId string

+ func (o ShowSqlJobProgressRequest) String() string

+ type ShowSqlJobProgressResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ JobId *string

+ Message *string

+ Progress *float64

+ Status *string

+ SubJobId *int32

+ SubJobs *[]SubJobDatas

+ func (o ShowSqlJobProgressResponse) String() string

+ type UpdateElasticResourcePoolQueueRequest struct

+ Body *UpdateElasticResourcePoolQueueScalingPolicyInfo

+ ElasticResourcePoolName string

+ QueueName string

+ func (o UpdateElasticResourcePoolQueueRequest) String() string

+ type UpdateElasticResourcePoolQueueResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ func (o UpdateElasticResourcePoolQueueResponse) String() string

+ type UpdateEnhancedConnectionRequest struct

+ Body *UpdateHostMassageReq

+ ConnectionId string

+ func (o UpdateEnhancedConnectionRequest) String() string

+ type UpdateEnhancedConnectionResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ func (o UpdateEnhancedConnectionResponse) String() string

+ type UpdateFlinkJarJobRequest struct

+ Body *UpdateFlinkJarRequestBody

+ JobId int64

+ func (o UpdateFlinkJarJobRequest) String() string

+ type UpdateFlinkJarJobResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Job *UpdateJobRespJob

+ Message *string

+ func (o UpdateFlinkJarJobResponse) String() string

+ type UpdateFlinkSqlJobRequest struct

+ Body *UpdateFlinkSqlRequestBody

+ JobId int64

+ func (o UpdateFlinkSqlJobRequest) String() string

+ type UpdateFlinkSqlJobResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Job *UpdateJobRespJob

+ Message *string

+ func (o UpdateFlinkSqlJobResponse) String() string

+ type UpdateFlinkSqlJobTemplateRequest struct

+ Body *UpdateFlinkTemplateRequestBody

+ TemplateId int64

+ func (o UpdateFlinkSqlJobTemplateRequest) String() string

+ type UpdateFlinkSqlJobTemplateResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ func (o UpdateFlinkSqlJobTemplateResponse) String() string

+ type UpdateGlobalVariableRequest struct

+ Body *UpdateGlobalValueReq

+ VarName string

+ func (o UpdateGlobalVariableRequest) String() string

+ type UpdateGlobalVariableResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ func (o UpdateGlobalVariableResponse) String() string

+ type UpdateSparkJobTemplateRequest struct

+ Body *UpdateJobTemplatesRequestBody

+ TemplateId string

+ func (o UpdateSparkJobTemplateRequest) String() string

+ type UpdateSparkJobTemplateResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ func (o UpdateSparkJobTemplateResponse) String() string

+ type UpdateSqlJobTemplateRequest struct

+ Body *UpdateSqlTemplatesRequestBody

+ SqlId string

+ func (o UpdateSqlJobTemplateRequest) String() string

+ type UpdateSqlJobTemplateResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ func (o UpdateSqlJobTemplateResponse) String() string

v0.1.67

Nov 16, 2023

Changes in this version

type ShowSqlJobStatusResponse

+ ResultFormat *string

+ ResultPath *string

v0.1.66

Nov 13, 2023

Changes in this version

type ElasticResourcePoolsResponse

+ Id *int32

v0.1.65

Nov 9, 2023

Changes in this version

+ type CreateQueuePropertyRequest struct

+ Body *InsertQueuePropertyRequestBody

+ QueueName string

+ func (o CreateQueuePropertyRequest) String() string

+ type CreateQueuePropertyResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ func (o CreateQueuePropertyResponse) String() string

+ type DeleteQueuePropertiesRequestBody struct

+ Keys []string

+ func (o DeleteQueuePropertiesRequestBody) String() string

+ type DeleteQueuePropertyRequest struct

+ Body *DeleteQueuePropertiesRequestBody

+ QueueName string

+ func (o DeleteQueuePropertyRequest) String() string

+ type DeleteQueuePropertyResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ func (o DeleteQueuePropertyResponse) String() string

+ type InsertQueuePropertyRequestBody struct

+ Properties *InsertQueuePropertyRequestBodyProperties

+ func (o InsertQueuePropertyRequestBody) String() string

+ type InsertQueuePropertyRequestBodyProperties struct

+ ComputeEngineMaxInstance *int32

+ ComputeEngineMaxPrefetchInstance *int32

+ JobMaxConcurrent *int32

+ func (o InsertQueuePropertyRequestBodyProperties) String() string

+ type ListQueuePropertyRequest struct

+ Page *int32

+ PageSize *int32

+ QueueName string

+ func (o ListQueuePropertyRequest) String() string

+ type ListQueuePropertyRespProperties struct

+ Key ListQueuePropertyRespPropertiesKey

+ Value string

+ func (o ListQueuePropertyRespProperties) String() string

+ type ListQueuePropertyRespPropertiesKey struct

+ func (c *ListQueuePropertyRespPropertiesKey) UnmarshalJSON(b []byte) error

+ func (c ListQueuePropertyRespPropertiesKey) MarshalJSON() ([]byte, error)

+ func (c ListQueuePropertyRespPropertiesKey) Value() string

+ type ListQueuePropertyRespPropertiesKeyEnum struct

+ COMPUTE_ENGINE_MAX_INSTANCES ListQueuePropertyRespPropertiesKey

+ COMPUTE_ENGINE_MAX_PREFETCH_INSTANCE ListQueuePropertyRespPropertiesKey

+ JOB_MAX_CONCURRENT ListQueuePropertyRespPropertiesKey

+ MULTIPLE_SC_SUPPORT ListQueuePropertyRespPropertiesKey

+ func GetListQueuePropertyRespPropertiesKeyEnum() ListQueuePropertyRespPropertiesKeyEnum

+ type ListQueuePropertyResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ Properties *[]ListQueuePropertyRespProperties

+ func (o ListQueuePropertyResponse) String() string

type ShowSqlJobStatusResponse

+ UserConf *string

+ type UpdateQueuePropertyRequest struct

+ Body *UpdateQueuePropertyRequestBody

+ QueueName string

+ func (o UpdateQueuePropertyRequest) String() string

+ type UpdateQueuePropertyRequestBody struct

+ Properties *UpdateQueuePropertyRequestBodyProperties

+ func (o UpdateQueuePropertyRequestBody) String() string

+ type UpdateQueuePropertyRequestBodyProperties struct

+ ComputeEngineMaxInstance *int32

+ ComputeEngineMaxPrefetchInstance *int32

+ JobMaxConcurrent *int32

+ NetworkCidrInVpc *string

+ func (o UpdateQueuePropertyRequestBodyProperties) String() string

+ type UpdateQueuePropertyResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ func (o UpdateQueuePropertyResponse) String() string

v0.1.64

Nov 2, 2023

v0.1.63

Oct 26, 2023

Changes in this version

type ListBatchesRequest

+ JobName *string

v0.1.62

Oct 19, 2023

v0.1.61

Oct 12, 2023

v0.1.60

Sep 19, 2023

v0.1.59

Sep 14, 2023

Changes in this version

type CreateBatchJobResponse

+ ReqBody *string

type ShowBatchInfoResponse

+ ReqBody *string

type ShowBatchJobDetailResp

+ ReqBody *string

v0.1.58

Sep 7, 2023

v0.1.57

Aug 31, 2023

Changes in this version

type ListJobsJobs

+ CpuCost *string

+ OutputByte *string

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

+ type AssociateConnectionQueueReq struct

+ ElasticResourcePools *[]string

+ Queues *[]string

+ func (o AssociateConnectionQueueReq) String() string

+ type AssociateConnectionQueueRequest struct

+ Body *AssociateConnectionQueueReq

+ ConnectionId string

+ func (o AssociateConnectionQueueRequest) String() string

+ type AssociateConnectionQueueResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ func (o AssociateConnectionQueueResponse) String() string

+ type AssociateQueueToElasticResourcePoolRequest struct

+ Body *AssociateQueueToElasticResourcePoolRequestBody

+ ElasticResourcePoolName string

+ func (o AssociateQueueToElasticResourcePoolRequest) String() string

+ type AssociateQueueToElasticResourcePoolRequestBody struct

+ QueueName string

+ func (o AssociateQueueToElasticResourcePoolRequestBody) String() string

+ type AssociateQueueToElasticResourcePoolResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ func (o AssociateQueueToElasticResourcePoolResponse) String() string

+ type AuthInfos struct

+ AuthInfoName *string

+ CertificateLocation *string

+ CreateTime *int64

+ DatasourceType *string

+ KeystoreLocation *string

+ Keytab *string

+ Krb5Conf *string

+ Owner *string

+ TruststoreLocation *string

+ UpdateTime *int64

+ UserName *string

+ func (o AuthInfos) String() string

+ type AuthorizeResourceRequest struct

+ Body *AuthorizeResourceRequestBody

+ func (o AuthorizeResourceRequest) String() string

+ type AuthorizeResourceRequestBody struct

+ Action AuthorizeResourceRequestBodyAction

+ Privileges []Privilege

+ ProjectId *string

+ UserName *string

+ func (o AuthorizeResourceRequestBody) String() string

+ type AuthorizeResourceRequestBodyAction struct

+ func (c *AuthorizeResourceRequestBodyAction) UnmarshalJSON(b []byte) error

+ func (c AuthorizeResourceRequestBodyAction) MarshalJSON() ([]byte, error)

+ func (c AuthorizeResourceRequestBodyAction) Value() string

+ type AuthorizeResourceRequestBodyActionEnum struct

+ GRANT AuthorizeResourceRequestBodyAction

+ REVOKE AuthorizeResourceRequestBodyAction

+ UPDATE AuthorizeResourceRequestBodyAction

+ func GetAuthorizeResourceRequestBodyActionEnum() AuthorizeResourceRequestBodyActionEnum

+ type AuthorizeResourceResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ func (o AuthorizeResourceResponse) String() string

+ type AvailableQueueInfo struct

+ ErrMsg *string

+ Name *string

+ Status *string

+ UpdateTime *int64

+ Uuid *string

+ func (o AvailableQueueInfo) String() string

+ type BatchDeleteFlinkJobsRequest struct

+ Body *BatchDeleteFlinkJobsRequestBody

+ func (o BatchDeleteFlinkJobsRequest) String() string

+ type BatchDeleteFlinkJobsRequestBody struct

+ JobIds []int64

+ func (o BatchDeleteFlinkJobsRequestBody) String() string

+ type BatchDeleteFlinkJobsResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ func (o BatchDeleteFlinkJobsResponse) String() string

+ type BatchDeleteQueuePlansRequest struct

+ Body *QueuePlanIds

+ QueueName string

+ func (o BatchDeleteQueuePlansRequest) String() string

+ type BatchDeleteQueuePlansResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ func (o BatchDeleteQueuePlansResponse) String() string

+ type BatchJobInfo struct

+ Args *[]string

+ AutoRecovery *bool

+ CatalogName *string

+ ClassName string

+ ClusterName *string

+ Conf map[string]interface{}

+ DriverCores *int32

+ DriverMemory *string

+ ExecutorCores *int32

+ ExecutorMemory *string

+ Feature *BatchJobInfoFeature

+ File string

+ Files *[]string

+ Groups *[]CreateSessionReqGroup

+ Image *string

+ Jars *[]string

+ MaxRetryTimes *int32

+ Modules *[]string

+ Name *string

+ NumExecutors *int32

+ ObsBucket *string

+ PyFiles *[]string

+ Queue *string

+ Resources *[]CreateSessionReqResource

+ ScType *string

+ SparkVersion *string

+ func (o BatchJobInfo) String() string

+ type BatchJobInfoFeature struct

+ func (c *BatchJobInfoFeature) UnmarshalJSON(b []byte) error

+ func (c BatchJobInfoFeature) MarshalJSON() ([]byte, error)

+ func (c BatchJobInfoFeature) Value() string

+ type BatchJobInfoFeatureEnum struct

+ AI BatchJobInfoFeature

+ BASIC BatchJobInfoFeature

+ CUSTOM BatchJobInfoFeature

+ func GetBatchJobInfoFeatureEnum() BatchJobInfoFeatureEnum

+ type BatchRunFlinkJobsRequest struct

+ Body *BatchRunFlinkJobsRequestBody

+ func (o BatchRunFlinkJobsRequest) String() string

+ type BatchRunFlinkJobsRequestBody struct

+ JobIds []int64

+ ResumeSavepoint *bool

+ func (o BatchRunFlinkJobsRequestBody) String() string

+ type BatchRunFlinkJobsResponse struct

+ Body *[]CommonResp

+ HttpStatusCode int

+ func (o BatchRunFlinkJobsResponse) String() string

+ type CancelBatchJobRequest struct

+ BatchId string

+ func (o CancelBatchJobRequest) String() string

+ type CancelBatchJobResponse struct

+ HttpStatusCode int

+ Msg *string

+ func (o CancelBatchJobResponse) String() string

+ type CancelSqlJobRequest struct

+ JobId string

+ func (o CancelSqlJobRequest) String() string

+ type CancelSqlJobResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ func (o CancelSqlJobResponse) String() string

+ type ChangeAuthorizationRequest struct

+ Body *GrantDataPermissionReq

+ func (o ChangeAuthorizationRequest) String() string

+ type ChangeAuthorizationResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ func (o ChangeAuthorizationResponse) String() string

+ type ChangeFlinkJobStatusReportRequest struct

+ Body *IefFlinkJobStatusReportReq

+ func (o ChangeFlinkJobStatusReportRequest) String() string

+ type ChangeFlinkJobStatusReportResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ func (o ChangeFlinkJobStatusReportResponse) String() string

+ type ChangeQueuePlanRequest struct

+ Body *SetQueuePlanReq

+ PlanId string

+ QueueName string

+ func (o ChangeQueuePlanRequest) String() string

+ type ChangeQueuePlanResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ PlanId *string

+ QueueName *string

+ func (o ChangeQueuePlanResponse) String() string

+ type CheckConnectionRequest struct

+ Body *VerityConnectivityReq

+ QueueName string

+ func (o CheckConnectionRequest) String() string

+ type CheckConnectionResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ TaskId *string

+ func (o CheckConnectionResponse) String() string

+ type CheckSqlRequest struct

+ Body *CheckSqlRequestBody

+ func (o CheckSqlRequest) String() string

+ type CheckSqlRequestBody struct

+ Currentdb *string

+ Sql string

+ func (o CheckSqlRequestBody) String() string

+ type CheckSqlResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ JobType *string

+ Message *string

+ func (o CheckSqlResponse) String() string

+ type CommonResp struct

+ IsSuccess *bool

+ Message *string

+ func (o CommonResp) String() string

+ type CreateAgencyRequest struct

+ Roles []string

+ func (o CreateAgencyRequest) String() string

+ type CreateAuthInfoReq struct

+ AuthInfoName string

+ CertificateLocation *string

+ DatasourceType string

+ KeyPassword *string

+ KeystoreLocation *string

+ KeystorePassword *string

+ Keytab *string

+ Krb5Conf *string

+ Password *string

+ TruststoreLocation *string

+ TruststorePassword *string

+ UserName *string

+ func (o CreateAuthInfoReq) String() string

+ type CreateAuthInfoRequest struct

+ Body *CreateAuthInfoReq

+ func (o CreateAuthInfoRequest) String() string

+ type CreateAuthInfoResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ func (o CreateAuthInfoResponse) String() string

+ type CreateBatchJobRequest struct

+ Body *BatchJobInfo

+ UserId *string

+ func (o CreateBatchJobRequest) String() string

+ type CreateBatchJobResponse struct

+ AppId *string

+ ClusterName *string

+ CreateTime *int64

+ Duration *int64

+ HttpStatusCode int

+ Id *string

+ Image *string

+ Kind *string

+ Log *[]string

+ Name *string

+ Owner *string

+ ProxyUser *string

+ Queue *string

+ ScType *string

+ State *string

+ UpdateTime *int64

+ func (o CreateBatchJobResponse) String() string

+ type CreateDatabaseRequest struct

+ Body *CreateDatabaseRequestBody

+ func (o CreateDatabaseRequest) String() string

+ type CreateDatabaseRequestBody struct

+ DatabaseName string

+ Description *string

+ EnterpriseProjectId *string

+ Tags *[]TmsTagEntity

+ func (o CreateDatabaseRequestBody) String() string

+ type CreateDatabaseResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ func (o CreateDatabaseResponse) String() string

+ type CreateDatasourceConnectionReq struct

+ Name string

+ NetworkId string

+ SecurityGroupId string

+ Service string

+ Tags *[]TmsTagEntity

+ Url string

+ func (o CreateDatasourceConnectionReq) String() string

+ type CreateDatasourceConnectionRequest struct

+ Body *CreateDatasourceConnectionReq

+ func (o CreateDatasourceConnectionRequest) String() string

+ type CreateDatasourceConnectionResponse struct

+ ConnectionId *string

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ func (o CreateDatasourceConnectionResponse) String() string

+ type CreateDliAgencyRequest struct

+ Body *CreateAgencyRequest

+ func (o CreateDliAgencyRequest) String() string

+ type CreateDliAgencyResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ func (o CreateDliAgencyResponse) String() string

+ type CreateElasticResourcePoolRequest struct

+ Body *CreateElasticResourcePoolRequestBody

+ func (o CreateElasticResourcePoolRequest) String() string

+ type CreateElasticResourcePoolRequestBody struct

+ ChargingMode int32

+ CidrInVpc *string

+ Description *string

+ ElasticResourcePoolName string

+ EnterpriseProjectId *string

+ MaxCu int32

+ MinCu int32

+ Tags *[]TmsTag

+ func (o CreateElasticResourcePoolRequestBody) String() string

+ type CreateElasticResourcePoolResponse struct

+ ElasticResourcePoolName *string

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ func (o CreateElasticResourcePoolResponse) String() string

+ type CreateEnhancedConnectionRequest struct

+ Body *CreateEnhancedConnectionsReq

+ func (o CreateEnhancedConnectionRequest) String() string

+ type CreateEnhancedConnectionResponse struct

+ ConnectionId *string

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ func (o CreateEnhancedConnectionResponse) String() string

+ type CreateEnhancedConnectionRoutesRequest struct

+ Body *CreateRouteRequestBody

+ ConnectionId string

+ func (o CreateEnhancedConnectionRoutesRequest) String() string

+ type CreateEnhancedConnectionRoutesResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ func (o CreateEnhancedConnectionRoutesResponse) String() string

+ type CreateEnhancedConnectionsReq struct

+ DestNetworkId string

+ DestVpcId string

+ Hosts *[]EnhancedConnectionsHost

+ Name string

+ Queues *[]string

+ RoutetableId *string

+ Tags *[]TmsTagEntity

+ func (o CreateEnhancedConnectionsReq) String() string

+ type CreateFlinkJarRequest struct

+ Body *CreateFlinkJarRequestBody

+ func (o CreateFlinkJarRequest) String() string

+ type CreateFlinkJarRequestBody struct

+ CheckpointPath *string

+ CuNumber *int32

+ DependencyFiles *[]string

+ DependencyJars *[]string

+ Desc *string

+ Entrypoint *string

+ EntrypointArgs *string

+ Feature *string

+ FlinkVersion *string

+ Image *string

+ LogEnabled *bool

+ MainClass *string

+ ManagerCuNumber *int32

+ Name string

+ ObsBucket *string

+ ParallelNumber *int32

+ QueueName *string

+ RestartWhenException *bool

+ ResumeCheckpoint *bool

+ ResumeMaxNum *int32

+ RuntimeConfig *string

+ SmnTopic *string

+ Tags *[]TmsTagEntity

+ TmCus *int32

+ TmSlotNum *int32

+ func (o CreateFlinkJarRequestBody) String() string

+ type CreateFlinkJarResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Job *CreateJobRespJob

+ Message *string

+ func (o CreateFlinkJarResponse) String() string

+ type CreateFlinkSqlJobRequest struct

+ Body *CreateFlinkSqlJobRequestBody

+ func (o CreateFlinkSqlJobRequest) String() string

+ type CreateFlinkSqlJobRequestBody struct

+ CheckpointEnabled *bool

+ CheckpointInterval *int32

+ CheckpointMode *int32

+ CuNumber *int32

+ Desc *string

+ DirtyDataStrategy *string

+ EdgeGroupIds *[]string

+ FlinkVersion *string

+ IdleStateRetention *int32

+ JobType *string

+ LogEnabled *bool

+ ManagerCuNumber *int32

+ Name string

+ ObsBucket *string

+ ParallelNumber *int32

+ QueueName *string

+ RestartWhenException *bool

+ ResumeCheckpoint *bool

+ ResumeMaxNum *int32

+ RunMode *string

+ RuntimeConfig *string

+ SmnTopic *string

+ SqlBody *string

+ Tags *[]TmsTagEntity

+ TemplateId *int64

+ TmCus *int32

+ TmSlotNum *int32

+ UdfJarUrl *string

+ func (o CreateFlinkSqlJobRequestBody) String() string

+ type CreateFlinkSqlJobResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Job *CreateJobRespJob

+ Message *string

+ func (o CreateFlinkSqlJobResponse) String() string

+ type CreateFlinkTemplateRequest struct

+ Body *CreateFlinkTemplateRequestBody

+ func (o CreateFlinkTemplateRequest) String() string

+ type CreateFlinkTemplateRequestBody struct

+ Desc *string

+ JobType *CreateFlinkTemplateRequestBodyJobType

+ Name string

+ SqlBody *string

+ Tags *[]TmsTagEntity

+ func (o CreateFlinkTemplateRequestBody) String() string

+ type CreateFlinkTemplateRequestBodyJobType struct

+ func (c *CreateFlinkTemplateRequestBodyJobType) UnmarshalJSON(b []byte) error

+ func (c CreateFlinkTemplateRequestBodyJobType) MarshalJSON() ([]byte, error)

+ func (c CreateFlinkTemplateRequestBodyJobType) Value() string

+ type CreateFlinkTemplateRequestBodyJobTypeEnum struct

+ FLINK_OPENSOURCE_SQL_JOB CreateFlinkTemplateRequestBodyJobType

+ FLINK_SQL_JOB CreateFlinkTemplateRequestBodyJobType

+ func GetCreateFlinkTemplateRequestBodyJobTypeEnum() CreateFlinkTemplateRequestBodyJobTypeEnum

+ type CreateFlinkTemplateResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ Template *FlinkTemplate

+ func (o CreateFlinkTemplateResponse) String() string

+ type CreateGlobalValueReq struct

+ IsSensitive *bool

+ VarName string

+ VarValue string

+ func (o CreateGlobalValueReq) String() string

+ type CreateGlobalValueRequest struct

+ Body *CreateGlobalValueReq

+ func (o CreateGlobalValueRequest) String() string

+ type CreateGlobalValueResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ func (o CreateGlobalValueResponse) String() string

+ type CreateIefMessageChannelReq struct

+ NodeId string

+ func (o CreateIefMessageChannelReq) String() string

+ type CreateIefMessageChannelRequest struct

+ Body *CreateIefMessageChannelReq

+ func (o CreateIefMessageChannelRequest) String() string

+ type CreateIefMessageChannelResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ func (o CreateIefMessageChannelResponse) String() string

+ type CreateIefSystemEventsRequest struct

+ Body *IefSystemEventsReq

+ func (o CreateIefSystemEventsRequest) String() string

+ type CreateIefSystemEventsResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ func (o CreateIefSystemEventsResponse) String() string

+ type CreateJobRespJob struct

+ JobId *int64

+ StatusDesc *string

+ StatusName *string

+ func (o CreateJobRespJob) String() string

+ type CreateJobTemplatesRequest struct

+ Body *CreateJobTemplatesRequestBody

+ func (o CreateJobTemplatesRequest) String() string

+ type CreateJobTemplatesRequestBody struct

+ Body string

+ Description *string

+ Group *string

+ Language *string

+ Name string

+ Type string

+ func (o CreateJobTemplatesRequestBody) String() string

+ type CreateJobTemplatesResponse struct

+ HttpStatusCode int

+ Id *string

+ func (o CreateJobTemplatesResponse) String() string

+ type CreateQueuePlanRequest struct

+ Body *SetQueuePlanReq

+ QueueName string

+ func (o CreateQueuePlanRequest) String() string

+ type CreateQueuePlanResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ func (o CreateQueuePlanResponse) String() string

+ type CreateQueueReq struct

+ ChargingMode *int32

+ CuCount int32

+ Description *string

+ ElasticResourcePoolName *string

+ EnterpriseProjectId *string

+ Feature *string

+ Labels *[]interface{}

+ Platform *string

+ QueueName string

+ QueueType *string

+ ResourceMode *int32

+ Tags *[]TmsTagEntity

+ func (o CreateQueueReq) String() string

+ type CreateQueueRequest struct

+ Body *CreateQueueReq

+ func (o CreateQueueRequest) String() string

+ type CreateQueueResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ QueueName *string

+ func (o CreateQueueResponse) String() string

+ type CreateRouteRequestBody struct

+ Cidr string

+ Name string

+ func (o CreateRouteRequestBody) String() string

+ type CreateSessionReqGroup struct

+ Name *string

+ Resources *[]CreateSessionReqResource

+ func (o CreateSessionReqGroup) String() string

+ type CreateSessionReqResource struct

+ Name *string

+ Type *string

+ func (o CreateSessionReqResource) String() string

+ type CreateSqlJobRequest struct

+ Body *CreateSqlJobRequestBody

+ func (o CreateSqlJobRequest) String() string

+ type CreateSqlJobRequestBody struct

+ Conf *[]string

+ Currentdb *string

+ QueueName *string

+ Sql string

+ Tags *[]TmsTagEntity

+ func (o CreateSqlJobRequestBody) String() string

+ type CreateSqlJobResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ JobId *string

+ JobMode *string

+ JobType *CreateSqlJobResponseJobType

+ Message *string

+ Rows *[][]string

+ Schema *[]interface{}

+ func (o CreateSqlJobResponse) String() string

+ type CreateSqlJobResponseJobType struct

+ func (c *CreateSqlJobResponseJobType) UnmarshalJSON(b []byte) error

+ func (c CreateSqlJobResponseJobType) MarshalJSON() ([]byte, error)

+ func (c CreateSqlJobResponseJobType) Value() string

+ type CreateSqlJobResponseJobTypeEnum struct

+ DCL CreateSqlJobResponseJobType

+ DDL CreateSqlJobResponseJobType

+ EXPORT CreateSqlJobResponseJobType

+ IMPORT CreateSqlJobResponseJobType

+ INSERT CreateSqlJobResponseJobType

+ QUERY CreateSqlJobResponseJobType

+ func GetCreateSqlJobResponseJobTypeEnum() CreateSqlJobResponseJobTypeEnum

+ type CreateSqlTemplatesRequest struct

+ Body *CreateSqlTemplatesRequestBody

+ func (o CreateSqlTemplatesRequest) String() string

+ type CreateSqlTemplatesRequestBody struct

+ Description *string

+ Group *string

+ Sql string

+ SqlName string

+ func (o CreateSqlTemplatesRequestBody) String() string

+ type CreateSqlTemplatesResponse struct

+ Group *string

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ SqlId *string

+ func (o CreateSqlTemplatesResponse) String() string

+ type CreateStreamGraphRequest struct

+ Body *GenStreamGraphReq

+ JobId string

+ func (o CreateStreamGraphRequest) String() string

+ type CreateStreamGraphResponse struct

+ ErrorCode *string

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ StreamGraph *string

+ func (o CreateStreamGraphResponse) String() string

+ type CreateTableReq struct

+ Columns []CreateTableReqColumn

+ DataLocation string

+ DataPath *string

+ DataType *string

+ DateFormat *string

+ Delimiter *string

+ Description *string

+ EscapeChar *string

+ QuoteChar *string

+ SelectStatement *string

+ TableName string

+ Tags *[]TmsTagEntity

+ TimestampFormat *string

+ WithColumnHeader *bool

+ func (o CreateTableReq) String() string

+ type CreateTableReqColumn struct

+ ColumnName string

+ Description *string

+ IsPartitionColumn *bool

+ Type string

+ func (o CreateTableReqColumn) String() string

+ type CreateTableRequest struct

+ Body *CreateTableReq

+ DatabaseName string

+ func (o CreateTableRequest) String() string

+ type CreateTableResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ func (o CreateTableResponse) String() string

+ type Database struct

+ DatabaseName *string

+ Description *string

+ EnterpriseProjectId string

+ Owner *string

+ ResourceId string

+ TableNumber *int32

+ func (o Database) String() string

+ type DeleteAuthInfoRequest struct

+ AuthInfoName string

+ func (o DeleteAuthInfoRequest) String() string

+ type DeleteAuthInfoResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ func (o DeleteAuthInfoResponse) String() string

+ type DeleteDatabaseRequest struct

+ Async *bool

+ Cascade *bool

+ DatabaseName string

+ func (o DeleteDatabaseRequest) String() string

+ type DeleteDatabaseResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ JobId *string

+ JobMode *string

+ JobType *string

+ Message *string

+ func (o DeleteDatabaseResponse) String() string

+ type DeleteDatasourceConnectionRequest struct

+ ConnectionId string

+ func (o DeleteDatasourceConnectionRequest) String() string

+ type DeleteDatasourceConnectionResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ func (o DeleteDatasourceConnectionResponse) String() string

+ type DeleteElasticResourcePoolRequest struct

+ ElasticResourcePoolName string

+ func (o DeleteElasticResourcePoolRequest) String() string

+ type DeleteElasticResourcePoolResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ func (o DeleteElasticResourcePoolResponse) String() string

+ type DeleteEnhancedConnectionRequest struct

+ ConnectionId string

+ func (o DeleteEnhancedConnectionRequest) String() string

+ type DeleteEnhancedConnectionResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ func (o DeleteEnhancedConnectionResponse) String() string

+ type DeleteEnhancedConnectionRoutesRequest struct

+ ConnectionId string

+ Name string

+ func (o DeleteEnhancedConnectionRoutesRequest) String() string

+ type DeleteEnhancedConnectionRoutesResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ func (o DeleteEnhancedConnectionRoutesResponse) String() string

+ type DeleteFlinkJobRequest struct

+ JobId int64

+ func (o DeleteFlinkJobRequest) String() string

+ type DeleteFlinkJobResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ func (o DeleteFlinkJobResponse) String() string

+ type DeleteFlinkTemplateRequest struct

+ TemplateId int64

+ func (o DeleteFlinkTemplateRequest) String() string

+ type DeleteFlinkTemplateResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ Template *DeleteTemplateRespTemplate

+ func (o DeleteFlinkTemplateResponse) String() string

+ type DeleteGlobalValueRequest struct

+ VarName string

+ func (o DeleteGlobalValueRequest) String() string

+ type DeleteGlobalValueResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ func (o DeleteGlobalValueResponse) String() string

+ type DeleteQueuePlanRequest struct

+ PlanId int64

+ QueueName string

+ func (o DeleteQueuePlanRequest) String() string

+ type DeleteQueuePlanResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ func (o DeleteQueuePlanResponse) String() string

+ type DeleteQueueRequest struct

+ QueueName string

+ func (o DeleteQueueRequest) String() string

+ type DeleteQueueResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ func (o DeleteQueueResponse) String() string

+ type DeleteResourceRequest struct

+ Group *string

+ ResourceName string

+ func (o DeleteResourceRequest) String() string

+ type DeleteResourceResponse struct

+ HttpStatusCode int

+ func (o DeleteResourceResponse) String() string

+ type DeleteSqlTemplatesRequest struct

+ Body *DeleteSqlTemplatesRequestBody

+ func (o DeleteSqlTemplatesRequest) String() string

+ type DeleteSqlTemplatesRequestBody struct

+ SqlIds []string

+ func (o DeleteSqlTemplatesRequestBody) String() string

+ type DeleteSqlTemplatesResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ func (o DeleteSqlTemplatesResponse) String() string

+ type DeleteTableRequest struct

+ Async *bool

+ DatabaseName string

+ TableName string

+ func (o DeleteTableRequest) String() string

+ type DeleteTableResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ JobMode *string

+ Message *string

+ func (o DeleteTableResponse) String() string

+ type DeleteTemplateRespTemplate struct

+ TemplateId *int64

+ func (o DeleteTemplateRespTemplate) String() string

+ type DisassociateConnectionQueueReq struct

+ ElasticResourcePools *[]string

+ Queues *[]string

+ func (o DisassociateConnectionQueueReq) String() string

+ type DisassociateConnectionQueueRequest struct

+ Body *DisassociateConnectionQueueReq

+ ConnectionId string

+ func (o DisassociateConnectionQueueRequest) String() string

+ type DisassociateConnectionQueueResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ func (o DisassociateConnectionQueueResponse) String() string

+ type ElasticResourcePoolsResponse struct

+ ActualCu *int32

+ ChargingMode *int32

+ CidrInVpc *string

+ CreateTime *int64

+ CurrentCu *int32

+ Description *string

+ ElasticResourcePoolName *string

+ EnterpriseProjectId *string

+ FailReason *string

+ Label map[string]string

+ Manager *string

+ MaxCu *int32

+ MinCu *int32

+ Owner *string

+ PrepayCu *int32

+ Queues *[]string

+ ResourceId *string

+ Status *string

+ UpdateTime *int64

+ func (o ElasticResourcePoolsResponse) String() string

+ type EnhancedConnectionResourceInfo struct

+ ErrMsg *string

+ Name *string

+ PeerId *string

+ Status *string

+ UpdateTime *int64

+ func (o EnhancedConnectionResourceInfo) String() string

+ type EnhancedConnectionsHost struct

+ Ip *string

+ Name *string

+ func (o EnhancedConnectionsHost) String() string

+ type ExportFlinkJobRequest struct

+ Body *ExportFlinkJobRequestBody

+ func (o ExportFlinkJobRequest) String() string

+ type ExportFlinkJobRequestBody struct

+ IsSelected bool

+ JobSelected *[]int64

+ ObsDir string

+ func (o ExportFlinkJobRequestBody) String() string

+ type ExportFlinkJobResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ ZipFile *[]string

+ func (o ExportFlinkJobResponse) String() string

+ type ExportSqlJobResultRequest struct

+ Body *ExportSqlResultRequestBody

+ JobId string

+ func (o ExportSqlJobResultRequest) String() string

+ type ExportSqlJobResultResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ JobId *string

+ JobMode *string

+ Message *string

+ func (o ExportSqlJobResultResponse) String() string

+ type ExportSqlResultRequestBody struct

+ Compress *string

+ DataPath string

+ DataType string

+ EncodingType *string

+ ExportMode *ExportSqlResultRequestBodyExportMode

+ LimitNum *int32

+ QueueName *string

+ WithColumnHeader *bool

+ func (o ExportSqlResultRequestBody) String() string

+ type ExportSqlResultRequestBodyExportMode struct

+ func (c *ExportSqlResultRequestBodyExportMode) UnmarshalJSON(b []byte) error

+ func (c ExportSqlResultRequestBodyExportMode) MarshalJSON() ([]byte, error)

+ func (c ExportSqlResultRequestBodyExportMode) Value() string

+ type ExportSqlResultRequestBodyExportModeEnum struct

+ ERROR_IF_EXISTS ExportSqlResultRequestBodyExportMode

+ OVERWRITE ExportSqlResultRequestBodyExportMode

+ func GetExportSqlResultRequestBodyExportModeEnum() ExportSqlResultRequestBodyExportModeEnum

+ type ExportTableRequest struct

+ Body *ExportTableRequestBody

+ func (o ExportTableRequest) String() string

+ type ExportTableRequestBody struct

+ Compress string

+ DataPath string

+ DataType string

+ DatabaseName string

+ ExportMode *string

+ QueueName *string

+ TableName string

+ WithColumnHeader *bool

+ func (o ExportTableRequestBody) String() string

+ type ExportTableResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ JobId *string

+ JobMode *string

+ Message *string

+ func (o ExportTableResponse) String() string

+ type FlinkJobConfig struct

+ CheckpointEnabled *bool

+ CheckpointInterval *int32

+ CheckpointMode *string

+ CheckpointPath *string

+ ConfigUrl *string

+ CuNumber *int32

+ DependencyFiles *[]string

+ DependencyJars *[]string

+ DirtyDataStrategy *string

+ EdgeGroupIds *[]string

+ Entrypoint *string

+ ExecutorCuNumber *int32

+ ExecutorNumber *int32

+ Feature *string

+ FlinkVersion *string

+ GraphEditorData *string

+ GraphEditorEnabled *bool

+ IdleStateRetention *int32

+ Image *string

+ LogEnabled *bool

+ ManagerCuNumber *int32

+ ObsBucket *string

+ OperatorConfig *string

+ ParallelNumber *int32

+ RestartWhenException *bool

+ ResumeCheckpoint *bool

+ ResumeMaxNum *int64

+ RootId *int32

+ RuntimeConfig *string

+ SmnTopic *string

+ StaticEstimatorConfig *string

+ TmCus *int32

+ TmSlotNum *int32

+ UdfJarUrl *string

+ func (o FlinkJobConfig) String() string

+ type FlinkJobDetail struct

+ CreateTime int64

+ Desc *string

+ EntrypointArgs *string

+ ExecutionGraph *string

+ JobConfig *FlinkJobConfig

+ JobId int64

+ JobType *string

+ MainClass *string

+ Name *string

+ ProjectId *string

+ QueueName *string

+ RunMode *string

+ SavepointPath *string

+ SqlBody *string

+ StartTime *int64

+ Status *string

+ StatusDesc *string

+ UpdateTime *int64

+ UserId *string

+ func (o FlinkJobDetail) String() string

+ type FlinkJobInfo struct

+ CreateTime int64

+ Desc *string

+ Duration *int64

+ EntrypointArgs *string

+ ExecutionGraph *string

+ GraphEditorEnabled *bool

+ HasSavepoint *bool

+ JobConfig *ShowStreamJobListJobConfig

+ JobId int64

+ JobType *string

+ MainClass *string

+ Name *string

+ ProjectId *string

+ RootId *int64

+ RunMode *string

+ SqlBody *string

+ StartTime *int64

+ Status *string

+ StatusDesc *string

+ UpdateTime *int64

+ UserId *string

+ UserName *string

+ func (o FlinkJobInfo) String() string

+ type FlinkJobList struct

+ Jobs *[]FlinkJobInfo

+ TotalCount *int32

+ func (o FlinkJobList) String() string

+ type FlinkTemplate struct

+ CreateTime *int64

+ Desc *string

+ JobType *string

+ Name *string

+ TemplateId *int64

+ func (o FlinkTemplate) String() string

+ type FlinkTemplateDetail struct

+ CreateTime *int64

+ Desc *string

+ JobType *string

+ Name *string

+ SqlBody *string

+ TemplateId *int32

+ UpdateTime *int64

+ func (o FlinkTemplateDetail) String() string

+ type FlinkTemplateList struct

+ Templates *[]FlinkTemplateDetail

+ TotalCount *int32

+ func (o FlinkTemplateList) String() string

+ type GenStreamGraphReq struct

+ CuNumber *int32

+ GraphType *string

+ JobType *string

+ ManagerCuNumber *int32

+ OperatorConfig *string

+ ParallelNumber *int32

+ SqlBody string

+ StaticEstimator *bool

+ StaticEstimatorConfig *string

+ TmCus *int32

+ TmSlotNum *int32

+ func (o GenStreamGraphReq) String() string

+ type GrantDataPermissionReq struct

+ Action string

+ Privileges []GrantDataPermissionRespPrivilege

+ UserName string

+ func (o GrantDataPermissionReq) String() string

+ type GrantDataPermissionRespPrivilege struct

+ Object string

+ Privileges []string

+ func (o GrantDataPermissionRespPrivilege) String() string

+ type GrantQueuePermissionReq struct

+ Action string

+ Privileges []string

+ QueueName string

+ UserName string

+ func (o GrantQueuePermissionReq) String() string

+ type IefEvents struct

+ Attributes *string

+ EventType string

+ Name string

+ Operation string

+ Timestamp int64

+ Topic string

+ func (o IefEvents) String() string

+ type IefFlinkJobMessagesReq struct

+ MessageId string

+ State *State

+ func (o IefFlinkJobMessagesReq) String() string

+ type IefFlinkJobStatusReportReq struct

+ Jobs []Jobs

+ MessageId string

+ MsgConfirmTopic *string

+ func (o IefFlinkJobStatusReportReq) String() string

+ type IefSystemEventsReq struct

+ Data *IefEvents

+ func (o IefSystemEventsReq) String() string

+ type ImportFlinkJobRequest struct

+ Body *ImportFlinkJobRequestBody

+ func (o ImportFlinkJobRequest) String() string

+ type ImportFlinkJobRequestBody struct

+ IsCover *bool

+ ZipFile string

+ func (o ImportFlinkJobRequestBody) String() string

+ type ImportFlinkJobResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ JobMapping *[]JobMapInfo

+ Message *string

+ func (o ImportFlinkJobResponse) String() string

+ type ImportTableRequest struct

+ Body *ImportTableRequestBody

+ func (o ImportTableRequest) String() string

+ type ImportTableRequestBody struct

+ BadRecordsPath *string

+ Conf *[]string

+ DataPath string

+ DataType string

+ DatabaseName string

+ DateFormat *string

+ Delimiter *string

+ EscapeChar *string

+ Overwrite *bool

+ PartitionSpec *string

+ QueueName *string

+ QuoteChar *string

+ TableName string

+ TimestampFormat *string

+ WithColumnHeader *bool

+ func (o ImportTableRequestBody) String() string

+ type ImportTableResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ JobId *string

+ JobMode *string

+ Message *string

+ func (o ImportTableResponse) String() string

+ type JobMapInfo struct

+ NewJobId *int64

+ OldJobId *int64

+ Remark *string

+ func (o JobMapInfo) String() string

+ type JobTemplateInfo struct

+ Body *BatchJobInfo

+ Description *string

+ Group *string

+ Id *string

+ Language *string

+ Name *string

+ Owner *string

+ Type *string

+ func (o JobTemplateInfo) String() string

+ type Jobs struct

+ CreateTime int64

+ Exceptions *string

+ JobId *int32

+ Metrics *string

+ Plan *string

+ Status string

+ func (o Jobs) String() string

+ type ListAllTablesRequest struct

+ CurrentPage *int32

+ DatabaseName string

+ Keyword *string

+ PageSize *int32

+ TableType *string

+ WithDetail *bool

+ WithPriv *bool

+ func (o ListAllTablesRequest) String() string

+ type ListAllTablesResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ TableCount *int32

+ Tables *[]Table

+ func (o ListAllTablesResponse) String() string

+ type ListAuthInfoRequest struct

+ AuthInfoName *string

+ Limit *int32

+ Offset *int32

+ func (o ListAuthInfoRequest) String() string

+ type ListAuthInfoResponse struct

+ AuthInfos *[]AuthInfos

+ Count *int32

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ func (o ListAuthInfoResponse) String() string

+ type ListBatchesRequest struct

+ ClusterName *string

+ End *int64

+ From *int32

+ JobId *string

+ Order *string

+ QueueName *string

+ Size *int32

+ Start *int64

+ State *string

+ func (o ListBatchesRequest) String() string

+ type ListBatchesResponse struct

+ CreateTime *int64

+ From *int32

+ HttpStatusCode int

+ Sessions *[]ShowBatchJobDetailResp

+ Total *int32

+ func (o ListBatchesResponse) String() string

+ type ListDatabaseUsersRequest struct

+ DatabaseName string

+ func (o ListDatabaseUsersRequest) String() string

+ type ListDatabaseUsersResponse struct

+ DatabaseName *string

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ Privileges *[]ShowDatabaseUsersPrivilege

+ func (o ListDatabaseUsersResponse) String() string

+ type ListDatabasesRequest struct

+ Keyword *string

+ Limit *int32

+ Offset *int32

+ Tags *string

+ WithPriv *bool

+ func (o ListDatabasesRequest) String() string

+ type ListDatabasesResponse struct

+ DatabaseCount *int32

+ Databases *[]Database

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ func (o ListDatabasesResponse) String() string

+ type ListDatasourceConnectionsRequest struct

+ Tags *string

+ func (o ListDatasourceConnectionsRequest) String() string

+ type ListDatasourceConnectionsResponse struct

+ Connections *[]ShowDatasourceConnectionResp

+ Count *int32

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ func (o ListDatasourceConnectionsResponse) String() string

+ type ListElasticResourcePoolQueuesRequest struct

+ ElasticResourcePoolName string

+ Limit *int32

+ Offset *int32

+ QueueName *string

+ func (o ListElasticResourcePoolQueuesRequest) String() string

+ type ListElasticResourcePoolQueuesResponse struct

+ Count *int64

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ Queues *[]QueueInfo

+ func (o ListElasticResourcePoolQueuesResponse) String() string

+ type ListElasticResourcePoolScaleRecordsRequest struct

+ ElasticResourcePoolName string

+ EndTime *int64

+ Limit *int32

+ Offset *int32

+ StartTime *int64

+ Status *ListElasticResourcePoolScaleRecordsRequestStatus

+ func (o ListElasticResourcePoolScaleRecordsRequest) String() string

+ type ListElasticResourcePoolScaleRecordsRequestStatus struct

+ func (c *ListElasticResourcePoolScaleRecordsRequestStatus) UnmarshalJSON(b []byte) error

+ func (c ListElasticResourcePoolScaleRecordsRequestStatus) MarshalJSON() ([]byte, error)

+ func (c ListElasticResourcePoolScaleRecordsRequestStatus) Value() string

+ type ListElasticResourcePoolScaleRecordsRequestStatusEnum struct

+ FAIL ListElasticResourcePoolScaleRecordsRequestStatus

+ SUCCESS ListElasticResourcePoolScaleRecordsRequestStatus

+ func GetListElasticResourcePoolScaleRecordsRequestStatusEnum() ListElasticResourcePoolScaleRecordsRequestStatusEnum

+ type ListElasticResourcePoolScaleRecordsResponse struct

+ Count *int32

+ HttpStatusCode int

+ Items *[][]interface{}

+ XAuthToken *string

+ func (o ListElasticResourcePoolScaleRecordsResponse) String() string

+ type ListElasticResourcePoolsRequest struct

+ Limit *int32

+ Name *string

+ Offset *int32

+ Status *ListElasticResourcePoolsRequestStatus

+ Tags *string

+ func (o ListElasticResourcePoolsRequest) String() string

+ type ListElasticResourcePoolsRequestStatus struct

+ func (c *ListElasticResourcePoolsRequestStatus) UnmarshalJSON(b []byte) error

+ func (c ListElasticResourcePoolsRequestStatus) MarshalJSON() ([]byte, error)

+ func (c ListElasticResourcePoolsRequestStatus) Value() string

+ type ListElasticResourcePoolsRequestStatusEnum struct

+ AVAILABLE ListElasticResourcePoolsRequestStatus

+ CREATING ListElasticResourcePoolsRequestStatus

+ FAILED ListElasticResourcePoolsRequestStatus

+ SCALING ListElasticResourcePoolsRequestStatus

+ func GetListElasticResourcePoolsRequestStatusEnum() ListElasticResourcePoolsRequestStatusEnum

+ type ListElasticResourcePoolsResponse struct

+ Count *int32

+ ElasticResourcePoolName *string

+ ElasticResourcePools *[]ElasticResourcePoolsResponse

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ func (o ListElasticResourcePoolsResponse) String() string

+ type ListEnhancedConnectionsDetail struct

+ AvailableQueueInfo *[]EnhancedConnectionResourceInfo

+ CreateTime *int64

+ DestNetworkId *string

+ DestVpcId *string

+ ElasticResourcePools *[]EnhancedConnectionResourceInfo

+ Hosts *[]EnhancedConnectionsHost

+ Id *string

+ IsPrivis *bool

+ Name *string

+ Status *string

+ func (o ListEnhancedConnectionsDetail) String() string

+ type ListEnhancedConnectionsRequest struct

+ Limit *int32

+ Name *string

+ Offset *int32

+ Status *string

+ Tags *string

+ func (o ListEnhancedConnectionsRequest) String() string

+ type ListEnhancedConnectionsResponse struct

+ Connections *[]ListEnhancedConnectionsDetail

+ Count *int32

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ func (o ListEnhancedConnectionsResponse) String() string

+ type ListFlinkJobsRequest struct

+ JobType *string

+ Limit *int32

+ Name *string

+ Offset *int64

+ Order *string

+ QueueName *string

+ RootJobId *int64

+ ShowDetail *bool

+ Status *string

+ SysEnterpriseProjectName *string

+ Tags *string

+ UserName *string

+ func (o ListFlinkJobsRequest) String() string

+ type ListFlinkJobsResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ JobList *FlinkJobList

+ Message *string

+ func (o ListFlinkJobsResponse) String() string

+ type ListFlinkTemplatesRequest struct

+ Limit *int32

+ Name *string

+ Offset *int64

+ Order *string

+ Tags *string

+ func (o ListFlinkTemplatesRequest) String() string

+ type ListFlinkTemplatesResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ TemplateList *FlinkTemplateList

+ func (o ListFlinkTemplatesResponse) String() string

+ type ListGlobalValue struct

+ CreateTime *int64

+ Id *int64

+ IsSensitive *bool

+ ProjectId *string

+ UpdateTime *int64

+ UserId *string

+ UserName *string

+ VarName *string

+ VarValue *string

+ func (o ListGlobalValue) String() string

+ type ListGlobalValuesRequest struct

+ Limit *int32

+ Offset *int32

+ func (o ListGlobalValuesRequest) String() string

+ type ListGlobalValuesResponse struct

+ Count *int32

+ GlobalVars *[]ListGlobalValue

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ func (o ListGlobalValuesResponse) String() string

+ type ListGroupPackagesResource struct

+ CreateTime *int64

+ Owner *string

+ ResourceName *string

+ ResourceType *string

+ Status *string

+ UnderlyingName *string

+ UpdateTime *int64

+ func (o ListGroupPackagesResource) String() string

+ type ListJobTemplatesRequest struct

+ CurrentPage *int32

+ Keyword *string

+ PageSize *int32

+ Type *string

+ func (o ListJobTemplatesRequest) String() string

+ type ListJobTemplatesResponse struct

+ Count *int32

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ Templates *[]JobTemplateInfo

+ func (o ListJobTemplatesResponse) String() string

+ type ListJobsJobs struct

+ BadRowCount *int64

+ DatabaseName *string

+ Detail string

+ Duration *int32

+ EndTime *int64

+ InputRowCount *int64

+ InputSize int64

+ JobId string

+ JobType string

+ Message *string

+ Owner string

+ QueueName string

+ ResultCount int32

+ StartTime int64

+ Statement string

+ Status ListJobsJobsStatus

+ TableName *string

+ Tags *[]TmsTagEntity

+ WithColumnHeader *bool

+ func (o ListJobsJobs) String() string

+ type ListJobsJobsStatus struct

+ func (c *ListJobsJobsStatus) UnmarshalJSON(b []byte) error

+ func (c ListJobsJobsStatus) MarshalJSON() ([]byte, error)

+ func (c ListJobsJobsStatus) Value() string

+ type ListJobsJobsStatusEnum struct

+ CANCELLED ListJobsJobsStatus

+ FAILED ListJobsJobsStatus

+ FINISHED ListJobsJobsStatus

+ LAUNCHING ListJobsJobsStatus

+ RUNNING ListJobsJobsStatus

+ func GetListJobsJobsStatusEnum() ListJobsJobsStatusEnum

+ type ListQueuePlansRequest struct

+ QueueName string

+ func (o ListQueuePlansRequest) String() string

+ type ListQueuePlansResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ Plans *[]QueuePlanEntity

+ func (o ListQueuePlansResponse) String() string

+ type ListQueueUsersRequest struct

+ QueueName string

+ func (o ListQueueUsersRequest) String() string

+ type ListQueueUsersResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ Privileges *[]PrivilegesInfo

+ QueueName *string

+ func (o ListQueueUsersResponse) String() string

+ type ListQueuesRequest struct

+ QueueType *string

+ Tags *string

+ WithChargeInfo *bool

+ WithPriv *bool

+ func (o ListQueuesRequest) String() string

+ type ListQueuesResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ Queues *[]QueueDetails

+ func (o ListQueuesResponse) String() string

+ type ListResourcePackagesRespMoudle struct

+ CreateTime *int64

+ Description *string

+ ModuleName *string

+ ModuleType *string

+ Resources *[]string

+ Status *string

+ UpdateTime *int64

+ func (o ListResourcePackagesRespMoudle) String() string

+ type ListResourcesRequest struct

+ Kind *string

+ Tags *string

+ func (o ListResourcesRequest) String() string

+ type ListResourcesResponse struct

+ Groups *[]interface{}

+ HttpStatusCode int

+ Modules *[]ListResourcePackagesRespMoudle

+ Resources *[]ListGroupPackagesResource

+ Total *int32

+ func (o ListResourcesResponse) String() string

+ type ListSqlJobsRequest struct

+ CurrentPage *int32

+ DbName *string

+ End *int64

+ EngineType *string

+ JobStatus *string

+ JobType *ListSqlJobsRequestJobType

+ Order *ListSqlJobsRequestOrder

+ Owner *string

+ PageSize *int32

+ QueueName *string

+ SqlPattern *string

+ Start *int64

+ TableName *string

+ Tags *string

+ func (o ListSqlJobsRequest) String() string

+ type ListSqlJobsRequestJobType struct

+ func (c *ListSqlJobsRequestJobType) UnmarshalJSON(b []byte) error

+ func (c ListSqlJobsRequestJobType) MarshalJSON() ([]byte, error)

+ func (c ListSqlJobsRequestJobType) Value() string

+ type ListSqlJobsRequestJobTypeEnum struct

+ DCL ListSqlJobsRequestJobType

+ DDL ListSqlJobsRequestJobType

+ EXPORT ListSqlJobsRequestJobType

+ IMPORT ListSqlJobsRequestJobType

+ INSERT ListSqlJobsRequestJobType

+ QUERY ListSqlJobsRequestJobType

+ func GetListSqlJobsRequestJobTypeEnum() ListSqlJobsRequestJobTypeEnum

+ type ListSqlJobsRequestOrder struct

+ func (c *ListSqlJobsRequestOrder) UnmarshalJSON(b []byte) error

+ func (c ListSqlJobsRequestOrder) MarshalJSON() ([]byte, error)

+ func (c ListSqlJobsRequestOrder) Value() string

+ type ListSqlJobsRequestOrderEnum struct

+ DURATION_ASC ListSqlJobsRequestOrder

+ DURATION_DESC ListSqlJobsRequestOrder

+ START_TIME_ASC ListSqlJobsRequestOrder

+ START_TIME_DESC ListSqlJobsRequestOrder

+ func GetListSqlJobsRequestOrderEnum() ListSqlJobsRequestOrderEnum

+ type ListSqlJobsResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ JobCount *int32

+ Jobs *[]ListJobsJobs

+ Message *string

+ func (o ListSqlJobsResponse) String() string

+ type ListTablePrivilegesRequest struct

+ DatabaseName string

+ TableName string

+ UserName string

+ func (o ListTablePrivilegesRequest) String() string

+ type ListTablePrivilegesResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ Privileges *[]TableUserPermissionsRespPrivilege

+ UserName *string

+ func (o ListTablePrivilegesResponse) String() string

+ type ListTableUsersRequest struct

+ DatabaseName string

+ TableName string

+ func (o ListTableUsersRequest) String() string

+ type ListTableUsersResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ Privileges *[]ShowTableUsersRespPrivilege

+ func (o ListTableUsersResponse) String() string

+ type ObsBuckets struct

+ ObsBuckets []string

+ func (o ObsBuckets) String() string

+ type PartitionInfos struct

+ CreateTime int64

+ LastAccessTime int64

+ LastDdlTime *int64

+ Locations *[]string

+ NumFiles *int64

+ NumRows *int64

+ PartitionName string

+ TotalSize *int64

+ func (o PartitionInfos) String() string

+ type Partitions struct

+ PartitionInfos []PartitionInfos

+ TotalCount int64

+ func (o Partitions) String() string

+ type PreviewJobResultRequest struct

+ JobId string

+ QueueName *string

+ func (o PreviewJobResultRequest) String() string

+ type PreviewJobResultResponse struct

+ HttpStatusCode int

+ InputSize *int64

+ IsSuccess *bool

+ JobId *string

+ JobType *PreviewJobResultResponseJobType

+ Message *string

+ RowCount *int32

+ Rows *[][]string

+ Schema *[]interface{}

+ func (o PreviewJobResultResponse) String() string

+ type PreviewJobResultResponseJobType struct

+ func (c *PreviewJobResultResponseJobType) UnmarshalJSON(b []byte) error

+ func (c PreviewJobResultResponseJobType) MarshalJSON() ([]byte, error)

+ func (c PreviewJobResultResponseJobType) Value() string

+ type PreviewJobResultResponseJobTypeEnum struct

+ DCL PreviewJobResultResponseJobType

+ DDL PreviewJobResultResponseJobType

+ EXPORT PreviewJobResultResponseJobType

+ IMPORT PreviewJobResultResponseJobType

+ INSERT PreviewJobResultResponseJobType

+ QUERY PreviewJobResultResponseJobType

+ func GetPreviewJobResultResponseJobTypeEnum() PreviewJobResultResponseJobTypeEnum

+ type Privilege struct

+ Object string

+ Privileges []string

+ func (o Privilege) String() string

+ type PrivilegesInfo struct

+ IsAdmin *bool

+ Privileges *[]string

+ UserName *string

+ func (o PrivilegesInfo) String() string

+ type ProjectPrivilege struct

+ ApplicantProjectId *string

+ Object *string

+ Privileges *[]string

+ func (o ProjectPrivilege) String() string

+ type QueueDetails struct

+ ChargingMode *int32

+ CidrInMgntsubnet *string

+ CidrInSubnet *string

+ CidrInVpc *string

+ CreateTime *int64

+ CuCount *int32

+ CuScaleInLimit *int32

+ CuScaleOutLimit *int32

+ CuSpec *int32

+ Description *string

+ ElasticResourcePoolName *string

+ EnterpriseProjectId *string

+ Feature *string

+ IsRestarting *bool

+ Labels *string

+ Owner *string

+ Platform *string

+ QueueId *int64

+ QueueName *string

+ QueueType *string

+ ResourceId *string

+ ResourceMode *int32

+ ResourceType *string

+ func (o QueueDetails) String() string

+ type QueueInfo struct

+ CreateTime *int64

+ Engine *string

+ EnterpriseProjectId *string

+ Owner *string

+ QueueName *string

+ QueueScalingPolicies *[]QueueScalingPoliciesResponse

+ QueueType *string

+ func (o QueueInfo) String() string

+ type QueuePlanEntity struct

+ Activate *bool

+ Id *int64

+ LastExecuteTime *int64

+ PlanName *string

+ RepeatDay []QueuePlanEntityRepeatDay

+ StartHour *int32

+ StartMinute *int32

+ TargetCu *int32

+ ValidDateBegin *int64

+ ValidDateEnd *int64

+ func (o QueuePlanEntity) String() string

+ type QueuePlanEntityRepeatDay struct

+ func (c *QueuePlanEntityRepeatDay) UnmarshalJSON(b []byte) error

+ func (c QueuePlanEntityRepeatDay) MarshalJSON() ([]byte, error)

+ func (c QueuePlanEntityRepeatDay) Value() string

+ type QueuePlanEntityRepeatDayEnum struct

+ FRIDAY QueuePlanEntityRepeatDay

+ MONDAY QueuePlanEntityRepeatDay

+ SATURDAY QueuePlanEntityRepeatDay

+ SUNDAY QueuePlanEntityRepeatDay

+ THURSDAY QueuePlanEntityRepeatDay

+ TUESDAY QueuePlanEntityRepeatDay

+ WEDNESDAY QueuePlanEntityRepeatDay

+ func GetQueuePlanEntityRepeatDayEnum() QueuePlanEntityRepeatDayEnum

+ type QueuePlanIds struct

+ PlanIds []int64

+ func (o QueuePlanIds) String() string

+ type QueueScalingPoliciesResponse struct

+ ImpactStartTime *string

+ ImpactStopTime *string

+ MaxCu *int32

+ MinCu *int32

+ Priority *int32

+ func (o QueueScalingPoliciesResponse) String() string

+ type QueueScalingPolicyInfo struct

+ ImpactStartTime string

+ ImpactStopTime string

+ MaxCu int32

+ MinCu int32

+ Priority int32

+ func (o QueueScalingPolicyInfo) String() string

+ type RegisterAuthorizedQueueRequest struct

+ Body *GrantQueuePermissionReq

+ func (o RegisterAuthorizedQueueRequest) String() string

+ type RegisterAuthorizedQueueResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ func (o RegisterAuthorizedQueueResponse) String() string

+ type RegisterBucketRequest struct

+ Body *ObsBuckets

+ func (o RegisterBucketRequest) String() string

+ type RegisterBucketResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ func (o RegisterBucketResponse) String() string

+ type RunIefJobActionCallBackRequest struct

+ Body *IefFlinkJobMessagesReq

+ func (o RunIefJobActionCallBackRequest) String() string

+ type RunIefJobActionCallBackResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ func (o RunIefJobActionCallBackResponse) String() string

+ type RunQueueActionReq struct

+ Action string

+ CuCount *int32

+ Force *bool

+ func (o RunQueueActionReq) String() string

+ type RunQueueActionRequest struct

+ Body *RunQueueActionReq

+ QueueName string

+ func (o RunQueueActionRequest) String() string

+ type RunQueueActionResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ JobId *string

+ Message *string

+ QueueName *string

+ Result *bool

+ func (o RunQueueActionResponse) String() string

+ type SetQueuePlanReq struct

+ Activate *bool

+ PlanName string

+ RepeatDay []SetQueuePlanReqRepeatDay

+ StartHour int32

+ StartMinute int32

+ TargetCu int32

+ ValidDateBegin *int64

+ ValidDateEnd *int64

+ func (o SetQueuePlanReq) String() string

+ type SetQueuePlanReqRepeatDay struct

+ func (c *SetQueuePlanReqRepeatDay) UnmarshalJSON(b []byte) error

+ func (c SetQueuePlanReqRepeatDay) MarshalJSON() ([]byte, error)

+ func (c SetQueuePlanReqRepeatDay) Value() string

+ type SetQueuePlanReqRepeatDayEnum struct

+ FRIDAY SetQueuePlanReqRepeatDay

+ MONDAY SetQueuePlanReqRepeatDay

+ SATURDAY SetQueuePlanReqRepeatDay

+ SUNDAY SetQueuePlanReqRepeatDay

+ THURSDAY SetQueuePlanReqRepeatDay

+ TUESDAY SetQueuePlanReqRepeatDay

+ WEDNESDAY SetQueuePlanReqRepeatDay

+ func GetSetQueuePlanReqRepeatDayEnum() SetQueuePlanReqRepeatDayEnum

+ type ShowBatchInfoRequest struct

+ BatchId string

+ func (o ShowBatchInfoRequest) String() string

+ type ShowBatchInfoResponse struct

+ AppId *string

+ ClusterName *string

+ CreateTime *int64

+ Feature *string

+ HttpStatusCode int

+ Id *string

+ Image *string

+ Kind *string

+ Log *[]string

+ Name *string

+ Owner *string

+ ProxyUser *string

+ Queue *string

+ ScType *string

+ SparkVersion *string

+ State *string

+ UpdateTime *int64

+ func (o ShowBatchInfoResponse) String() string

+ type ShowBatchJobDetailResp struct

+ AppId *string

+ ClusterName *string

+ CreateTime *int64

+ Duration *int64

+ Id *string

+ Image *string

+ Kind *string

+ Log *[]string

+ Name *string

+ Owner *string

+ ProxyUser *string

+ Queue *string

+ ScType *string

+ State *string

+ UpdateTime *int64

+ func (o ShowBatchJobDetailResp) String() string

+ type ShowBatchLogRequest struct

+ BatchId string

+ From *int32

+ Index *int32

+ Size *int32

+ Type *string

+ func (o ShowBatchLogRequest) String() string

+ type ShowBatchLogResponse struct

+ From *string

+ HttpStatusCode int

+ Id *string

+ Log *[]string

+ Total *int64

+ func (o ShowBatchLogResponse) String() string

+ type ShowBatchStateRequest struct

+ BatchId string

+ func (o ShowBatchStateRequest) String() string

+ type ShowBatchStateResponse struct

+ HttpStatusCode int

+ Id *string

+ State *string

+ func (o ShowBatchStateResponse) String() string

+ type ShowDatabaseUsersPrivilege struct

+ IsAdmin *bool

+ Privileges *[]string

+ UserName *string

+ func (o ShowDatabaseUsersPrivilege) String() string

+ type ShowDatasourceConnectionRequest struct

+ ConnectionId string

+ func (o ShowDatasourceConnectionRequest) String() string

+ type ShowDatasourceConnectionResp struct

+ ClusterName *string

+ ConnectionId *string

+ ConnectionUrl *string

+ CreateTime *int64

+ Destination *string

+ IsSuccess *bool

+ Message *string

+ Name *string

+ Process *float64

+ QueueList *[]string

+ Service *string

+ State *string

+ func (o ShowDatasourceConnectionResp) String() string

+ type ShowDatasourceConnectionResponse struct

+ AvailableQueueInfo *[]AvailableQueueInfo

+ ClusterName *string

+ ConnectionId *string

+ ConnectionUrl *string

+ CreateTime *int64

+ Destination *string

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ Name *string

+ Process *float64

+ Service *string

+ State *string

+ func (o ShowDatasourceConnectionResponse) String() string

+ type ShowDescribeTableRequest struct

+ DatabaseName string

+ TableName string

+ func (o ShowDescribeTableRequest) String() string

+ type ShowDescribeTableResponse struct

+ ColumnCount *int32

+ Columns *[]CreateTableReqColumn

+ CreateTableSql *string

+ DataLocation *string

+ DataType *string

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ StorageProperties *[]interface{}

+ TableComment *string

+ TableType *string

+ func (o ShowDescribeTableResponse) String() string

+ type ShowDliAgencyRequest struct

+ func (o ShowDliAgencyRequest) String() string

+ type ShowDliAgencyResponse struct

+ CurrentRoles *[]string

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ Version *string

+ func (o ShowDliAgencyResponse) String() string

+ type ShowEnhancedConnectionRequest struct

+ ConnectionId string

+ func (o ShowEnhancedConnectionRequest) String() string

+ type ShowEnhancedConnectionResponse struct

+ AvailableQueueInfo *[]EnhancedConnectionResourceInfo

+ CreateTime *int64

+ DestNetworkId *string

+ DestVpcId *string

+ ElasticResourcePools *[]EnhancedConnectionResourceInfo

+ Hosts *[]EnhancedConnectionsHost

+ HttpStatusCode int

+ Id *string

+ IsSuccess *bool

+ Message *string

+ Name *string

+ Status *string

+ func (o ShowEnhancedConnectionResponse) String() string

+ type ShowEnhancedPrivilegeRequest struct

+ ConnectionId string

+ func (o ShowEnhancedPrivilegeRequest) String() string

+ type ShowEnhancedPrivilegeResponse struct

+ ConnectionId *string

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ Privileges *[]ProjectPrivilege

+ func (o ShowEnhancedPrivilegeResponse) String() string

+ type ShowFlinkExecuteGraphRequest struct

+ JobId int64

+ func (o ShowFlinkExecuteGraphRequest) String() string

+ type ShowFlinkExecuteGraphResponse struct

+ ExecuteGraph *StreamGraphInfo

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ func (o ShowFlinkExecuteGraphResponse) String() string

+ type ShowFlinkJobRequest struct

+ JobId int64

+ func (o ShowFlinkJobRequest) String() string

+ type ShowFlinkJobResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ JobDetail *FlinkJobDetail

+ Message *string

+ func (o ShowFlinkJobResponse) String() string

+ type ShowFlinkMetricRequest struct

+ Body *ShowJobMonitorInfoReq

+ func (o ShowFlinkMetricRequest) String() string

+ type ShowFlinkMetricResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ Metrics *ShowJobMonitorInfoRespPayload

+ func (o ShowFlinkMetricResponse) String() string

+ type ShowJobMonitorInfoReq struct

+ JobIds []int64

+ func (o ShowJobMonitorInfoReq) String() string

+ type ShowJobMonitorInfoRespPayload struct

+ Jobs *[]ShowJobMonitorInfoRespPayloadJobs

+ func (o ShowJobMonitorInfoRespPayload) String() string

+ type ShowJobMonitorInfoRespPayloadJobs struct

+ JobId *int64

+ Metrics *ShowJobMonitorInfoRespPayloadJobsMetrics

+ func (o ShowJobMonitorInfoRespPayloadJobs) String() string

+ type ShowJobMonitorInfoRespPayloadJobsMetrics struct

+ Sinks *[]ShowJobMonitorInfoRespPayloadJobsMetricsSources

+ Sources *[]ShowJobMonitorInfoRespPayloadJobsMetricsSources

+ TotalReadRate *float64

+ TotalWriteRate *float64

+ func (o ShowJobMonitorInfoRespPayloadJobsMetrics) String() string

+ type ShowJobMonitorInfoRespPayloadJobsMetricsSources struct

+ CorruptedRecords *int64

+ Name *string

+ Records *int64

+ func (o ShowJobMonitorInfoRespPayloadJobsMetricsSources) String() string

+ type ShowJobProgressRequest struct

+ JobId string

+ func (o ShowJobProgressRequest) String() string

+ type ShowJobProgressResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ JobId *string

+ Message *string

+ Progress *float64

+ Status *string

+ SubJobId *int32

+ SubJobs *[]SubJobDatas

+ func (o ShowJobProgressResponse) String() string

+ type ShowJobTemplateRequest struct

+ TemplateId string

+ func (o ShowJobTemplateRequest) String() string

+ type ShowJobTemplateResponse struct

+ Body *BatchJobInfo

+ Description *string

+ Group *string

+ HttpStatusCode int

+ Id *string

+ Language *string

+ Name *string

+ Owner *string

+ Type *string

+ func (o ShowJobTemplateResponse) String() string

+ type ShowNodeConnectivityRequest struct

+ QueueName string

+ TaskId string

+ func (o ShowNodeConnectivityRequest) String() string

+ type ShowNodeConnectivityResponse struct

+ Connectivity *string

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ func (o ShowNodeConnectivityResponse) String() string

+ type ShowObjectUserRequest struct

+ Object string

+ func (o ShowObjectUserRequest) String() string

+ type ShowObjectUserResponse struct

+ Count *int32

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ ObjectName *string

+ ObjectType *string

+ Privileges *[]ShowDatabaseUsersPrivilege

+ func (o ShowObjectUserResponse) String() string

+ type ShowPartitionsRequest struct

+ DatabaseName string

+ Limit *int32

+ Offset *int32

+ TableName string

+ func (o ShowPartitionsRequest) String() string

+ type ShowPartitionsResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ Partitions *Partitions

+ func (o ShowPartitionsResponse) String() string

+ type ShowQueueDetailRequest struct

+ QueueName string

+ func (o ShowQueueDetailRequest) String() string

+ type ShowQueueDetailResponse struct

+ ChargingMode *int32

+ CreateTime *int64

+ CuCount *int32

+ CuScaleInLimit *int32

+ CuScaleOutLimit *int32

+ CuSpec *int32

+ Description *string

+ ElasticResourcePoolName *string

+ EnterpriseProjectId *string

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ Owner *string

+ QueueId *int64

+ QueueName *string

+ QueueType *string

+ ResourceId *string

+ ResourceMode *int32

+ ResourceType *string

+ func (o ShowQueueDetailResponse) String() string

+ type ShowResourceInfoRequest struct

+ Group *string

+ ResourceName string

+ func (o ShowResourceInfoRequest) String() string

+ type ShowResourceInfoResponse struct

+ CreateTime *int64

+ HttpStatusCode int

+ Owner *string

+ ResourceName *string

+ ResourceType *string

+ Status *string

+ UnderlyingName *string

+ UpdateTime *int64

+ func (o ShowResourceInfoResponse) String() string

+ type ShowSqlJobDetailRequest struct

+ JobId string

+ func (o ShowSqlJobDetailRequest) String() string

+ type ShowSqlJobDetailResponse struct

+ Compress *string

+ DataPath *string

+ DataType *string

+ DatabaseName *string

+ DateFormat *string

+ Delimiter *string

+ Duration *int64

+ EscapeChar *string

+ ExportMode *string

+ HttpStatusCode int

+ IsSuccess *bool

+ JobId *string

+ Message *string

+ Owner *string

+ QuoteChar *string

+ StartTime *int64

+ TableName *string

+ Tags *[]TmsTagEntity

+ TimestampFormat *string

+ WithColumnHeader *bool

+ func (o ShowSqlJobDetailResponse) String() string

+ type ShowSqlJobStatusRequest struct

+ JobId string

+ func (o ShowSqlJobStatusRequest) String() string

+ type ShowSqlJobStatusResponse struct

+ BadRowCount *int64

+ DatabaseName *string

+ Detail *string

+ Duration *int64

+ HttpStatusCode int

+ InputRowCount *int64

+ InputSize *int64

+ IsSuccess *bool

+ JobId *string

+ JobMode *string

+ JobType *string

+ Message *string

+ Owner *string

+ QueueName *string

+ ResultCount *int32

+ StartTime *int64

+ Statement *string

+ Status *ShowSqlJobStatusResponseStatus

+ TableName *string

+ Tags *[]TmsTagEntity

+ func (o ShowSqlJobStatusResponse) String() string

+ type ShowSqlJobStatusResponseStatus struct

+ func (c *ShowSqlJobStatusResponseStatus) UnmarshalJSON(b []byte) error

+ func (c ShowSqlJobStatusResponseStatus) MarshalJSON() ([]byte, error)

+ func (c ShowSqlJobStatusResponseStatus) Value() string

+ type ShowSqlJobStatusResponseStatusEnum struct

+ CANCELLED ShowSqlJobStatusResponseStatus

+ FAILED ShowSqlJobStatusResponseStatus

+ FINISHED ShowSqlJobStatusResponseStatus

+ LAUNCHING ShowSqlJobStatusResponseStatus

+ RUNNING ShowSqlJobStatusResponseStatus

+ func GetShowSqlJobStatusResponseStatusEnum() ShowSqlJobStatusResponseStatusEnum

+ type ShowSqlSampleTemplatesRequest struct

+ func (o ShowSqlSampleTemplatesRequest) String() string

+ type ShowSqlSampleTemplatesResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ SqlCount *int32

+ Sqls *[]SqlsSampleResp

+ func (o ShowSqlSampleTemplatesResponse) String() string

+ type ShowSqlTemplatesRequest struct

+ Keyword *string

+ func (o ShowSqlTemplatesRequest) String() string

+ type ShowSqlTemplatesResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ SqlCount *int32

+ Sqls *[]SqlsResp

+ func (o ShowSqlTemplatesResponse) String() string

+ type ShowStreamJobListJobConfig struct

+ CheckpointEnabled *bool

+ CheckpointInterval *int32

+ CheckpointMode *string

+ CuNumber *int32

+ DependencyFiles *[]string

+ DependencyJars *[]string

+ DirtyDataStrategy *string

+ EdgeGroupIds *[]string

+ Entrypoint *string

+ ExecutorCuNumber *int32

+ ExecutorNumber *int32

+ IdleStateRetention *int32

+ LogEnabled *bool

+ ManagerCuNumber *int32

+ ObsBucket *string

+ ParallelNumber *int32

+ RestartWhenException *bool

+ ResumeCheckpoint *bool

+ RootId *int32

+ SmnTopic *string

+ UdfJarUrl *string

+ func (o ShowStreamJobListJobConfig) String() string

+ type ShowTableContentRequest struct

+ DatabaseName string

+ Mode *string

+ TableName string

+ func (o ShowTableContentRequest) String() string

+ type ShowTableContentResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ Rows *[]interface{}

+ Schema *[]interface{}

+ func (o ShowTableContentResponse) String() string

+ type ShowTableUsersRespPrivilege struct

+ IsAdmin *bool

+ Object *string

+ Privileges *[]string

+ UserName *string

+ func (o ShowTableUsersRespPrivilege) String() string

+ type SqlsResp struct

+ Description *string

+ Group *string

+ Owner *string

+ Sql *string

+ SqlId *string

+ SqlName *string

+ func (o SqlsResp) String() string

+ type SqlsSampleResp struct

+ Description *string

+ Group *string

+ Lang *string

+ Name *string

+ Sql *string

+ func (o SqlsSampleResp) String() string

+ type State struct

+ Phase string

+ Reason *string

+ func (o State) String() string

+ type StopFlinkJobsRequest struct

+ Body *StopFlinkJobsRequestBody

+ func (o StopFlinkJobsRequest) String() string

+ type StopFlinkJobsRequestBody struct

+ JobIds []int64

+ TriggerSavepoint *bool

+ func (o StopFlinkJobsRequestBody) String() string

+ type StopFlinkJobsResponse struct

+ Body *[]CommonResp

+ HttpStatusCode int

+ func (o StopFlinkJobsResponse) String() string

+ type StreamGraphInfo struct

+ Duration *int64

+ EndTime *int64

+ IsStoppable *bool

+ Jid *string

+ Name *string

+ StartTime *int64

+ State *string

+ func (o StreamGraphInfo) String() string

+ type SubJobDatas struct

+ CompletionTime *string

+ Description *string

+ Id *int32

+ JobGroup *string

+ KilledTasksSummary map[string]int32

+ Name *string

+ NumActiveStages *int32

+ NumActiveTasks *int32

+ NumCompletedIndices *int32

+ NumCompletedStages *int32

+ NumCompletedTasks *int32

+ NumFailedStages *int32

+ NumFailedTasks *int32

+ NumKilledTasks *int32

+ NumSkippedStages *int32

+ NumSkippedTasks *int32

+ NumTasks *int32

+ StageIds *[]int32

+ Status *string

+ SubmissionTime *string

+ func (o SubJobDatas) String() string

+ type Table struct

+ CreateTime int32

+ CurrentPage *int32

+ DataLocation string

+ DataType *string

+ LastAccessTime int32

+ Location *string

+ Owner string

+ PageSize *int32

+ PartitionColumns *string

+ TableName string

+ TableSize int32

+ TableType string

+ func (o Table) String() string

+ type TableUserPermissionsRespPrivilege struct

+ Object *string

+ Privileges *[]string

+ func (o TableUserPermissionsRespPrivilege) String() string

+ type TmsTag struct

+ Key string

+ Value string

+ func (o TmsTag) String() string

+ type TmsTagEntity struct

+ Key string

+ Value string

+ func (o TmsTagEntity) String() string

+ type UpdateAuthInfoRequest struct

+ Body *UpdateAuthInfoRequestBody

+ func (o UpdateAuthInfoRequest) String() string

+ type UpdateAuthInfoRequestBody struct

+ AuthInfoName string

+ KeystoreLocation *string

+ KeystorePassword *string

+ Keytab *string

+ Krb5Conf *string

+ Password *string

+ TruststoreLocation *string

+ TruststorePassword *string

+ UserName *string

+ func (o UpdateAuthInfoRequestBody) String() string

+ type UpdateAuthInfoResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ func (o UpdateAuthInfoResponse) String() string

+ type UpdateDatabaseOwnerRequest struct

+ Body *UpdateOwnerRequestBody

+ DatabaseName string

+ func (o UpdateDatabaseOwnerRequest) String() string

+ type UpdateDatabaseOwnerResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ func (o UpdateDatabaseOwnerResponse) String() string

+ type UpdateElasticResourcePoolQueueInfoRequest struct

+ Body *UpdateElasticResourcePoolQueueScalingPolicyInfo

+ ElasticResourcePoolName string

+ QueueName string

+ func (o UpdateElasticResourcePoolQueueInfoRequest) String() string

+ type UpdateElasticResourcePoolQueueInfoResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ func (o UpdateElasticResourcePoolQueueInfoResponse) String() string

+ type UpdateElasticResourcePoolQueueScalingPolicyInfo struct

+ QueueScalingPolicies []QueueScalingPolicyInfo

+ func (o UpdateElasticResourcePoolQueueScalingPolicyInfo) String() string

+ type UpdateElasticResourcePoolRequest struct

+ Body *UpdateElasticResourcePoolRequestBody

+ ElasticResourcePoolName string

+ func (o UpdateElasticResourcePoolRequest) String() string

+ type UpdateElasticResourcePoolRequestBody struct

+ Description *string

+ MaxCu *int32

+ MinCu *int32

+ func (o UpdateElasticResourcePoolRequestBody) String() string

+ type UpdateElasticResourcePoolResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ func (o UpdateElasticResourcePoolResponse) String() string

+ type UpdateFlinkJarRequest struct

+ Body *UpdateFlinkJarRequestBody

+ JobId int64

+ func (o UpdateFlinkJarRequest) String() string

+ type UpdateFlinkJarRequestBody struct

+ CheckpointPath *string

+ CuNumber *int32

+ DependencyFiles *[]string

+ DependencyJars *[]string

+ Desc *string

+ Entrypoint *string

+ EntrypointArgs *string

+ Feature *string

+ FlinkVersion *string

+ Image *string

+ JobType *string

+ LogEnabled *bool

+ MainClass *string

+ ManagerCuNumber *int32

+ Name *string

+ ObsBucket *string

+ ParallelNumber *int32

+ QueueName *string

+ RestartWhenException *bool

+ ResumeCheckpoint *bool

+ ResumeMaxNum *int32

+ RuntimeConfig *string

+ SmnTopic *string

+ TmCus *int32

+ TmSlotNum *int32

+ func (o UpdateFlinkJarRequestBody) String() string

+ type UpdateFlinkJarResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Job *UpdateJobRespJob

+ Message *string

+ func (o UpdateFlinkJarResponse) String() string

+ type UpdateFlinkSqlRequest struct

+ Body *UpdateFlinkSqlRequestBody

+ JobId int64

+ func (o UpdateFlinkSqlRequest) String() string

+ type UpdateFlinkSqlRequestBody struct

+ CheckpointEnabled *bool

+ CheckpointInterval *int32

+ CheckpointMode *int32

+ CuNumber *int32

+ Desc *string

+ DirtyDataStrategy *string

+ EdgeGroupIds *[]string

+ FlinkVersion *string

+ IdleStateRetention *int32

+ LogEnabled *bool

+ ManagerCuNumber *int32

+ Name *string

+ ObsBucket *string

+ OperatorConfig *string

+ ParallelNumber *int32

+ QueueName *string

+ RestartWhenException *bool

+ ResumeCheckpoint *bool

+ ResumeMaxNum *int32

+ RunMode *string

+ RuntimeConfig *string

+ SmnTopic *string

+ SqlBody *string

+ StaticEstimatorConfig *string

+ TmCus *int32

+ TmSlotNum *int32

+ UdfJarUrl *string

+ func (o UpdateFlinkSqlRequestBody) String() string

+ type UpdateFlinkSqlResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Job *UpdateJobRespJob

+ Message *string

+ func (o UpdateFlinkSqlResponse) String() string

+ type UpdateFlinkTemplateRequest struct

+ Body *UpdateFlinkTemplateRequestBody

+ TemplateId int64

+ func (o UpdateFlinkTemplateRequest) String() string

+ type UpdateFlinkTemplateRequestBody struct

+ Desc *string

+ Name *string

+ SqlBody *string

+ func (o UpdateFlinkTemplateRequestBody) String() string

+ type UpdateFlinkTemplateResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ func (o UpdateFlinkTemplateResponse) String() string

+ type UpdateGlobalValueReq struct

+ VarValue string

+ func (o UpdateGlobalValueReq) String() string

+ type UpdateGlobalValueRequest struct

+ Body *UpdateGlobalValueReq

+ VarName string

+ func (o UpdateGlobalValueRequest) String() string

+ type UpdateGlobalValueResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ func (o UpdateGlobalValueResponse) String() string

+ type UpdateGroupOrResourceOwnerRequest struct

+ Body *UpdateResourceOwner

+ func (o UpdateGroupOrResourceOwnerRequest) String() string

+ type UpdateGroupOrResourceOwnerResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ func (o UpdateGroupOrResourceOwnerResponse) String() string

+ type UpdateHostMassageReq struct

+ Hosts []EnhancedConnectionsHost

+ func (o UpdateHostMassageReq) String() string

+ type UpdateHostMassageRequest struct

+ Body *UpdateHostMassageReq

+ ConnectionId string

+ func (o UpdateHostMassageRequest) String() string

+ type UpdateHostMassageResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ func (o UpdateHostMassageResponse) String() string

+ type UpdateJobRespJob struct

+ UpdateTime *int64

+ func (o UpdateJobRespJob) String() string

+ type UpdateJobTemplatesRequest struct

+ Body *UpdateJobTemplatesRequestBody

+ TemplateId string

+ func (o UpdateJobTemplatesRequest) String() string

+ type UpdateJobTemplatesRequestBody struct

+ Body string

+ Description *string

+ Group *string

+ Name string

+ func (o UpdateJobTemplatesRequestBody) String() string

+ type UpdateJobTemplatesResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ func (o UpdateJobTemplatesResponse) String() string

+ type UpdateOwnerRequestBody struct

+ NewOwner string

+ func (o UpdateOwnerRequestBody) String() string

+ type UpdateQueueCidrReq struct

+ CidrInVpc *string

+ func (o UpdateQueueCidrReq) String() string

+ type UpdateQueueCidrRequest struct

+ Body *UpdateQueueCidrReq

+ QueueName string

+ func (o UpdateQueueCidrRequest) String() string

+ type UpdateQueueCidrResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ func (o UpdateQueueCidrResponse) String() string

+ type UpdateResourceOwner struct

+ GroupName string

+ NewOwner string

+ ResourceName *string

+ func (o UpdateResourceOwner) String() string

+ type UpdateSqlTemplatesRequest struct

+ Body *UpdateSqlTemplatesRequestBody

+ SqlId string

+ func (o UpdateSqlTemplatesRequest) String() string

+ type UpdateSqlTemplatesRequestBody struct

+ Description *string

+ Group *string

+ Sql *string

+ SqlName *string

+ func (o UpdateSqlTemplatesRequestBody) String() string

+ type UpdateSqlTemplatesResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ func (o UpdateSqlTemplatesResponse) String() string

+ type UpdateTableOwnerRequest struct

+ Body *UpdateOwnerRequestBody

+ DatabaseName string

+ TableName string

+ func (o UpdateTableOwnerRequest) String() string

+ type UpdateTableOwnerResponse struct

+ HttpStatusCode int

+ IsSuccess *bool

+ Message *string

+ func (o UpdateTableOwnerResponse) String() string

+ type UploadFilesRequest struct

+ Body *UploadGroupPackageReq

+ UserId *string

+ func (o UploadFilesRequest) String() string

+ type UploadFilesResponse struct

+ CreateTime *int64

+ Description *string

+ Details *[]UploadPackageGroupDetailsResp

+ GroupName *string

+ HttpStatusCode int

+ IsAsync *bool

+ ModuleName *string

+ ModuleType *string

+ Owner *string

+ Resources *[]string

+ Status *string

+ UpdateTime *int64

+ func (o UploadFilesResponse) String() string

+ type UploadGroupPackageReq struct

+ Group string

+ Paths []string

+ func (o UploadGroupPackageReq) String() string

+ type UploadJarsRequest struct

+ Body *UploadGroupPackageReq

+ UserId *string

+ func (o UploadJarsRequest) String() string

+ type UploadJarsResponse struct

+ CreateTime *int64

+ Description *string

+ Details *[]UploadPackageGroupDetailsResp

+ GroupName *string

+ HttpStatusCode int

+ IsAsync *bool

+ ModuleName *string

+ ModuleType *string

+ Owner *string

+ Resources *[]string

+ Status *string

+ UpdateTime *int64

+ func (o UploadJarsResponse) String() string

+ type UploadPackageGroupDetailsResp struct

+ CreateTime int64

+ IsAsync *bool

+ ResourceName *string

+ ResourceType string

+ Status *string

+ UnderlyingName *string

+ UpdateTime *int64

+ func (o UploadPackageGroupDetailsResp) String() string

+ type UploadPackageGroupReq struct

+ Group string

+ IsAsync *bool

+ Kind string

+ Paths []string

+ Tags *[]TmsTagEntity

+ func (o UploadPackageGroupReq) String() string

+ type UploadPythonFilesRequest struct

+ Body *UploadGroupPackageReq

+ UserId *string

+ func (o UploadPythonFilesRequest) String() string

+ type UploadPythonFilesResponse struct

+ CreateTime *int64

+ Description *string

+ Details *[]UploadPackageGroupDetailsResp

+ GroupName *string

+ HttpStatusCode int

+ IsAsync *bool

+ ModuleName *string

+ ModuleType *string

+ Owner *string

+ Resources *[]string

+ Status *string

+ UpdateTime *int64

+ func (o UploadPythonFilesResponse) String() string

+ type UploadResourcesRequest struct

+ Body *UploadPackageGroupReq

+ UserId *string

+ func (o UploadResourcesRequest) String() string

+ type UploadResourcesResponse struct

+ CreateTime *int64

+ Details *[]UploadPackageGroupDetailsResp

+ GroupName *string

+ HttpStatusCode int

+ IsAsync *bool

+ Owner *string

+ Resources *[]string

+ Status *string

+ UpdateTime *int64

+ func (o UploadResourcesResponse) String() string

+ type VerityConnectivityReq struct

+ Address string

+ func (o VerityConnectivityReq) String() string

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