v1

package
v0.0.4 Latest Latest
Warning

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

 Go to latest Published: Aug 15, 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 

type AddDevDataInvoker struct {
	*invoker.BaseInvoker
}

func (*AddDevDataInvoker) Invoke 

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

type AddPipelineJobInvoker 

type AddPipelineJobInvoker struct {
	*invoker.BaseInvoker
}

func (*AddPipelineJobInvoker) Invoke 

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

type CreateAssetModelInvoker 

type CreateAssetModelInvoker struct {
	*invoker.BaseInvoker
}

func (*CreateAssetModelInvoker) Invoke 

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

type CreateAssetNewInvoker 

type CreateAssetNewInvoker struct {
	*invoker.BaseInvoker
}

func (*CreateAssetNewInvoker) Invoke 

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

type CreateBatchJobInvoker 

type CreateBatchJobInvoker struct {
	*invoker.BaseInvoker
}

func (*CreateBatchJobInvoker) Invoke 

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

type CreateComputingResourceInvoker 

type CreateComputingResourceInvoker struct {
	*invoker.BaseInvoker
}

func (*CreateComputingResourceInvoker) Invoke 

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

type CreateDatasourceInvoker 

type CreateDatasourceInvoker struct {
	*invoker.BaseInvoker
}

func (*CreateDatasourceInvoker) Invoke 

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

type CreateGroupInvoker 

type CreateGroupInvoker struct {
	*invoker.BaseInvoker
}

func (*CreateGroupInvoker) Invoke 

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

type CreateRunInvoker 

type CreateRunInvoker struct {
	*invoker.BaseInvoker
}

func (*CreateRunInvoker) Invoke 

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

type CreateStreamingJobInvoker 

type CreateStreamingJobInvoker struct {
	*invoker.BaseInvoker
}

func (*CreateStreamingJobInvoker) Invoke 

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

type CreateTableInvoker 

type CreateTableInvoker struct {
	*invoker.BaseInvoker
}

func (*CreateTableInvoker) Invoke 

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

type DeleteAssetModelInvoker 

type DeleteAssetModelInvoker struct {
	*invoker.BaseInvoker
}

func (*DeleteAssetModelInvoker) Invoke 

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

type DeleteAssetNewInvoker 

type DeleteAssetNewInvoker struct {
	*invoker.BaseInvoker
}

func (*DeleteAssetNewInvoker) Invoke 

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

type DeleteBatchJobInvoker 

type DeleteBatchJobInvoker struct {
	*invoker.BaseInvoker
}

func (*DeleteBatchJobInvoker) Invoke 

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

type DeleteComputingResourceInvoker 

type DeleteComputingResourceInvoker struct {
	*invoker.BaseInvoker
}

func (*DeleteComputingResourceInvoker) Invoke 

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

type DeleteDataStoreInvoker 

type DeleteDataStoreInvoker struct {
	*invoker.BaseInvoker
}

func (*DeleteDataStoreInvoker) Invoke 

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

type DeleteDatasourceInvoker 

type DeleteDatasourceInvoker struct {
	*invoker.BaseInvoker
}

func (*DeleteDatasourceInvoker) Invoke 

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

type DeleteGroupInvoker 

type DeleteGroupInvoker struct {
	*invoker.BaseInvoker
}

func (*DeleteGroupInvoker) Invoke 

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

type DeletePipelineJobInvoker 

type DeletePipelineJobInvoker struct {
	*invoker.BaseInvoker
}

func (*DeletePipelineJobInvoker) Invoke 

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

type DeleteRunInvoker 

type DeleteRunInvoker struct {
	*invoker.BaseInvoker
}

func (*DeleteRunInvoker) Invoke 

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

type DeleteStreamingJobByIdInvoker 

type DeleteStreamingJobByIdInvoker struct {
	*invoker.BaseInvoker
}

func (*DeleteStreamingJobByIdInvoker) Invoke 

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

type DeleteTableInvoker 

type DeleteTableInvoker struct {
	*invoker.BaseInvoker
}

func (*DeleteTableInvoker) Invoke 

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

type ExportDatasetInvoker 

type ExportDatasetInvoker struct {
	*invoker.BaseInvoker
}

func (*ExportDatasetInvoker) Invoke 

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

type ImportDataInvoker 

type ImportDataInvoker struct {
	*invoker.BaseInvoker
}

func (*ImportDataInvoker) Invoke 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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

ValidateSqlInvoker 检查离线作业SQL语法

type ListAssetModelsInvoker 

type ListAssetModelsInvoker struct {
	*invoker.BaseInvoker
}

func (*ListAssetModelsInvoker) Invoke 

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

type ListAssetsNewInvoker 

type ListAssetsNewInvoker struct {
	*invoker.BaseInvoker
}

func (*ListAssetsNewInvoker) Invoke 

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

type ListBatchJobsInvoker 

type ListBatchJobsInvoker struct {
	*invoker.BaseInvoker
}

func (*ListBatchJobsInvoker) Invoke 

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

type ListComputingResourcesInvoker 

type ListComputingResourcesInvoker struct {
	*invoker.BaseInvoker
}

func (*ListComputingResourcesInvoker) Invoke 

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

type ListDataStoresInvoker 

type ListDataStoresInvoker struct {
	*invoker.BaseInvoker
}

func (*ListDataStoresInvoker) Invoke 

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

type ListGroupsInvoker 

type ListGroupsInvoker struct {
	*invoker.BaseInvoker
}

func (*ListGroupsInvoker) Invoke 

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

type ListHistoryInvoker 

type ListHistoryInvoker struct {
	*invoker.BaseInvoker
}

func (*ListHistoryInvoker) Invoke 

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

type ListMetricsInvoker 

type ListMetricsInvoker struct {
	*invoker.BaseInvoker
}

func (*ListMetricsInvoker) Invoke 

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

type ListPipelineJobsInvoker 

type ListPipelineJobsInvoker struct {
	*invoker.BaseInvoker
}

func (*ListPipelineJobsInvoker) Invoke 

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

type ListRunsInvoker 

type ListRunsInvoker struct {
	*invoker.BaseInvoker
}

func (*ListRunsInvoker) Invoke 

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

type ListTablesInvoker 

type ListTablesInvoker struct {
	*invoker.BaseInvoker
}

func (*ListTablesInvoker) Invoke 

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

type ListTagValuesInvoker 

type ListTagValuesInvoker struct {
	*invoker.BaseInvoker
}

func (*ListTagValuesInvoker) Invoke 

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

type PublishRootAssetInvoker 

type PublishRootAssetInvoker struct {
	*invoker.BaseInvoker
}

func (*PublishRootAssetInvoker) Invoke 

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

type ShowAllDataSourceInvoker 

type ShowAllDataSourceInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowAllDataSourceInvoker) Invoke 

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

type ShowAssetModelInvoker 

type ShowAssetModelInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowAssetModelInvoker) Invoke 

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

type ShowAssetNewInvoker 

type ShowAssetNewInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowAssetNewInvoker) Invoke 

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

type ShowBatchJobInvoker 

type ShowBatchJobInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowBatchJobInvoker) Invoke 

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

type ShowDataSourceInvoker 

type ShowDataSourceInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowDataSourceInvoker) Invoke 

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

type ShowDatasetInvoker 

type ShowDatasetInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowDatasetInvoker) Invoke 

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

type ShowJobByIdInvoker 

type ShowJobByIdInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowJobByIdInvoker) Invoke 

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

type ShowJobsInvoker 

type ShowJobsInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowJobsInvoker) Invoke 

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

type ShowLastPropertyValueInvoker 

type ShowLastPropertyValueInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowLastPropertyValueInvoker) Invoke 

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

type ShowMetricValueInvoker 

type ShowMetricValueInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowMetricValueInvoker) Invoke 

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

type ShowPipelineJobInvoker 

type ShowPipelineJobInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowPipelineJobInvoker) Invoke 

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

type ShowPropertyRawValueInvoker 

type ShowPropertyRawValueInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowPropertyRawValueInvoker) Invoke 

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

type ShowPropertyValuesInvoker 

type ShowPropertyValuesInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowPropertyValuesInvoker) Invoke 

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

type ShowRunInvoker 

type ShowRunInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowRunInvoker) Invoke 

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

type ShowTablePreviewInvoker 

type ShowTablePreviewInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowTablePreviewInvoker) Invoke 

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

type ShowTableSchemaInvoker 

type ShowTableSchemaInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowTableSchemaInvoker) Invoke 

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

type StartJobInvoker 

type StartJobInvoker struct {
	*invoker.BaseInvoker
}

func (*StartJobInvoker) Invoke 

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

type StartPipelineJobInvoker 

type StartPipelineJobInvoker struct {
	*invoker.BaseInvoker
}

func (*StartPipelineJobInvoker) Invoke 

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

type StopJobInvoker 

type StopJobInvoker struct {
	*invoker.BaseInvoker
}

func (*StopJobInvoker) Invoke 

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

type StopPipelineJobInvoker 

type StopPipelineJobInvoker struct {
	*invoker.BaseInvoker
}

func (*StopPipelineJobInvoker) Invoke 

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

type UpdateAssetModelInvoker 

type UpdateAssetModelInvoker struct {
	*invoker.BaseInvoker
}

func (*UpdateAssetModelInvoker) Invoke 

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

type UpdateAssetNewInvoker 

type UpdateAssetNewInvoker struct {
	*invoker.BaseInvoker
}

func (*UpdateAssetNewInvoker) Invoke 

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

type UpdateBatchJobInvoker 

type UpdateBatchJobInvoker struct {
	*invoker.BaseInvoker
}

func (*UpdateBatchJobInvoker) Invoke 

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

type UpdateDataSourceInvoker 

type UpdateDataSourceInvoker struct {
	*invoker.BaseInvoker
}

func (*UpdateDataSourceInvoker) Invoke 

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

type UpdateDataStoreInvoker 

type UpdateDataStoreInvoker struct {
	*invoker.BaseInvoker
}

func (*UpdateDataStoreInvoker) Invoke 

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

type UpdateGroupInvoker 

type UpdateGroupInvoker struct {
	*invoker.BaseInvoker
}

func (*UpdateGroupInvoker) Invoke 

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

type UpdatePipelineJobInvoker 

type UpdatePipelineJobInvoker struct {
	*invoker.BaseInvoker
}

func (*UpdatePipelineJobInvoker) Invoke 

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

type UpdateStreamingJobInvoker 

type UpdateStreamingJobInvoker struct {
	*invoker.BaseInvoker
}

func (*UpdateStreamingJobInvoker) Invoke 

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

type ValidateSqlInvoker 

type ValidateSqlInvoker struct {
	*invoker.BaseInvoker
}

func (*ValidateSqlInvoker) Invoke 

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.