v1

package
v0.1.50 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GenReqDefForAddDevData 

func GenReqDefForAddDevData() *def.HttpRequestDef

func GenReqDefForAddPipelineJob 

func GenReqDefForAddPipelineJob() *def.HttpRequestDef

func GenReqDefForCreateAssetModel 

func GenReqDefForCreateAssetModel() *def.HttpRequestDef

func GenReqDefForCreateAssetNew 

func GenReqDefForCreateAssetNew() *def.HttpRequestDef

func GenReqDefForCreateBatchJob 

func GenReqDefForCreateBatchJob() *def.HttpRequestDef

func GenReqDefForCreateComputingResource 

func GenReqDefForCreateComputingResource() *def.HttpRequestDef

func GenReqDefForCreateDatasource 

func GenReqDefForCreateDatasource() *def.HttpRequestDef

func GenReqDefForCreateGroup 

func GenReqDefForCreateGroup() *def.HttpRequestDef

func GenReqDefForCreateRun 

func GenReqDefForCreateRun() *def.HttpRequestDef

func GenReqDefForCreateStreamingJob 

func GenReqDefForCreateStreamingJob() *def.HttpRequestDef

func GenReqDefForCreateTable 

func GenReqDefForCreateTable() *def.HttpRequestDef

func GenReqDefForDeleteAssetModel 

func GenReqDefForDeleteAssetModel() *def.HttpRequestDef

func GenReqDefForDeleteAssetNew 

func GenReqDefForDeleteAssetNew() *def.HttpRequestDef

func GenReqDefForDeleteBatchJob 

func GenReqDefForDeleteBatchJob() *def.HttpRequestDef

func GenReqDefForDeleteComputingResource 

func GenReqDefForDeleteComputingResource() *def.HttpRequestDef

func GenReqDefForDeleteDataStore 

func GenReqDefForDeleteDataStore() *def.HttpRequestDef

func GenReqDefForDeleteDatasource 

func GenReqDefForDeleteDatasource() *def.HttpRequestDef

func GenReqDefForDeleteGroup 

func GenReqDefForDeleteGroup() *def.HttpRequestDef

func GenReqDefForDeletePipelineJob 

func GenReqDefForDeletePipelineJob() *def.HttpRequestDef

func GenReqDefForDeleteRun 

func GenReqDefForDeleteRun() *def.HttpRequestDef

func GenReqDefForDeleteStreamingJobById 

func GenReqDefForDeleteStreamingJobById() *def.HttpRequestDef

func GenReqDefForDeleteTable 

func GenReqDefForDeleteTable() *def.HttpRequestDef

func GenReqDefForExportDataset 

func GenReqDefForExportDataset() *def.HttpRequestDef

func GenReqDefForImportData 

func GenReqDefForImportData() *def.HttpRequestDef

func GenReqDefForListAssetModels 

func GenReqDefForListAssetModels() *def.HttpRequestDef

func GenReqDefForListAssetsNew 

func GenReqDefForListAssetsNew() *def.HttpRequestDef

func GenReqDefForListBatchJobs 

func GenReqDefForListBatchJobs() *def.HttpRequestDef

func GenReqDefForListComputingResources 

func GenReqDefForListComputingResources() *def.HttpRequestDef

func GenReqDefForListDataStores 

func GenReqDefForListDataStores() *def.HttpRequestDef

func GenReqDefForListGroups 

func GenReqDefForListGroups() *def.HttpRequestDef

func GenReqDefForListHistory 

func GenReqDefForListHistory() *def.HttpRequestDef

func GenReqDefForListMetrics 

func GenReqDefForListMetrics() *def.HttpRequestDef

func GenReqDefForListPipelineJobs 

func GenReqDefForListPipelineJobs() *def.HttpRequestDef

func GenReqDefForListRuns 

func GenReqDefForListRuns() *def.HttpRequestDef

func GenReqDefForListTables 

func GenReqDefForListTables() *def.HttpRequestDef

func GenReqDefForListTagValues 

func GenReqDefForListTagValues() *def.HttpRequestDef

func GenReqDefForPublishRootAsset 

func GenReqDefForPublishRootAsset() *def.HttpRequestDef

func GenReqDefForShowAllDataSource 

func GenReqDefForShowAllDataSource() *def.HttpRequestDef

func GenReqDefForShowAssetModel 

func GenReqDefForShowAssetModel() *def.HttpRequestDef

func GenReqDefForShowAssetNew 

func GenReqDefForShowAssetNew() *def.HttpRequestDef

func GenReqDefForShowBatchJob 

func GenReqDefForShowBatchJob() *def.HttpRequestDef

func GenReqDefForShowDataSource 

func GenReqDefForShowDataSource() *def.HttpRequestDef

func GenReqDefForShowDataset 

func GenReqDefForShowDataset() *def.HttpRequestDef

func GenReqDefForShowJobById 

func GenReqDefForShowJobById() *def.HttpRequestDef

func GenReqDefForShowJobs 

func GenReqDefForShowJobs() *def.HttpRequestDef

func GenReqDefForShowLastPropertyValue 

func GenReqDefForShowLastPropertyValue() *def.HttpRequestDef

func GenReqDefForShowMetricValue 

func GenReqDefForShowMetricValue() *def.HttpRequestDef

func GenReqDefForShowPipelineJob 

func GenReqDefForShowPipelineJob() *def.HttpRequestDef

func GenReqDefForShowPropertyRawValue 

func GenReqDefForShowPropertyRawValue() *def.HttpRequestDef

func GenReqDefForShowPropertyValues 

func GenReqDefForShowPropertyValues() *def.HttpRequestDef

func GenReqDefForShowRun 

func GenReqDefForShowRun() *def.HttpRequestDef

func GenReqDefForShowTablePreview 

func GenReqDefForShowTablePreview() *def.HttpRequestDef

func GenReqDefForShowTableSchema 

func GenReqDefForShowTableSchema() *def.HttpRequestDef

func GenReqDefForStartJob 

func GenReqDefForStartJob() *def.HttpRequestDef

func GenReqDefForStartPipelineJob 

func GenReqDefForStartPipelineJob() *def.HttpRequestDef

func GenReqDefForStopJob 

func GenReqDefForStopJob() *def.HttpRequestDef

func GenReqDefForStopPipelineJob 

func GenReqDefForStopPipelineJob() *def.HttpRequestDef

func GenReqDefForUpdateAssetModel 

func GenReqDefForUpdateAssetModel() *def.HttpRequestDef

func GenReqDefForUpdateAssetNew 

func GenReqDefForUpdateAssetNew() *def.HttpRequestDef

func GenReqDefForUpdateBatchJob 

func GenReqDefForUpdateBatchJob() *def.HttpRequestDef

func GenReqDefForUpdateDataSource 

func GenReqDefForUpdateDataSource() *def.HttpRequestDef

func GenReqDefForUpdateDataStore 

func GenReqDefForUpdateDataStore() *def.HttpRequestDef

func GenReqDefForUpdateGroup 

func GenReqDefForUpdateGroup() *def.HttpRequestDef

func GenReqDefForUpdatePipelineJob 

func GenReqDefForUpdatePipelineJob() *def.HttpRequestDef

func GenReqDefForUpdateStreamingJob 

func GenReqDefForUpdateStreamingJob() *def.HttpRequestDef

func GenReqDefForValidateSql 

func GenReqDefForValidateSql() *def.HttpRequestDef

func IoTAnalyticsClientBuilder 

func IoTAnalyticsClientBuilder() *http_client.HcHttpClientBuilder

Types

type AddDevDataInvoker added in v0.0.90 

type AddDevDataInvoker struct {
	*invoker.BaseInvoker
}

func (*AddDevDataInvoker) Invoke added in v0.0.90 

func (i *AddDevDataInvoker) Invoke() (*model.AddDevDataResponse, error)

type AddPipelineJobInvoker added in v0.0.90 

type AddPipelineJobInvoker struct {
	*invoker.BaseInvoker
}

func (*AddPipelineJobInvoker) Invoke added in v0.0.90 

func (i *AddPipelineJobInvoker) Invoke() (*model.AddPipelineJobResponse, error)

type CreateAssetModelInvoker added in v0.0.90 

type CreateAssetModelInvoker struct {
	*invoker.BaseInvoker
}

func (*CreateAssetModelInvoker) Invoke added in v0.0.90 

func (i *CreateAssetModelInvoker) Invoke() (*model.CreateAssetModelResponse, error)

type CreateAssetNewInvoker added in v0.0.90 

type CreateAssetNewInvoker struct {
	*invoker.BaseInvoker
}

func (*CreateAssetNewInvoker) Invoke added in v0.0.90 

func (i *CreateAssetNewInvoker) Invoke() (*model.CreateAssetNewResponse, error)

type CreateBatchJobInvoker added in v0.0.90 

type CreateBatchJobInvoker struct {
	*invoker.BaseInvoker
}

func (*CreateBatchJobInvoker) Invoke added in v0.0.90 

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

type CreateComputingResourceInvoker added in v0.0.90 

type CreateComputingResourceInvoker struct {
	*invoker.BaseInvoker
}

func (*CreateComputingResourceInvoker) Invoke added in v0.0.90 

func (i *CreateComputingResourceInvoker) Invoke() (*model.CreateComputingResourceResponse, error)

type CreateDatasourceInvoker added in v0.0.90 

type CreateDatasourceInvoker struct {
	*invoker.BaseInvoker
}

func (*CreateDatasourceInvoker) Invoke added in v0.0.90 

func (i *CreateDatasourceInvoker) Invoke() (*model.CreateDatasourceResponse, error)

type CreateGroupInvoker added in v0.0.90 

type CreateGroupInvoker struct {
	*invoker.BaseInvoker
}

func (*CreateGroupInvoker) Invoke added in v0.0.90 

func (i *CreateGroupInvoker) Invoke() (*model.CreateGroupResponse, error)

type CreateRunInvoker added in v0.0.90 

type CreateRunInvoker struct {
	*invoker.BaseInvoker
}

func (*CreateRunInvoker) Invoke added in v0.0.90 

func (i *CreateRunInvoker) Invoke() (*model.CreateRunResponse, error)

type CreateStreamingJobInvoker added in v0.0.90 

type CreateStreamingJobInvoker struct {
	*invoker.BaseInvoker
}

func (*CreateStreamingJobInvoker) Invoke added in v0.0.90 

func (i *CreateStreamingJobInvoker) Invoke() (*model.CreateStreamingJobResponse, error)

type CreateTableInvoker added in v0.0.90 

type CreateTableInvoker struct {
	*invoker.BaseInvoker
}

func (*CreateTableInvoker) Invoke added in v0.0.90 

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

type DeleteAssetModelInvoker added in v0.0.90 

type DeleteAssetModelInvoker struct {
	*invoker.BaseInvoker
}

func (*DeleteAssetModelInvoker) Invoke added in v0.0.90 

func (i *DeleteAssetModelInvoker) Invoke() (*model.DeleteAssetModelResponse, error)

type DeleteAssetNewInvoker added in v0.0.90 

type DeleteAssetNewInvoker struct {
	*invoker.BaseInvoker
}

func (*DeleteAssetNewInvoker) Invoke added in v0.0.90 

func (i *DeleteAssetNewInvoker) Invoke() (*model.DeleteAssetNewResponse, error)

type DeleteBatchJobInvoker added in v0.0.90 

type DeleteBatchJobInvoker struct {
	*invoker.BaseInvoker
}

func (*DeleteBatchJobInvoker) Invoke added in v0.0.90 

func (i *DeleteBatchJobInvoker) Invoke() (*model.DeleteBatchJobResponse, error)

type DeleteComputingResourceInvoker added in v0.0.90 

type DeleteComputingResourceInvoker struct {
	*invoker.BaseInvoker
}

func (*DeleteComputingResourceInvoker) Invoke added in v0.0.90 

func (i *DeleteComputingResourceInvoker) Invoke() (*model.DeleteComputingResourceResponse, error)

type DeleteDataStoreInvoker added in v0.0.90 

type DeleteDataStoreInvoker struct {
	*invoker.BaseInvoker
}

func (*DeleteDataStoreInvoker) Invoke added in v0.0.90 

func (i *DeleteDataStoreInvoker) Invoke() (*model.DeleteDataStoreResponse, error)

type DeleteDatasourceInvoker added in v0.0.90 

type DeleteDatasourceInvoker struct {
	*invoker.BaseInvoker
}

func (*DeleteDatasourceInvoker) Invoke added in v0.0.90 

func (i *DeleteDatasourceInvoker) Invoke() (*model.DeleteDatasourceResponse, error)

type DeleteGroupInvoker added in v0.0.90 

type DeleteGroupInvoker struct {
	*invoker.BaseInvoker
}

func (*DeleteGroupInvoker) Invoke added in v0.0.90 

func (i *DeleteGroupInvoker) Invoke() (*model.DeleteGroupResponse, error)

type DeletePipelineJobInvoker added in v0.0.90 

type DeletePipelineJobInvoker struct {
	*invoker.BaseInvoker
}

func (*DeletePipelineJobInvoker) Invoke added in v0.0.90 

func (i *DeletePipelineJobInvoker) Invoke() (*model.DeletePipelineJobResponse, error)

type DeleteRunInvoker added in v0.0.90 

type DeleteRunInvoker struct {
	*invoker.BaseInvoker
}

func (*DeleteRunInvoker) Invoke added in v0.0.90 

func (i *DeleteRunInvoker) Invoke() (*model.DeleteRunResponse, error)

type DeleteStreamingJobByIdInvoker added in v0.0.90 

type DeleteStreamingJobByIdInvoker struct {
	*invoker.BaseInvoker
}

func (*DeleteStreamingJobByIdInvoker) Invoke added in v0.0.90 

func (i *DeleteStreamingJobByIdInvoker) Invoke() (*model.DeleteStreamingJobByIdResponse, error)

type DeleteTableInvoker added in v0.0.90 

type DeleteTableInvoker struct {
	*invoker.BaseInvoker
}

func (*DeleteTableInvoker) Invoke added in v0.0.90 

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

type ExportDatasetInvoker added in v0.0.90 

type ExportDatasetInvoker struct {
	*invoker.BaseInvoker
}

func (*ExportDatasetInvoker) Invoke added in v0.0.90 

func (i *ExportDatasetInvoker) Invoke() (*model.ExportDatasetResponse, error)

type ImportDataInvoker added in v0.0.90 

type ImportDataInvoker struct {
	*invoker.BaseInvoker
}

func (*ImportDataInvoker) Invoke added in v0.0.90 

func (i *ImportDataInvoker) Invoke() (*model.ImportDataResponse, error)

type IoTAnalyticsClient 

type IoTAnalyticsClient struct {
	HcClient *http_client.HcHttpClient
}

func NewIoTAnalyticsClient 

func NewIoTAnalyticsClient(hcClient *http_client.HcHttpClient) *IoTAnalyticsClient

func (*IoTAnalyticsClient) AddDevData 

func (c *IoTAnalyticsClient) AddDevData(request *model.AddDevDataRequest) (*model.AddDevDataResponse, error)

AddDevData 通过API数据源上报设备数据

通过API数据源上报设备数据

Please refer to HUAWEI cloud API Explorer for details.

func (*IoTAnalyticsClient) AddDevDataInvoker added in v0.0.90 

func (c *IoTAnalyticsClient) AddDevDataInvoker(request *model.AddDevDataRequest) *AddDevDataInvoker

AddDevDataInvoker 通过API数据源上报设备数据

func (*IoTAnalyticsClient) AddPipelineJob 

func (c *IoTAnalyticsClient) AddPipelineJob(request *model.AddPipelineJobRequest) (*model.AddPipelineJobResponse, error)

AddPipelineJob 新建管道作业

新建管道作业时，需要在URL中指定是更新哪一个作业，将在body中附带完整的作业信息。（作业中各算子的详细配置请参考算子配置章节。） check参数表示是否需要对作业配置进行检查，若为false，则不检查，将作业保存为草稿；若为true，则对作业配置进行检查。当检查不通过时，将作业状态修改为草稿；检查通过时，将作业状态修改为就绪，并返回成功。

Please refer to HUAWEI cloud API Explorer for details.

func (*IoTAnalyticsClient) AddPipelineJobInvoker added in v0.0.90 

func (c *IoTAnalyticsClient) AddPipelineJobInvoker(request *model.AddPipelineJobRequest) *AddPipelineJobInvoker

AddPipelineJobInvoker 新建管道作业

func (*IoTAnalyticsClient) CreateAssetModel 

func (c *IoTAnalyticsClient) CreateAssetModel(request *model.CreateAssetModelRequest) (*model.CreateAssetModelResponse, error)

CreateAssetModel 创建资产模型

创建资产模型

Please refer to HUAWEI cloud API Explorer for details.

func (*IoTAnalyticsClient) CreateAssetModelInvoker added in v0.0.90 

func (c *IoTAnalyticsClient) CreateAssetModelInvoker(request *model.CreateAssetModelRequest) *CreateAssetModelInvoker

CreateAssetModelInvoker 创建资产模型

func (*IoTAnalyticsClient) CreateAssetNew 

func (c *IoTAnalyticsClient) CreateAssetNew(request *model.CreateAssetNewRequest) (*model.CreateAssetNewResponse, error)

CreateAssetNew 创建资产

创建资产

Please refer to HUAWEI cloud API Explorer for details.

func (*IoTAnalyticsClient) CreateAssetNewInvoker added in v0.0.90 

func (c *IoTAnalyticsClient) CreateAssetNewInvoker(request *model.CreateAssetNewRequest) *CreateAssetNewInvoker

CreateAssetNewInvoker 创建资产

func (*IoTAnalyticsClient) CreateBatchJob 

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

CreateBatchJob 创建离线作业

创建离线作业。

Please refer to HUAWEI cloud API Explorer for details.

func (*IoTAnalyticsClient) CreateBatchJobInvoker added in v0.0.90 

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

CreateBatchJobInvoker 创建离线作业

func (*IoTAnalyticsClient) CreateComputingResource 

func (c *IoTAnalyticsClient) CreateComputingResource(request *model.CreateComputingResourceRequest) (*model.CreateComputingResourceResponse, error)

CreateComputingResource 创建批计算资源

创建批计算资源。

Please refer to HUAWEI cloud API Explorer for details.

func (*IoTAnalyticsClient) CreateComputingResourceInvoker added in v0.0.90 

func (c *IoTAnalyticsClient) CreateComputingResourceInvoker(request *model.CreateComputingResourceRequest) *CreateComputingResourceInvoker

CreateComputingResourceInvoker 创建批计算资源

func (*IoTAnalyticsClient) CreateDatasource 

func (c *IoTAnalyticsClient) CreateDatasource(request *model.CreateDatasourceRequest) (*model.CreateDatasourceResponse, error)

CreateDatasource 创建数据源

创建数据源

Please refer to HUAWEI cloud API Explorer for details.

func (*IoTAnalyticsClient) CreateDatasourceInvoker added in v0.0.90 

func (c *IoTAnalyticsClient) CreateDatasourceInvoker(request *model.CreateDatasourceRequest) *CreateDatasourceInvoker

CreateDatasourceInvoker 创建数据源

func (*IoTAnalyticsClient) CreateGroup 

func (c *IoTAnalyticsClient) CreateGroup(request *model.CreateGroupRequest) (*model.CreateGroupResponse, error)

CreateGroup 创建存储组

创建存储组

Please refer to HUAWEI cloud API Explorer for details.

func (*IoTAnalyticsClient) CreateGroupInvoker added in v0.0.90 

func (c *IoTAnalyticsClient) CreateGroupInvoker(request *model.CreateGroupRequest) *CreateGroupInvoker

CreateGroupInvoker 创建存储组

func (*IoTAnalyticsClient) CreateRun 

func (c *IoTAnalyticsClient) CreateRun(request *model.CreateRunRequest) (*model.CreateRunResponse, error)

CreateRun 执行离线作业

执行离线作业。

Please refer to HUAWEI cloud API Explorer for details.

func (*IoTAnalyticsClient) CreateRunInvoker added in v0.0.90 

func (c *IoTAnalyticsClient) CreateRunInvoker(request *model.CreateRunRequest) *CreateRunInvoker

CreateRunInvoker 执行离线作业

func (*IoTAnalyticsClient) CreateStreamingJob 

func (c *IoTAnalyticsClient) CreateStreamingJob(request *model.CreateStreamingJobRequest) (*model.CreateStreamingJobResponse, error)

CreateStreamingJob 新建实时作业

除名称和描述外，可先不提供作业的详细配置信息。 check参数表示是否需要对作业配置进行检查，若为false，则不检查，将作业保存为草稿；若为true，则对作业配置进行检查，无论检查是否通过，都将作业及配置信息保存为草稿，当检查不通过时，返回失败及错误信息，检查通过时，将作业状态修改为就绪，并返回成功。

Please refer to HUAWEI cloud API Explorer for details.

func (*IoTAnalyticsClient) CreateStreamingJobInvoker added in v0.0.90 

func (c *IoTAnalyticsClient) CreateStreamingJobInvoker(request *model.CreateStreamingJobRequest) *CreateStreamingJobInvoker

CreateStreamingJobInvoker 新建实时作业

func (*IoTAnalyticsClient) CreateTable 

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

CreateTable 创建离线数据表

创建离线数据表。

Please refer to HUAWEI cloud API Explorer for details.

func (*IoTAnalyticsClient) CreateTableInvoker added in v0.0.90 

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

CreateTableInvoker 创建离线数据表

func (*IoTAnalyticsClient) DeleteAssetModel 

func (c *IoTAnalyticsClient) DeleteAssetModel(request *model.DeleteAssetModelRequest) (*model.DeleteAssetModelResponse, error)

DeleteAssetModel 删除资产模型

删除资产模型

Please refer to HUAWEI cloud API Explorer for details.

func (*IoTAnalyticsClient) DeleteAssetModelInvoker added in v0.0.90 

func (c *IoTAnalyticsClient) DeleteAssetModelInvoker(request *model.DeleteAssetModelRequest) *DeleteAssetModelInvoker

DeleteAssetModelInvoker 删除资产模型

func (*IoTAnalyticsClient) DeleteAssetNew 

func (c *IoTAnalyticsClient) DeleteAssetNew(request *model.DeleteAssetNewRequest) (*model.DeleteAssetNewResponse, error)

DeleteAssetNew 删除资产

删除资产

Please refer to HUAWEI cloud API Explorer for details.

func (*IoTAnalyticsClient) DeleteAssetNewInvoker added in v0.0.90 

func (c *IoTAnalyticsClient) DeleteAssetNewInvoker(request *model.DeleteAssetNewRequest) *DeleteAssetNewInvoker

DeleteAssetNewInvoker 删除资产

func (*IoTAnalyticsClient) DeleteBatchJob 

func (c *IoTAnalyticsClient) DeleteBatchJob(request *model.DeleteBatchJobRequest) (*model.DeleteBatchJobResponse, error)

DeleteBatchJob 删除离线作业

删除离线作业。

Please refer to HUAWEI cloud API Explorer for details.

func (*IoTAnalyticsClient) DeleteBatchJobInvoker added in v0.0.90 

func (c *IoTAnalyticsClient) DeleteBatchJobInvoker(request *model.DeleteBatchJobRequest) *DeleteBatchJobInvoker

DeleteBatchJobInvoker 删除离线作业

func (*IoTAnalyticsClient) DeleteComputingResource 

func (c *IoTAnalyticsClient) DeleteComputingResource(request *model.DeleteComputingResourceRequest) (*model.DeleteComputingResourceResponse, error)

DeleteComputingResource 删除批计算资源

删除批计算资源。

Please refer to HUAWEI cloud API Explorer for details.

func (*IoTAnalyticsClient) DeleteComputingResourceInvoker added in v0.0.90 

func (c *IoTAnalyticsClient) DeleteComputingResourceInvoker(request *model.DeleteComputingResourceRequest) *DeleteComputingResourceInvoker

DeleteComputingResourceInvoker 删除批计算资源

func (*IoTAnalyticsClient) DeleteDataStore 

func (c *IoTAnalyticsClient) DeleteDataStore(request *model.DeleteDataStoreRequest) (*model.DeleteDataStoreResponse, error)

DeleteDataStore 删除存储

删除存储

Please refer to HUAWEI cloud API Explorer for details.

func (*IoTAnalyticsClient) DeleteDataStoreInvoker added in v0.0.90 

func (c *IoTAnalyticsClient) DeleteDataStoreInvoker(request *model.DeleteDataStoreRequest) *DeleteDataStoreInvoker

DeleteDataStoreInvoker 删除存储

func (*IoTAnalyticsClient) DeleteDatasource 

func (c *IoTAnalyticsClient) DeleteDatasource(request *model.DeleteDatasourceRequest) (*model.DeleteDatasourceResponse, error)

DeleteDatasource 删除数据源

删除数据源

Please refer to HUAWEI cloud API Explorer for details.

func (*IoTAnalyticsClient) DeleteDatasourceInvoker added in v0.0.90 

func (c *IoTAnalyticsClient) DeleteDatasourceInvoker(request *model.DeleteDatasourceRequest) *DeleteDatasourceInvoker

DeleteDatasourceInvoker 删除数据源

func (*IoTAnalyticsClient) DeleteGroup 

func (c *IoTAnalyticsClient) DeleteGroup(request *model.DeleteGroupRequest) (*model.DeleteGroupResponse, error)

DeleteGroup 删除存储组

删除存储组

Please refer to HUAWEI cloud API Explorer for details.

func (*IoTAnalyticsClient) DeleteGroupInvoker added in v0.0.90 

func (c *IoTAnalyticsClient) DeleteGroupInvoker(request *model.DeleteGroupRequest) *DeleteGroupInvoker

DeleteGroupInvoker 删除存储组

func (*IoTAnalyticsClient) DeletePipelineJob 

func (c *IoTAnalyticsClient) DeletePipelineJob(request *model.DeletePipelineJobRequest) (*model.DeletePipelineJobResponse, error)

DeletePipelineJob 删除管道作业

删除用户指定的管道作业

Please refer to HUAWEI cloud API Explorer for details.

func (*IoTAnalyticsClient) DeletePipelineJobInvoker added in v0.0.90 

func (c *IoTAnalyticsClient) DeletePipelineJobInvoker(request *model.DeletePipelineJobRequest) *DeletePipelineJobInvoker

DeletePipelineJobInvoker 删除管道作业

func (*IoTAnalyticsClient) DeleteRun 

func (c *IoTAnalyticsClient) DeleteRun(request *model.DeleteRunRequest) (*model.DeleteRunResponse, error)

DeleteRun 停止离线作业

停止提交中或运行中的离线作业，若作业已经执行结束或失败则无法停止。

Please refer to HUAWEI cloud API Explorer for details.

func (*IoTAnalyticsClient) DeleteRunInvoker added in v0.0.90 

func (c *IoTAnalyticsClient) DeleteRunInvoker(request *model.DeleteRunRequest) *DeleteRunInvoker

DeleteRunInvoker 停止离线作业

func (*IoTAnalyticsClient) DeleteStreamingJobById 

func (c *IoTAnalyticsClient) DeleteStreamingJobById(request *model.DeleteStreamingJobByIdRequest) (*model.DeleteStreamingJobByIdResponse, error)

DeleteStreamingJobById 删除实时作业

删除用户指定的作业

Please refer to HUAWEI cloud API Explorer for details.

func (*IoTAnalyticsClient) DeleteStreamingJobByIdInvoker added in v0.0.90 

func (c *IoTAnalyticsClient) DeleteStreamingJobByIdInvoker(request *model.DeleteStreamingJobByIdRequest) *DeleteStreamingJobByIdInvoker

DeleteStreamingJobByIdInvoker 删除实时作业

func (*IoTAnalyticsClient) DeleteTable 

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

DeleteTable 删除离线数据表

删除离线数据表。

Please refer to HUAWEI cloud API Explorer for details.

func (*IoTAnalyticsClient) DeleteTableInvoker added in v0.0.90 

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

DeleteTableInvoker 删除离线数据表

func (*IoTAnalyticsClient) ExportDataset 

func (c *IoTAnalyticsClient) ExportDataset(request *model.ExportDatasetRequest) (*model.ExportDatasetResponse, error)

ExportDataset 下载离线作业结果

将SQL语句的查询结果下载到本地，只支持下载“QUERY”类型作业的查询结果。

Please refer to HUAWEI cloud API Explorer for details.

func (*IoTAnalyticsClient) ExportDatasetInvoker added in v0.0.90 

func (c *IoTAnalyticsClient) ExportDatasetInvoker(request *model.ExportDatasetRequest) *ExportDatasetInvoker

ExportDatasetInvoker 下载离线作业结果

func (*IoTAnalyticsClient) ImportData 

func (c *IoTAnalyticsClient) ImportData(request *model.ImportDataRequest) (*model.ImportDataResponse, error)

ImportData 执行导入数据离线作业

将数据从文件导入OBS表。

Please refer to HUAWEI cloud API Explorer for details.

func (*IoTAnalyticsClient) ImportDataInvoker added in v0.0.90 

func (c *IoTAnalyticsClient) ImportDataInvoker(request *model.ImportDataRequest) *ImportDataInvoker

ImportDataInvoker 执行导入数据离线作业

func (*IoTAnalyticsClient) ListAssetModels 

func (c *IoTAnalyticsClient) ListAssetModels(request *model.ListAssetModelsRequest) (*model.ListAssetModelsResponse, error)

ListAssetModels 获取资产模型列表

获取资产模型列表

Please refer to HUAWEI cloud API Explorer for details.

func (*IoTAnalyticsClient) ListAssetModelsInvoker added in v0.0.90 

func (c *IoTAnalyticsClient) ListAssetModelsInvoker(request *model.ListAssetModelsRequest) *ListAssetModelsInvoker

ListAssetModelsInvoker 获取资产模型列表

func (*IoTAnalyticsClient) ListAssetsNew 

func (c *IoTAnalyticsClient) ListAssetsNew(request *model.ListAssetsNewRequest) (*model.ListAssetsNewResponse, error)

ListAssetsNew 获取资产列表

获取资产列表

Please refer to HUAWEI cloud API Explorer for details.

func (*IoTAnalyticsClient) ListAssetsNewInvoker added in v0.0.90 

func (c *IoTAnalyticsClient) ListAssetsNewInvoker(request *model.ListAssetsNewRequest) *ListAssetsNewInvoker

ListAssetsNewInvoker 获取资产列表

func (*IoTAnalyticsClient) ListBatchJobs 

func (c *IoTAnalyticsClient) ListBatchJobs(request *model.ListBatchJobsRequest) (*model.ListBatchJobsResponse, error)

ListBatchJobs 查询离线作业列表

查询离线作业列表。

Please refer to HUAWEI cloud API Explorer for details.

func (*IoTAnalyticsClient) ListBatchJobsInvoker added in v0.0.90 

func (c *IoTAnalyticsClient) ListBatchJobsInvoker(request *model.ListBatchJobsRequest) *ListBatchJobsInvoker

ListBatchJobsInvoker 查询离线作业列表

func (*IoTAnalyticsClient) ListComputingResources 

func (c *IoTAnalyticsClient) ListComputingResources(request *model.ListComputingResourcesRequest) (*model.ListComputingResourcesResponse, error)

ListComputingResources 查询批计算资源列表

查询批计算资源列表。

Please refer to HUAWEI cloud API Explorer for details.

func (*IoTAnalyticsClient) ListComputingResourcesInvoker added in v0.0.90 

func (c *IoTAnalyticsClient) ListComputingResourcesInvoker(request *model.ListComputingResourcesRequest) *ListComputingResourcesInvoker

ListComputingResourcesInvoker 查询批计算资源列表

func (*IoTAnalyticsClient) ListDataStores 

func (c *IoTAnalyticsClient) ListDataStores(request *model.ListDataStoresRequest) (*model.ListDataStoresResponse, error)

ListDataStores 查询存储列表

查询存储列表

Please refer to HUAWEI cloud API Explorer for details.

func (*IoTAnalyticsClient) ListDataStoresInvoker added in v0.0.90 

func (c *IoTAnalyticsClient) ListDataStoresInvoker(request *model.ListDataStoresRequest) *ListDataStoresInvoker

ListDataStoresInvoker 查询存储列表

func (*IoTAnalyticsClient) ListGroups 

func (c *IoTAnalyticsClient) ListGroups(request *model.ListGroupsRequest) (*model.ListGroupsResponse, error)

ListGroups 查询存储组列表

查询存储组列表

Please refer to HUAWEI cloud API Explorer for details.

func (*IoTAnalyticsClient) ListGroupsInvoker added in v0.0.90 

func (c *IoTAnalyticsClient) ListGroupsInvoker(request *model.ListGroupsRequest) *ListGroupsInvoker

ListGroupsInvoker 查询存储组列表

func (*IoTAnalyticsClient) ListHistory 

func (c *IoTAnalyticsClient) ListHistory(request *model.ListHistoryRequest) (*model.ListHistoryResponse, error)

ListHistory 根据标签查询设备历史值

根据标签查询设备历史值

Please refer to HUAWEI cloud API Explorer for details.

func (*IoTAnalyticsClient) ListHistoryInvoker added in v0.0.90 

func (c *IoTAnalyticsClient) ListHistoryInvoker(request *model.ListHistoryRequest) *ListHistoryInvoker

ListHistoryInvoker 根据标签查询设备历史值

func (*IoTAnalyticsClient) ListMetrics 

func (c *IoTAnalyticsClient) ListMetrics(request *model.ListMetricsRequest) (*model.ListMetricsResponse, error)

ListMetrics 根据标签聚合、查询指标数据

根据标签聚合、查询数据

Please refer to HUAWEI cloud API Explorer for details.

func (*IoTAnalyticsClient) ListMetricsInvoker added in v0.0.90 

func (c *IoTAnalyticsClient) ListMetricsInvoker(request *model.ListMetricsRequest) *ListMetricsInvoker

ListMetricsInvoker 根据标签聚合、查询指标数据

func (*IoTAnalyticsClient) ListPipelineJobs 

func (c *IoTAnalyticsClient) ListPipelineJobs(request *model.ListPipelineJobsRequest) (*model.ListPipelineJobsResponse, error)

ListPipelineJobs 获取管道作业列表

获取用户下的所有管道作业，支持分页。

Please refer to HUAWEI cloud API Explorer for details.

func (*IoTAnalyticsClient) ListPipelineJobsInvoker added in v0.0.90 

func (c *IoTAnalyticsClient) ListPipelineJobsInvoker(request *model.ListPipelineJobsRequest) *ListPipelineJobsInvoker

ListPipelineJobsInvoker 获取管道作业列表

func (*IoTAnalyticsClient) ListRuns 

func (c *IoTAnalyticsClient) ListRuns(request *model.ListRunsRequest) (*model.ListRunsResponse, error)

ListRuns 查询离线作业运行列表

查询离线作业运行列表。

Please refer to HUAWEI cloud API Explorer for details.

func (*IoTAnalyticsClient) ListRunsInvoker added in v0.0.90 

func (c *IoTAnalyticsClient) ListRunsInvoker(request *model.ListRunsRequest) *ListRunsInvoker

ListRunsInvoker 查询离线作业运行列表

func (*IoTAnalyticsClient) ListTables 

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

ListTables 查询离线数据表列表

查询离线数据表列表。

Please refer to HUAWEI cloud API Explorer for details.

func (*IoTAnalyticsClient) ListTablesInvoker added in v0.0.90 

func (c *IoTAnalyticsClient) ListTablesInvoker(request *model.ListTablesRequest) *ListTablesInvoker

ListTablesInvoker 查询离线数据表列表

func (*IoTAnalyticsClient) ListTagValues 

func (c *IoTAnalyticsClient) ListTagValues(request *model.ListTagValuesRequest) (*model.ListTagValuesResponse, error)

ListTagValues 查询标签的值列表

查询标签的值列表

Please refer to HUAWEI cloud API Explorer for details.

func (*IoTAnalyticsClient) ListTagValuesInvoker added in v0.0.90 

func (c *IoTAnalyticsClient) ListTagValuesInvoker(request *model.ListTagValuesRequest) *ListTagValuesInvoker

ListTagValuesInvoker 查询标签的值列表

func (*IoTAnalyticsClient) PublishRootAsset 

func (c *IoTAnalyticsClient) PublishRootAsset(request *model.PublishRootAssetRequest) (*model.PublishRootAssetResponse, error)

PublishRootAsset 发布资产

发布资产

Please refer to HUAWEI cloud API Explorer for details.

func (*IoTAnalyticsClient) PublishRootAssetInvoker added in v0.0.90 

func (c *IoTAnalyticsClient) PublishRootAssetInvoker(request *model.PublishRootAssetRequest) *PublishRootAssetInvoker

PublishRootAssetInvoker 发布资产

func (*IoTAnalyticsClient) ShowAllDataSource 

func (c *IoTAnalyticsClient) ShowAllDataSource(request *model.ShowAllDataSourceRequest) (*model.ShowAllDataSourceResponse, error)

ShowAllDataSource 查询数据源列表

查询数据源列表

Please refer to HUAWEI cloud API Explorer for details.

func (*IoTAnalyticsClient) ShowAllDataSourceInvoker added in v0.0.90 

func (c *IoTAnalyticsClient) ShowAllDataSourceInvoker(request *model.ShowAllDataSourceRequest) *ShowAllDataSourceInvoker

ShowAllDataSourceInvoker 查询数据源列表

func (*IoTAnalyticsClient) ShowAssetModel 

func (c *IoTAnalyticsClient) ShowAssetModel(request *model.ShowAssetModelRequest) (*model.ShowAssetModelResponse, error)

ShowAssetModel 获取资产模型详情

获取资产模型详情

Please refer to HUAWEI cloud API Explorer for details.

func (*IoTAnalyticsClient) ShowAssetModelInvoker added in v0.0.90 

func (c *IoTAnalyticsClient) ShowAssetModelInvoker(request *model.ShowAssetModelRequest) *ShowAssetModelInvoker

ShowAssetModelInvoker 获取资产模型详情

func (*IoTAnalyticsClient) ShowAssetNew 

func (c *IoTAnalyticsClient) ShowAssetNew(request *model.ShowAssetNewRequest) (*model.ShowAssetNewResponse, error)

ShowAssetNew 获取资产详情

获取资产详情

Please refer to HUAWEI cloud API Explorer for details.

func (*IoTAnalyticsClient) ShowAssetNewInvoker added in v0.0.90 

func (c *IoTAnalyticsClient) ShowAssetNewInvoker(request *model.ShowAssetNewRequest) *ShowAssetNewInvoker

ShowAssetNewInvoker 获取资产详情

func (*IoTAnalyticsClient) ShowBatchJob 

func (c *IoTAnalyticsClient) ShowBatchJob(request *model.ShowBatchJobRequest) (*model.ShowBatchJobResponse, error)

ShowBatchJob 查询离线作业详情

查询离线作业详情。

Please refer to HUAWEI cloud API Explorer for details.

func (*IoTAnalyticsClient) ShowBatchJobInvoker added in v0.0.90 

func (c *IoTAnalyticsClient) ShowBatchJobInvoker(request *model.ShowBatchJobRequest) *ShowBatchJobInvoker

ShowBatchJobInvoker 查询离线作业详情

func (*IoTAnalyticsClient) ShowDataSource 

func (c *IoTAnalyticsClient) ShowDataSource(request *model.ShowDataSourceRequest) (*model.ShowDataSourceResponse, error)

ShowDataSource 查询数据源详情

查询数据源详情

Please refer to HUAWEI cloud API Explorer for details.

func (*IoTAnalyticsClient) ShowDataSourceInvoker added in v0.0.90 

func (c *IoTAnalyticsClient) ShowDataSourceInvoker(request *model.ShowDataSourceRequest) *ShowDataSourceInvoker

ShowDataSourceInvoker 查询数据源详情

func (*IoTAnalyticsClient) ShowDataset 

func (c *IoTAnalyticsClient) ShowDataset(request *model.ShowDatasetRequest) (*model.ShowDatasetResponse, error)

ShowDataset 查询离线作业结果

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

Please refer to HUAWEI cloud API Explorer for details.

func (*IoTAnalyticsClient) ShowDatasetInvoker added in v0.0.90 

func (c *IoTAnalyticsClient) ShowDatasetInvoker(request *model.ShowDatasetRequest) *ShowDatasetInvoker

ShowDatasetInvoker 查询离线作业结果

func (*IoTAnalyticsClient) ShowJobById 

func (c *IoTAnalyticsClient) ShowJobById(request *model.ShowJobByIdRequest) (*model.ShowJobByIdResponse, error)

ShowJobById 获取实时作业详情

获取指定作业的详情

Please refer to HUAWEI cloud API Explorer for details.

func (*IoTAnalyticsClient) ShowJobByIdInvoker added in v0.0.90 

func (c *IoTAnalyticsClient) ShowJobByIdInvoker(request *model.ShowJobByIdRequest) *ShowJobByIdInvoker

ShowJobByIdInvoker 获取实时作业详情

func (*IoTAnalyticsClient) ShowJobs 

func (c *IoTAnalyticsClient) ShowJobs(request *model.ShowJobsRequest) (*model.ShowJobsResponse, error)

ShowJobs 获取实时作业列表

获取用户下的所有实时分析作业，支持分页。

Please refer to HUAWEI cloud API Explorer for details.

func (*IoTAnalyticsClient) ShowJobsInvoker added in v0.0.90 

func (c *IoTAnalyticsClient) ShowJobsInvoker(request *model.ShowJobsRequest) *ShowJobsInvoker

ShowJobsInvoker 获取实时作业列表

func (*IoTAnalyticsClient) ShowLastPropertyValue 

func (c *IoTAnalyticsClient) ShowLastPropertyValue(request *model.ShowLastPropertyValueRequest) (*model.ShowLastPropertyValueResponse, error)

ShowLastPropertyValue 获取资产属性最新值

获取资产属性最新值

Please refer to HUAWEI cloud API Explorer for details.

func (*IoTAnalyticsClient) ShowLastPropertyValueInvoker added in v0.0.90 

func (c *IoTAnalyticsClient) ShowLastPropertyValueInvoker(request *model.ShowLastPropertyValueRequest) *ShowLastPropertyValueInvoker

ShowLastPropertyValueInvoker 获取资产属性最新值

func (*IoTAnalyticsClient) ShowMetricValue 

func (c *IoTAnalyticsClient) ShowMetricValue(request *model.ShowMetricValueRequest) (*model.ShowMetricValueResponse, error)

ShowMetricValue 获取资产属性聚合值

获取资产属性聚合值

Please refer to HUAWEI cloud API Explorer for details.

func (*IoTAnalyticsClient) ShowMetricValueInvoker added in v0.0.90 

func (c *IoTAnalyticsClient) ShowMetricValueInvoker(request *model.ShowMetricValueRequest) *ShowMetricValueInvoker

ShowMetricValueInvoker 获取资产属性聚合值

func (*IoTAnalyticsClient) ShowPipelineJob 

func (c *IoTAnalyticsClient) ShowPipelineJob(request *model.ShowPipelineJobRequest) (*model.ShowPipelineJobResponse, error)

ShowPipelineJob 获取管道作业详情

获取指定管道作业的详情

Please refer to HUAWEI cloud API Explorer for details.

func (*IoTAnalyticsClient) ShowPipelineJobInvoker added in v0.0.90 

func (c *IoTAnalyticsClient) ShowPipelineJobInvoker(request *model.ShowPipelineJobRequest) *ShowPipelineJobInvoker

ShowPipelineJobInvoker 获取管道作业详情

func (*IoTAnalyticsClient) ShowPropertyRawValue 

func (c *IoTAnalyticsClient) ShowPropertyRawValue(request *model.ShowPropertyRawValueRequest) (*model.ShowPropertyRawValueResponse, error)

ShowPropertyRawValue 获取资产属性历史值

获取资产属性历史值

Please refer to HUAWEI cloud API Explorer for details.

func (*IoTAnalyticsClient) ShowPropertyRawValueInvoker added in v0.0.90 

func (c *IoTAnalyticsClient) ShowPropertyRawValueInvoker(request *model.ShowPropertyRawValueRequest) *ShowPropertyRawValueInvoker

ShowPropertyRawValueInvoker 获取资产属性历史值

func (*IoTAnalyticsClient) ShowPropertyValues 

func (c *IoTAnalyticsClient) ShowPropertyValues(request *model.ShowPropertyValuesRequest) (*model.ShowPropertyValuesResponse, error)

ShowPropertyValues 查询设备属性最新状态值

查询设备属性最新状态值

Please refer to HUAWEI cloud API Explorer for details.

func (*IoTAnalyticsClient) ShowPropertyValuesInvoker added in v0.0.90 

func (c *IoTAnalyticsClient) ShowPropertyValuesInvoker(request *model.ShowPropertyValuesRequest) *ShowPropertyValuesInvoker

ShowPropertyValuesInvoker 查询设备属性最新状态值

func (*IoTAnalyticsClient) ShowRun 

func (c *IoTAnalyticsClient) ShowRun(request *model.ShowRunRequest) (*model.ShowRunResponse, error)

ShowRun 查询离线作业运行详情

查询离线作业运行详情。

Please refer to HUAWEI cloud API Explorer for details.

func (*IoTAnalyticsClient) ShowRunInvoker added in v0.0.90 

func (c *IoTAnalyticsClient) ShowRunInvoker(request *model.ShowRunRequest) *ShowRunInvoker

ShowRunInvoker 查询离线作业运行详情

func (*IoTAnalyticsClient) ShowTablePreview 

func (c *IoTAnalyticsClient) ShowTablePreview(request *model.ShowTablePreviewRequest) (*model.ShowTablePreviewResponse, error)

ShowTablePreview 预览离线数据表内容

预览离线数据表内容。

Please refer to HUAWEI cloud API Explorer for details.

func (*IoTAnalyticsClient) ShowTablePreviewInvoker added in v0.0.90 

func (c *IoTAnalyticsClient) ShowTablePreviewInvoker(request *model.ShowTablePreviewRequest) *ShowTablePreviewInvoker

ShowTablePreviewInvoker 预览离线数据表内容

func (*IoTAnalyticsClient) ShowTableSchema 

func (c *IoTAnalyticsClient) ShowTableSchema(request *model.ShowTableSchemaRequest) (*model.ShowTableSchemaResponse, error)

ShowTableSchema 查询离线数据表结构

查询离线数据表结构。

Please refer to HUAWEI cloud API Explorer for details.

func (*IoTAnalyticsClient) ShowTableSchemaInvoker added in v0.0.90 

func (c *IoTAnalyticsClient) ShowTableSchemaInvoker(request *model.ShowTableSchemaRequest) *ShowTableSchemaInvoker

ShowTableSchemaInvoker 查询离线数据表结构

func (*IoTAnalyticsClient) StartJob 

func (c *IoTAnalyticsClient) StartJob(request *model.StartJobRequest) (*model.StartJobResponse, error)

StartJob 启动实时作业

提交作业到运行环境，实时接收数据并按用户定义的业务逻辑对数据进行处理。

Please refer to HUAWEI cloud API Explorer for details.

func (*IoTAnalyticsClient) StartJobInvoker added in v0.0.90 

func (c *IoTAnalyticsClient) StartJobInvoker(request *model.StartJobRequest) *StartJobInvoker

StartJobInvoker 启动实时作业

func (*IoTAnalyticsClient) StartPipelineJob 

func (c *IoTAnalyticsClient) StartPipelineJob(request *model.StartPipelineJobRequest) (*model.StartPipelineJobResponse, error)

StartPipelineJob 启动管道作业

提交管道作业到运行环境，实时接收数据源的数据并按用户定义的数据清洗逻辑对数据进行处理。

Please refer to HUAWEI cloud API Explorer for details.

func (*IoTAnalyticsClient) StartPipelineJobInvoker added in v0.0.90 

func (c *IoTAnalyticsClient) StartPipelineJobInvoker(request *model.StartPipelineJobRequest) *StartPipelineJobInvoker

StartPipelineJobInvoker 启动管道作业

func (*IoTAnalyticsClient) StopJob 

func (c *IoTAnalyticsClient) StopJob(request *model.StopJobRequest) (*model.StopJobResponse, error)

StopJob 停止实时作业

停止一个正在运行中的作业

Please refer to HUAWEI cloud API Explorer for details.

func (*IoTAnalyticsClient) StopJobInvoker added in v0.0.90 

func (c *IoTAnalyticsClient) StopJobInvoker(request *model.StopJobRequest) *StopJobInvoker

StopJobInvoker 停止实时作业

func (*IoTAnalyticsClient) StopPipelineJob 

func (c *IoTAnalyticsClient) StopPipelineJob(request *model.StopPipelineJobRequest) (*model.StopPipelineJobResponse, error)

StopPipelineJob 停止管道作业

停止一个正在运行中的管道作业

Please refer to HUAWEI cloud API Explorer for details.

func (*IoTAnalyticsClient) StopPipelineJobInvoker added in v0.0.90 

func (c *IoTAnalyticsClient) StopPipelineJobInvoker(request *model.StopPipelineJobRequest) *StopPipelineJobInvoker

StopPipelineJobInvoker 停止管道作业

func (*IoTAnalyticsClient) UpdateAssetModel 

func (c *IoTAnalyticsClient) UpdateAssetModel(request *model.UpdateAssetModelRequest) (*model.UpdateAssetModelResponse, error)

UpdateAssetModel 修改资产模型

修改资产模型

Please refer to HUAWEI cloud API Explorer for details.

func (*IoTAnalyticsClient) UpdateAssetModelInvoker added in v0.0.90 

func (c *IoTAnalyticsClient) UpdateAssetModelInvoker(request *model.UpdateAssetModelRequest) *UpdateAssetModelInvoker

UpdateAssetModelInvoker 修改资产模型

func (*IoTAnalyticsClient) UpdateAssetNew 

func (c *IoTAnalyticsClient) UpdateAssetNew(request *model.UpdateAssetNewRequest) (*model.UpdateAssetNewResponse, error)

UpdateAssetNew 修改资产

修改资产

Please refer to HUAWEI cloud API Explorer for details.

func (*IoTAnalyticsClient) UpdateAssetNewInvoker added in v0.0.90 

func (c *IoTAnalyticsClient) UpdateAssetNewInvoker(request *model.UpdateAssetNewRequest) *UpdateAssetNewInvoker

UpdateAssetNewInvoker 修改资产

func (*IoTAnalyticsClient) UpdateBatchJob 

func (c *IoTAnalyticsClient) UpdateBatchJob(request *model.UpdateBatchJobRequest) (*model.UpdateBatchJobResponse, error)

UpdateBatchJob 修改离线作业

修改离线作业。

Please refer to HUAWEI cloud API Explorer for details.

func (*IoTAnalyticsClient) UpdateBatchJobInvoker added in v0.0.90 

func (c *IoTAnalyticsClient) UpdateBatchJobInvoker(request *model.UpdateBatchJobRequest) *UpdateBatchJobInvoker

UpdateBatchJobInvoker 修改离线作业

func (*IoTAnalyticsClient) UpdateDataSource 

func (c *IoTAnalyticsClient) UpdateDataSource(request *model.UpdateDataSourceRequest) (*model.UpdateDataSourceResponse, error)

UpdateDataSource 修改数据源

修改数据源

Please refer to HUAWEI cloud API Explorer for details.

func (*IoTAnalyticsClient) UpdateDataSourceInvoker added in v0.0.90 

func (c *IoTAnalyticsClient) UpdateDataSourceInvoker(request *model.UpdateDataSourceRequest) *UpdateDataSourceInvoker

UpdateDataSourceInvoker 修改数据源

func (*IoTAnalyticsClient) UpdateDataStore 

func (c *IoTAnalyticsClient) UpdateDataStore(request *model.UpdateDataStoreRequest) (*model.UpdateDataStoreResponse, error)

UpdateDataStore 更新存储

更新存储

Please refer to HUAWEI cloud API Explorer for details.

func (*IoTAnalyticsClient) UpdateDataStoreInvoker added in v0.0.90 

func (c *IoTAnalyticsClient) UpdateDataStoreInvoker(request *model.UpdateDataStoreRequest) *UpdateDataStoreInvoker

UpdateDataStoreInvoker 更新存储

func (*IoTAnalyticsClient) UpdateGroup 

func (c *IoTAnalyticsClient) UpdateGroup(request *model.UpdateGroupRequest) (*model.UpdateGroupResponse, error)

UpdateGroup 更新存储组

更新存储组

Please refer to HUAWEI cloud API Explorer for details.

func (*IoTAnalyticsClient) UpdateGroupInvoker added in v0.0.90 

func (c *IoTAnalyticsClient) UpdateGroupInvoker(request *model.UpdateGroupRequest) *UpdateGroupInvoker

UpdateGroupInvoker 更新存储组

func (*IoTAnalyticsClient) UpdatePipelineJob 

func (c *IoTAnalyticsClient) UpdatePipelineJob(request *model.UpdatePipelineJobRequest) (*model.UpdatePipelineJobResponse, error)

UpdatePipelineJob 更新管道作业

更新管道作业时，需要在URL中指定是更新哪一个作业，将在body中附带完整的作业信息。（管道作业详细配置，每个作业可选择不同的算子进行组合，各算子的使用方法详见：数据管道算子配置指南。） check参数表示是否需要对作业配置进行检查，若为false，则不检查，将作业保存为草稿；若为true，则对作业配置进行检查。当检查不通过时，将作业状态修改为草稿；检查通过时，将作业状态修改为就绪，并返回成功。

Please refer to HUAWEI cloud API Explorer for details.

func (*IoTAnalyticsClient) UpdatePipelineJobInvoker added in v0.0.90 

func (c *IoTAnalyticsClient) UpdatePipelineJobInvoker(request *model.UpdatePipelineJobRequest) *UpdatePipelineJobInvoker

UpdatePipelineJobInvoker 更新管道作业

func (*IoTAnalyticsClient) UpdateStreamingJob 

func (c *IoTAnalyticsClient) UpdateStreamingJob(request *model.UpdateStreamingJobRequest) (*model.UpdateStreamingJobResponse, error)

UpdateStreamingJob 更新实时作业

更新作业时，需要在URL中指定是更新哪一个作业，将在body中附带完整的作业信息。 check参数表示是否需要对作业配置进行检查，若为false，则不检查，将作业保存为草稿；若为true，则对作业配置进行检查，无论检查是否通过，都将作业及配置信息保存为草稿，当检查不通过时，返回失败及错误信息，检查通过时，将作业状态修改为就绪，并返回成功。

Please refer to HUAWEI cloud API Explorer for details.

func (*IoTAnalyticsClient) UpdateStreamingJobInvoker added in v0.0.90 

func (c *IoTAnalyticsClient) UpdateStreamingJobInvoker(request *model.UpdateStreamingJobRequest) *UpdateStreamingJobInvoker

UpdateStreamingJobInvoker 更新实时作业

func (*IoTAnalyticsClient) ValidateSql 

func (c *IoTAnalyticsClient) ValidateSql(request *model.ValidateSqlRequest) (*model.ValidateSqlResponse, error)

ValidateSql 检查离线作业SQL语法

检查离线作业SQL语法。

Please refer to HUAWEI cloud API Explorer for details.

func (*IoTAnalyticsClient) ValidateSqlInvoker added in v0.0.90 

func (c *IoTAnalyticsClient) ValidateSqlInvoker(request *model.ValidateSqlRequest) *ValidateSqlInvoker

ValidateSqlInvoker 检查离线作业SQL语法

type ListAssetModelsInvoker added in v0.0.90 

type ListAssetModelsInvoker struct {
	*invoker.BaseInvoker
}

func (*ListAssetModelsInvoker) Invoke added in v0.0.90 

func (i *ListAssetModelsInvoker) Invoke() (*model.ListAssetModelsResponse, error)

type ListAssetsNewInvoker added in v0.0.90 

type ListAssetsNewInvoker struct {
	*invoker.BaseInvoker
}

func (*ListAssetsNewInvoker) Invoke added in v0.0.90 

func (i *ListAssetsNewInvoker) Invoke() (*model.ListAssetsNewResponse, error)

type ListBatchJobsInvoker added in v0.0.90 

type ListBatchJobsInvoker struct {
	*invoker.BaseInvoker
}

func (*ListBatchJobsInvoker) Invoke added in v0.0.90 

func (i *ListBatchJobsInvoker) Invoke() (*model.ListBatchJobsResponse, error)

type ListComputingResourcesInvoker added in v0.0.90 

type ListComputingResourcesInvoker struct {
	*invoker.BaseInvoker
}

func (*ListComputingResourcesInvoker) Invoke added in v0.0.90 

func (i *ListComputingResourcesInvoker) Invoke() (*model.ListComputingResourcesResponse, error)

type ListDataStoresInvoker added in v0.0.90 

type ListDataStoresInvoker struct {
	*invoker.BaseInvoker
}

func (*ListDataStoresInvoker) Invoke added in v0.0.90 

func (i *ListDataStoresInvoker) Invoke() (*model.ListDataStoresResponse, error)

type ListGroupsInvoker added in v0.0.90 

type ListGroupsInvoker struct {
	*invoker.BaseInvoker
}

func (*ListGroupsInvoker) Invoke added in v0.0.90 

func (i *ListGroupsInvoker) Invoke() (*model.ListGroupsResponse, error)

type ListHistoryInvoker added in v0.0.90 

type ListHistoryInvoker struct {
	*invoker.BaseInvoker
}

func (*ListHistoryInvoker) Invoke added in v0.0.90 

func (i *ListHistoryInvoker) Invoke() (*model.ListHistoryResponse, error)

type ListMetricsInvoker added in v0.0.90 

type ListMetricsInvoker struct {
	*invoker.BaseInvoker
}

func (*ListMetricsInvoker) Invoke added in v0.0.90 

func (i *ListMetricsInvoker) Invoke() (*model.ListMetricsResponse, error)

type ListPipelineJobsInvoker added in v0.0.90 

type ListPipelineJobsInvoker struct {
	*invoker.BaseInvoker
}

func (*ListPipelineJobsInvoker) Invoke added in v0.0.90 

func (i *ListPipelineJobsInvoker) Invoke() (*model.ListPipelineJobsResponse, error)

type ListRunsInvoker added in v0.0.90 

type ListRunsInvoker struct {
	*invoker.BaseInvoker
}

func (*ListRunsInvoker) Invoke added in v0.0.90 

func (i *ListRunsInvoker) Invoke() (*model.ListRunsResponse, error)

type ListTablesInvoker added in v0.0.90 

type ListTablesInvoker struct {
	*invoker.BaseInvoker
}

func (*ListTablesInvoker) Invoke added in v0.0.90 

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

type ListTagValuesInvoker added in v0.0.90 

type ListTagValuesInvoker struct {
	*invoker.BaseInvoker
}

func (*ListTagValuesInvoker) Invoke added in v0.0.90 

func (i *ListTagValuesInvoker) Invoke() (*model.ListTagValuesResponse, error)

type PublishRootAssetInvoker added in v0.0.90 

type PublishRootAssetInvoker struct {
	*invoker.BaseInvoker
}

func (*PublishRootAssetInvoker) Invoke added in v0.0.90 

func (i *PublishRootAssetInvoker) Invoke() (*model.PublishRootAssetResponse, error)

type ShowAllDataSourceInvoker added in v0.0.90 

type ShowAllDataSourceInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowAllDataSourceInvoker) Invoke added in v0.0.90 

func (i *ShowAllDataSourceInvoker) Invoke() (*model.ShowAllDataSourceResponse, error)

type ShowAssetModelInvoker added in v0.0.90 

type ShowAssetModelInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowAssetModelInvoker) Invoke added in v0.0.90 

func (i *ShowAssetModelInvoker) Invoke() (*model.ShowAssetModelResponse, error)

type ShowAssetNewInvoker added in v0.0.90 

type ShowAssetNewInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowAssetNewInvoker) Invoke added in v0.0.90 

func (i *ShowAssetNewInvoker) Invoke() (*model.ShowAssetNewResponse, error)

type ShowBatchJobInvoker added in v0.0.90 

type ShowBatchJobInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowBatchJobInvoker) Invoke added in v0.0.90 

func (i *ShowBatchJobInvoker) Invoke() (*model.ShowBatchJobResponse, error)

type ShowDataSourceInvoker added in v0.0.90 

type ShowDataSourceInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowDataSourceInvoker) Invoke added in v0.0.90 

func (i *ShowDataSourceInvoker) Invoke() (*model.ShowDataSourceResponse, error)

type ShowDatasetInvoker added in v0.0.90 

type ShowDatasetInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowDatasetInvoker) Invoke added in v0.0.90 

func (i *ShowDatasetInvoker) Invoke() (*model.ShowDatasetResponse, error)

type ShowJobByIdInvoker added in v0.0.90 

type ShowJobByIdInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowJobByIdInvoker) Invoke added in v0.0.90 

func (i *ShowJobByIdInvoker) Invoke() (*model.ShowJobByIdResponse, error)

type ShowJobsInvoker added in v0.0.90 

type ShowJobsInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowJobsInvoker) Invoke added in v0.0.90 

func (i *ShowJobsInvoker) Invoke() (*model.ShowJobsResponse, error)

type ShowLastPropertyValueInvoker added in v0.0.90 

type ShowLastPropertyValueInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowLastPropertyValueInvoker) Invoke added in v0.0.90 

func (i *ShowLastPropertyValueInvoker) Invoke() (*model.ShowLastPropertyValueResponse, error)

type ShowMetricValueInvoker added in v0.0.90 

type ShowMetricValueInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowMetricValueInvoker) Invoke added in v0.0.90 

func (i *ShowMetricValueInvoker) Invoke() (*model.ShowMetricValueResponse, error)

type ShowPipelineJobInvoker added in v0.0.90 

type ShowPipelineJobInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowPipelineJobInvoker) Invoke added in v0.0.90 

func (i *ShowPipelineJobInvoker) Invoke() (*model.ShowPipelineJobResponse, error)

type ShowPropertyRawValueInvoker added in v0.0.90 

type ShowPropertyRawValueInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowPropertyRawValueInvoker) Invoke added in v0.0.90 

func (i *ShowPropertyRawValueInvoker) Invoke() (*model.ShowPropertyRawValueResponse, error)

type ShowPropertyValuesInvoker added in v0.0.90 

type ShowPropertyValuesInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowPropertyValuesInvoker) Invoke added in v0.0.90 

func (i *ShowPropertyValuesInvoker) Invoke() (*model.ShowPropertyValuesResponse, error)

type ShowRunInvoker added in v0.0.90 

type ShowRunInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowRunInvoker) Invoke added in v0.0.90 

func (i *ShowRunInvoker) Invoke() (*model.ShowRunResponse, error)

type ShowTablePreviewInvoker added in v0.0.90 

type ShowTablePreviewInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowTablePreviewInvoker) Invoke added in v0.0.90 

func (i *ShowTablePreviewInvoker) Invoke() (*model.ShowTablePreviewResponse, error)

type ShowTableSchemaInvoker added in v0.0.90 

type ShowTableSchemaInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowTableSchemaInvoker) Invoke added in v0.0.90 

func (i *ShowTableSchemaInvoker) Invoke() (*model.ShowTableSchemaResponse, error)

type StartJobInvoker added in v0.0.90 

type StartJobInvoker struct {
	*invoker.BaseInvoker
}

func (*StartJobInvoker) Invoke added in v0.0.90 

func (i *StartJobInvoker) Invoke() (*model.StartJobResponse, error)

type StartPipelineJobInvoker added in v0.0.90 

type StartPipelineJobInvoker struct {
	*invoker.BaseInvoker
}

func (*StartPipelineJobInvoker) Invoke added in v0.0.90 

func (i *StartPipelineJobInvoker) Invoke() (*model.StartPipelineJobResponse, error)

type StopJobInvoker added in v0.0.90 

type StopJobInvoker struct {
	*invoker.BaseInvoker
}

func (*StopJobInvoker) Invoke added in v0.0.90 

func (i *StopJobInvoker) Invoke() (*model.StopJobResponse, error)

type StopPipelineJobInvoker added in v0.0.90 

type StopPipelineJobInvoker struct {
	*invoker.BaseInvoker
}

func (*StopPipelineJobInvoker) Invoke added in v0.0.90 

func (i *StopPipelineJobInvoker) Invoke() (*model.StopPipelineJobResponse, error)

type UpdateAssetModelInvoker added in v0.0.90 

type UpdateAssetModelInvoker struct {
	*invoker.BaseInvoker
}

func (*UpdateAssetModelInvoker) Invoke added in v0.0.90 

func (i *UpdateAssetModelInvoker) Invoke() (*model.UpdateAssetModelResponse, error)

type UpdateAssetNewInvoker added in v0.0.90 

type UpdateAssetNewInvoker struct {
	*invoker.BaseInvoker
}

func (*UpdateAssetNewInvoker) Invoke added in v0.0.90 

func (i *UpdateAssetNewInvoker) Invoke() (*model.UpdateAssetNewResponse, error)

type UpdateBatchJobInvoker added in v0.0.90 

type UpdateBatchJobInvoker struct {
	*invoker.BaseInvoker
}

func (*UpdateBatchJobInvoker) Invoke added in v0.0.90 

func (i *UpdateBatchJobInvoker) Invoke() (*model.UpdateBatchJobResponse, error)

type UpdateDataSourceInvoker added in v0.0.90 

type UpdateDataSourceInvoker struct {
	*invoker.BaseInvoker
}

func (*UpdateDataSourceInvoker) Invoke added in v0.0.90 

func (i *UpdateDataSourceInvoker) Invoke() (*model.UpdateDataSourceResponse, error)

type UpdateDataStoreInvoker added in v0.0.90 

type UpdateDataStoreInvoker struct {
	*invoker.BaseInvoker
}

func (*UpdateDataStoreInvoker) Invoke added in v0.0.90 

func (i *UpdateDataStoreInvoker) Invoke() (*model.UpdateDataStoreResponse, error)

type UpdateGroupInvoker added in v0.0.90 

type UpdateGroupInvoker struct {
	*invoker.BaseInvoker
}

func (*UpdateGroupInvoker) Invoke added in v0.0.90 

func (i *UpdateGroupInvoker) Invoke() (*model.UpdateGroupResponse, error)

type UpdatePipelineJobInvoker added in v0.0.90 

type UpdatePipelineJobInvoker struct {
	*invoker.BaseInvoker
}

func (*UpdatePipelineJobInvoker) Invoke added in v0.0.90 

func (i *UpdatePipelineJobInvoker) Invoke() (*model.UpdatePipelineJobResponse, error)

type UpdateStreamingJobInvoker added in v0.0.90 

type UpdateStreamingJobInvoker struct {
	*invoker.BaseInvoker
}

func (*UpdateStreamingJobInvoker) Invoke added in v0.0.90 

func (i *UpdateStreamingJobInvoker) Invoke() (*model.UpdateStreamingJobResponse, error)

type ValidateSqlInvoker added in v0.0.90 

type ValidateSqlInvoker struct {
	*invoker.BaseInvoker
}

func (*ValidateSqlInvoker) Invoke added in v0.0.90 

func (i *ValidateSqlInvoker) Invoke() (*model.ValidateSqlResponse, error)

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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