dli

package
v1.64.0 Latest Latest
Warning

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

 Go to latest Published: Apr 29, 2024 License: MPL-2.0 Imports: 41 Imported by: 4

Documentation

Overview

Generated by PMS #67

Generated by PMS #108

Generated by PMS #66

Generated by PMS #89

Generated by PMS #119

Index

Constants

View Source 
const (
	CU16  = 16
	CU64  = 64
	CU256 = 256

	QueueTypeSQL     = "sql"
	QueueTypeGeneral = "general"

	MaxInstance         = "computeEngine.maxInstance"
	MaxConcurrent       = "job.maxConcurrent"
	MaxPrefetchInstance = "computeEngine.maxPrefetchInstance"
)
View Source 
const DliAgencyID = "dli_admin_agency"
View Source 
const ErrCodeConnNotFound string = "DLI.0001"

The error code corresponding to ErrCodeConnNotFound is an important sign that the related resource does not exist. When the object is enhanced connection and the connection not exist, the API return this error: + {"error_code": "DLI.0001", "error_msg": "Connection xxx is not exist"}

Variables

This section is empty.

Functions

func DataSourceAuths added in v1.61.1 

func DataSourceAuths() *schema.Resource

@API DLI GET /v3/{project_id}/datasource/auth-infos

func DataSourceConnections added in v1.61.1 

func DataSourceConnections() *schema.Resource

@API DLI GET /v2.0/{project_id}/datasource/enhanced-connections

func DataSourceDliElasticPools added in v1.63.1 

func DataSourceDliElasticPools() *schema.Resource

func DataSourceDliFlinkTemplates added in v1.63.2 

func DataSourceDliFlinkTemplates() *schema.Resource

func DataSourceDliQuotas added in v1.63.0 

func DataSourceDliQuotas() *schema.Resource

func DataSourceDliSparkTemplates added in v1.63.2 

func DataSourceDliSparkTemplates() *schema.Resource

func DataSourceDliSqlTemplates added in v1.63.2 

func DataSourceDliSqlTemplates() *schema.Resource

func GetDatasourceConnectionAssociatedPoolNames added in v1.63.0 

func GetDatasourceConnectionAssociatedPoolNames(client *golangsdk.ServiceClient, connectionId string) ([]interface{}, error)

func GetDliDependentPackageInfo added in v1.30.0 

func GetDliDependentPackageInfo(c *golangsdk.ServiceClient, id string) (*resources.Resource, error)

func GetDliSQLDatabaseByName added in v1.58.0 

func GetDliSQLDatabaseByName(c *golangsdk.ServiceClient, dbName string) (databases.Database, error)

func GetElasticResourcePoolByName added in v1.61.1 

func GetElasticResourcePoolByName(client *golangsdk.ServiceClient, resourceName string) (interface{}, error)

GetElasticResourcePoolByName is the method used to query the elastic resource pool matching the name.

func GetElasticResourcePools added in v1.61.1 

func GetElasticResourcePools(client *golangsdk.ServiceClient) ([]interface{}, error)

GetElasticResourcePools is a method used to query all elastic resource pools in a specified region.

func GetObjectPrivilegesForSpecifiedUser added in v1.63.2 

func GetObjectPrivilegesForSpecifiedUser(client *golangsdk.ServiceClient, object, userName string) (interface{}, error)

func ParseAuthInfoFromId added in v1.31.1 

func ParseAuthInfoFromId(id string) (object, userName string)

func ParsePrivilegesQueryError added in v1.63.0 

func ParsePrivilegesQueryError(err error, special404ErrCode string) error

ParsePrivilegesQueryError is a method that used to parse the special error returned by the permission query request of the DLI object (enhanced connection, database or table). + DLI.0001: enhanced connection has been deleted. + DLI.0002: database or table has been deleted.

func ParseTableInfoFromId added in v1.30.0 

func ParseTableInfoFromId(id string) (databaseName, tableName string)

func QueryPermission added in v1.31.1 

func QueryPermission(client *golangsdk.ServiceClient, obj, userName string) (*auth.Privilege, error)

Object format: databases.Database_name databases.Database_name.tables.Table_name databases.Database_name.tables.Table_name.columns.Column_name jobs.flink.Flink_job_ID groups.Package_group_name resources.PackageName queues.queueName

func ResourceDatabasePrivilege added in v1.63.2 

func ResourceDatabasePrivilege() *schema.Resource

@API DLI PUT /v1.0/{project_id}/authorization @API DLI GET /v1.0/{project_id}/authorization/privileges

func ResourceDatasourceAuth added in v1.47.0 

func ResourceDatasourceAuth() *schema.Resource

@API DLI POST /v3/{project_id}/datasource/auth-infos @API DLI GET /v3/{project_id}/datasource/auth-infos @API DLI PUT /v3/{project_id}/datasource/auth-infos @API DLI DELETE /v3/{project_id}/datasource/auth-infos/{auth_info_name}

func ResourceDatasourceConnection added in v1.47.0 

func ResourceDatasourceConnection() *schema.Resource

@API DLI POST /v2.0/{project_id}/datasource/enhanced-connections @API DLI POST /v2.0/{project_id}/datasource/enhanced-connections/{id}/routes @API DLI GET /v2.0/{project_id}/datasource/enhanced-connections/{id} @API DLI PUT /v2.0/{project_id}/datasource/enhanced-connections/{id} @API DLI POST /v2.0/{project_id}/datasource/enhanced-connections/{id}/associate-queue @API DLI POST /v2.0/{project_id}/datasource/enhanced-connections/{id}/disassociate-queue @API DLI DELETE /v2.0/{project_id}/datasource/enhanced-connections/{id}/routes/{name} @API DLI DELETE /v2.0/{project_id}/datasource/enhanced-connections/{id}

func ResourceDatasourceConnectionAssociate added in v1.63.0 

func ResourceDatasourceConnectionAssociate() *schema.Resource

@API DLI POST /v2.0/{project_id}/datasource/enhanced-connections/{connection_id}/associate-queue @API DLI GET /v2.0/{project_id}/datasource/enhanced-connections/{connection_id} @API DLI POST /v2.0/{project_id}/datasource/enhanced-connections/{connection_id}/disassociate-queue

func ResourceDatasourceConnectionPrivilege added in v1.63.0 

func ResourceDatasourceConnectionPrivilege() *schema.Resource

@API DLI PUT /v1.0/{project_id}/authorization @API DLI GET /v2.0/{project_id}/datasource/enhanced-connections/{connection_id}/privileges

func ResourceDliAgency added in v1.48.0 

func ResourceDliAgency() *schema.Resource

@API DLI POST /v2/{project_id}/agency @API DLI GET /v2/{project_id}/agency

func ResourceDliDependentPackageV2Create added in v1.30.0 

func ResourceDliDependentPackageV2Create(ctx context.Context, d *schema.ResourceData, meta interface{}) diag.Diagnostics

func ResourceDliDependentPackageV2Delete added in v1.30.0 

func ResourceDliDependentPackageV2Delete(_ context.Context, d *schema.ResourceData, meta interface{}) diag.Diagnostics

func ResourceDliDependentPackageV2Read added in v1.30.0 

func ResourceDliDependentPackageV2Read(_ context.Context, d *schema.ResourceData, meta interface{}) diag.Diagnostics

func ResourceDliDependentPackageV2Update added in v1.30.0 

func ResourceDliDependentPackageV2Update(ctx context.Context, d *schema.ResourceData,
	meta interface{}) diag.Diagnostics

func ResourceDliPackageV2 added in v1.30.0 

func ResourceDliPackageV2() *schema.Resource

@API DLI POST /v2.0/{project_id}/resources @API DLI GET /v2.0/{project_id}/resources/{resource_name} @API DLI PUT /v2.0/{project_id}/resources/owner @API DLI DELETE /v2.0/{project_id}/resources/{resource_name} @API DLI GET /v3/{project_id}/dli_package_resource/{resource_id}/tags @API DLI POST /v3/{project_id}/dli_package_resource/{resource_id}/tags/create @API DLI POST /v3/{project_id}/dli_package_resource/{resource_id}/tags/delete

func ResourceDliPermission added in v1.31.1 

func ResourceDliPermission() *schema.Resource

@API DLI PUT /v1.0/{project_id}/queues/user-authorization @API DLI PUT /v1.0/{project_id}/user-authorization @API DLI GET /v1.0/{project_id}/authorization/privileges @API DLI GET /v1.0/{project_id}/databases/{database_name}/users @API DLI GET /v1.0/{project_id}/databases/{database_name}/tables/{table_name}/users @API DLI GET /v1.0/{project_id}/queues/{queue_name}/users

func ResourceDliQueue 

func ResourceDliQueue() *schema.Resource

func ResourceDliSparkJobV2 added in v1.30.0 

func ResourceDliSparkJobV2() *schema.Resource

@API DLI POST /v2.0/{project_id}/batches @API DLI GET /v2.0/{project_id}/batches/{batch_id} @API DLI GET /v2.0/{project_id}/batches/{batch_id}/state @API DLI DELETE /v2.0/{project_id}/batches/{batch_id}

func ResourceDliSqlDatabaseV1 added in v1.30.0 

func ResourceDliSqlDatabaseV1() *schema.Resource

@API DLI POST /v1.0/{project_id}/databases @API DLI GET /v1.0/{project_id}/databases @API DLI PUT /v1.0/{project_id}/databases/{database_name}/owner @API DLI DELETE /v1.0/{project_id}/databases/{database_name}

func ResourceDliTable added in v1.30.0 

func ResourceDliTable() *schema.Resource

@API DLI POST /v1.0/{project_id}/databases/{database_name}/tables @API DLI GET /v1.0/{project_id}/databases/{database_name}/tables/{table_name} @API DLI GET /v1.0/{project_id}/databases/{database_name}/tables @API DLI DELETE /v1.0/{project_id}/databases/{database_name}/tables/{table_name}

func ResourceElasticResourcePool added in v1.61.1 

func ResourceElasticResourcePool() *schema.Resource

@API DLI POST /v3/{project_id}/elastic-resource-pools @API DLI GET /v3/{project_id}/elastic-resource-pools @API DLI PUT /v3/{project_id}/elastic-resource-pools/{elastic_resource_pool_name} @API DLI DELETE /v3/{project_id}/elastic-resource-pools/{elastic_resource_pool_name}

func ResourceFlinkJarJob added in v1.31.1 

func ResourceFlinkJarJob() *schema.Resource

@API DLI POST /v1.0/{project_id}/dli/obs-authorize @API DLI POST /v1.0/{project_id}/streaming/flink-jobs @API DLI POST /v1.0/{project_id}/streaming/jobs/run @API DLI GET /v1.0/{project_id}/streaming/jobs/{job_id} @API DLI PUT /v1.0/{project_id}/streaming/flink-jobs/{job_id} @API DLI POST /v1.0/{project_id}/streaming/jobs/stop @API DLI DELETE /v1.0/{project_id}/streaming/jobs/{job_id} @API DLI GET /v3/{project_id}/dli_flink_job/{resource_id}/tags @API DLI POST /v3/{project_id}/dli_flink_job/{resource_id}/tags/create @API DLI POST /v3/{project_id}/dli_flink_job/{resource_id}/tags/delete

func ResourceFlinkSqlJob added in v1.30.0 

func ResourceFlinkSqlJob() *schema.Resource

@API DLI POST /v1.0/{project_id}/dli/obs-authorize @API DLI POST /v1.0/{project_id}/streaming/sql-jobs @API DLI POST /v1.0/{project_id}/streaming/jobs/run @API DLI GET /v1.0/{project_id}/streaming/jobs/{job_id} @API DLI PUT /v1.0/{project_id}/streaming/sql-jobs/{job_id} @API DLI POST /v1.0/{project_id}/streaming/jobs/stop @API DLI DELETE /v1.0/{project_id}/streaming/jobs/{job_id} @API DLI GET /v3/{project_id}/dli_flink_job/{resource_id}/tags @API DLI POST /v3/{project_id}/dli_flink_job/{resource_id}/tags/create @API DLI POST /v3/{project_id}/dli_flink_job/{resource_id}/tags/delete @API DLI POST /v3/{project_id}/streaming/jobs/{job_id}/gen-graph

func ResourceFlinkTemplate added in v1.48.0 

func ResourceFlinkTemplate() *schema.Resource

@API DLI POST /v1.0/{project_id}/streaming/job-templates @API DLI GET /v1.0/{project_id}/streaming/job-templates @API DLI PUT /v1.0/{project_id}/streaming/job-templates/{id} @API DLI DELETE /v1.0/{project_id}/streaming/job-templates/{id}

func ResourceGlobalVariable added in v1.48.0 

func ResourceGlobalVariable() *schema.Resource

@API DLI POST /v1.0/{project_id}/variables @API DLI GET /v1.0/{project_id}/variables @API DLI PUT /v1.0/{project_id}/variables/{var_name} @API DLI DELETE /v1.0/{project_id}/variables/{var_name}

func ResourceSQLTemplate added in v1.48.0 

func ResourceSQLTemplate() *schema.Resource

@API DLI POST /v1.0/{project_id}/sqls @API DLI GET /v1.0/{project_id}/sqls @API DLI PUT /v1.0/{project_id}/sqls/{id} @API DLI POST /v1.0/{project_id}/sqls-deletion

func ResourceSparkTemplate added in v1.48.0 

func ResourceSparkTemplate() *schema.Resource

@API DLI POST /v3/{project_id}/templates @API DLI GET /v3/{project_id}/templates/{id} @API DLI PUT /v3/{project_id}/templates/{id} @API DLI POST /v1.0/{project_id}/sqls-deletion

func ResourceSqlJob added in v1.30.0 

func ResourceSqlJob() *schema.Resource

@API DLI POST /v1.0/{project_id}/jobs/submit-job @API DLI GET /v1.0/{project_id}/jobs/{job_id}/status @API DLI GET /v1.0/{project_id}/jobs @API DLI DELETE /v1.0/{project_id}/jobs/{job_id}

func SparkTemplateBodySchema added in v1.48.0 

func SparkTemplateBodySchema() *schema.Resource

func SparkTemplateGroupSchema added in v1.48.0 

func SparkTemplateGroupSchema() *schema.Resource

func SparkTemplateResourceSchema added in v1.48.0 

func SparkTemplateResourceSchema() *schema.Resource

Types

type ElasticPoolsDSWrapper added in v1.63.1 

type ElasticPoolsDSWrapper struct {
	*schemas.ResourceDataWrapper
	Config *config.Config
}

func (*ElasticPoolsDSWrapper) ListElasticResourcePools added in v1.63.1 

func (w *ElasticPoolsDSWrapper) ListElasticResourcePools() (*gjson.Result, error)

@API DLI GET /v3/{project_id}/elastic-resource-pools

type FlinkTemplatesDSWrapper added in v1.63.2 

type FlinkTemplatesDSWrapper struct {
	*schemas.ResourceDataWrapper
	Config *config.Config
}

func (*FlinkTemplatesDSWrapper) ListFlinkSqlJobTemplates added in v1.63.2 

func (w *FlinkTemplatesDSWrapper) ListFlinkSqlJobTemplates() (*gjson.Result, error)

@API DLI GET /v1.0/{project_id}/streaming/job-templates

type QuotasDSWrapper added in v1.63.0 

type QuotasDSWrapper struct {
	*schemas.ResourceDataWrapper
	Config *config.Config
}

func (*QuotasDSWrapper) ShowQuota added in v1.63.0 

func (w *QuotasDSWrapper) ShowQuota() (*gjson.Result, error)

@API DLI GET /v3/{project_id}/quotas

type SparkTemplatesDSWrapper added in v1.63.2 

type SparkTemplatesDSWrapper struct {
	*schemas.ResourceDataWrapper
	Config *config.Config
}

func (*SparkTemplatesDSWrapper) ListSparkJobTemplates added in v1.63.2 

func (w *SparkTemplatesDSWrapper) ListSparkJobTemplates() (*gjson.Result, error)

@API DLI GET /v3/{project_id}/templates

type SqlTemplatesDSWrapper added in v1.63.2 

type SqlTemplatesDSWrapper struct {
	*schemas.ResourceDataWrapper
	Config *config.Config
}

func (*SqlTemplatesDSWrapper) ListSqlJobTemplates added in v1.63.2 

func (w *SqlTemplatesDSWrapper) ListSqlJobTemplates() (*gjson.Result, error)

@API DLI GET /v1.0/{project_id}/sqls

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.