model

package
v0.0.83 Latest Latest
Warning

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

 Go to latest Published: Apr 7, 2022 License: Apache-2.0, BSD-2-Clause, BSD-3-Clause Imports: 5 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AddDevDataRequest 

type AddDevDataRequest struct {
	DatasourceId string `json:"datasource_id"`

	Body *interface{} `json:"body,omitempty"`
}

Request Object

func (AddDevDataRequest) String 

func (o AddDevDataRequest) String() string

type AddDevDataResponse 

type AddDevDataResponse struct {
	Body           *string `json:"body,omitempty"`
	HttpStatusCode int     `json:"-"`
}

Response Object

func (AddDevDataResponse) String 

func (o AddDevDataResponse) String() string

type AddPipelineJobRequest 

type AddPipelineJobRequest struct {
	Check *bool `json:"check,omitempty"`

	Body map[string]interface{} `json:"body,omitempty"`
}

Request Object

func (AddPipelineJobRequest) String 

func (o AddPipelineJobRequest) String() string

type AddPipelineJobResponse 

type AddPipelineJobResponse struct {
	PipelineId *string `json:"pipeline_id,omitempty"`

	CheckInfo      map[string]interface{} `json:"check_info,omitempty"`
	HttpStatusCode int                    `json:"-"`
}

Response Object

func (AddPipelineJobResponse) String 

func (o AddPipelineJobResponse) String() string

type AggregateMetric 

type AggregateMetric struct {
	Inputs []InputParam `json:"inputs"`

	MetricName string `json:"metric_name"`

	Expression string `json:"expression"`
}

查询指标

func (AggregateMetric) String 

func (o AggregateMetric) String() string

type AggregateMetrics 

type AggregateMetrics struct {
	TimeSpan *TimeSpan `json:"time_span"`

	Interval *string `json:"interval,omitempty"`

	Offset *string `json:"offset,omitempty"`

	Tags map[string]string `json:"tags"`

	Metrics []AggregateMetric `json:"metrics"`

	Limit *int32 `json:"limit,omitempty"`
}

聚合计算定义

func (AggregateMetrics) String 

func (o AggregateMetrics) String() string

type AggregateMetricsRequest 

type AggregateMetricsRequest struct {
	TimeSpan *TimeSpanDt `json:"time_span,omitempty"`

	Interval string `json:"interval"`

	Offset *string `json:"offset,omitempty"`

	Tags map[string]interface{} `json:"tags,omitempty"`

	PropertyFilter *[]PropertyFilter `json:"property_filter,omitempty"`

	Metrics []DtAggregateMetrics `json:"metrics"`

	Limit *int32 `json:"limit,omitempty"`
}

查询经过聚合计算的序列值定义

func (AggregateMetricsRequest) String 

func (o AggregateMetricsRequest) String() string

type AggregateModel 

type AggregateModel struct {
	Inputs []InputModel `json:"inputs"`

	Expression *Expression `json:"expression"`

	Schedule *DtSchedule `json:"schedule"`

	OutputProperty *string `json:"output_property,omitempty"`

	Outputs *[]OutputWithModel `json:"outputs,omitempty"`
}

聚合计算

func (AggregateModel) String 

func (o AggregateModel) String() string

type AggregateResponse 

type AggregateResponse struct {
	Inputs *[]InputResponse `json:"inputs,omitempty"`

	Expression *Expression `json:"expression,omitempty"`

	OutputProperty *string `json:"output_property,omitempty"`

	Outputs *[]OutputResponse `json:"outputs,omitempty"`

	Schedule *DtSchedule `json:"schedule,omitempty"`
}

聚合计算

func (AggregateResponse) String 

func (o AggregateResponse) String() string

type AnalysisModelRequest 

type AnalysisModelRequest struct {
	Name string `json:"name"`

	DisplayName *string `json:"display_name,omitempty"`

	Type string `json:"type"`

	Transform *TransformModel `json:"transform,omitempty"`

	Aggregate *AggregateModel `json:"aggregate,omitempty"`

	Stream *StreamModel `json:"stream,omitempty"`
}

分析任务

func (AnalysisModelRequest) String 

func (o AnalysisModelRequest) String() string

type AnalysisModelResponse 

type AnalysisModelResponse struct {
	Name string `json:"name"`

	DisplayName *string `json:"display_name,omitempty"`

	Type string `json:"type"`

	Transform *TransformModel `json:"transform,omitempty"`

	Aggregate *AggregateModel `json:"aggregate,omitempty"`

	Stream *StreamModel `json:"stream,omitempty"`

	AnalysisId *string `json:"analysis_id,omitempty"`
}

func (AnalysisModelResponse) String 

func (o AnalysisModelResponse) String() string

type AnalysisRequest 

type AnalysisRequest struct {
	Name string `json:"name"`

	Transform *DtTransformRequest `json:"transform,omitempty"`

	Aggregate *DtAggregateRequest `json:"aggregate,omitempty"`

	Stream *DtStreamRequest `json:"stream,omitempty"`
}

分析任务

func (AnalysisRequest) String 

func (o AnalysisRequest) String() string

type AnalysisResponse 

type AnalysisResponse struct {
	AnalysisId *string `json:"analysis_id,omitempty"`

	Name *string `json:"name,omitempty"`

	DisplayName *string `json:"display_name,omitempty"`

	Type *string `json:"type,omitempty"`

	Transform *TransformResponse `json:"transform,omitempty"`

	Aggregate *AggregateResponse `json:"aggregate,omitempty"`

	Stream *StreamResponse `json:"stream,omitempty"`
}

func (AnalysisResponse) String 

func (o AnalysisResponse) String() string

type ApiContentReq 

type ApiContentReq struct {
	Name string `json:"name"`
}

Api数据源请求内容

func (ApiContentReq) String 

func (o ApiContentReq) String() string

type ApiContentRsp 

type ApiContentRsp struct {
	Name *string `json:"name,omitempty"`

	Url *string `json:"url,omitempty"`
}

API数据源配置内容

func (ApiContentRsp) String 

func (o ApiContentRsp) String() string

type AssetAddRequest 

type AssetAddRequest struct {
	AssetModelId string `json:"asset_model_id"`

	Name string `json:"name"`

	DisplayName *string `json:"display_name,omitempty"`

	Parent *string `json:"parent,omitempty"`

	Properties *[]PropertyRequest `json:"properties,omitempty"`

	Analyses *[]AnalysisRequest `json:"analyses,omitempty"`
}

func (AssetAddRequest) String 

func (o AssetAddRequest) String() string

type AssetModRequest 

type AssetModRequest struct {
	Name *string `json:"name,omitempty"`

	DisplayName *string `json:"display_name,omitempty"`

	Parent *string `json:"parent,omitempty"`

	Properties *[]PropertyRequest `json:"properties,omitempty"`

	Analyses *[]AnalysisRequest `json:"analyses,omitempty"`
}

func (AssetModRequest) String 

func (o AssetModRequest) String() string

type AssetModelAddRequest 

type AssetModelAddRequest struct {
	Name string `json:"name"`

	DisplayName *string `json:"display_name,omitempty"`

	Properties *[]PropertyModelRequest `json:"properties,omitempty"`

	Analyses *[]AnalysisModelRequest `json:"analyses,omitempty"`
}

func (AssetModelAddRequest) String 

func (o AssetModelAddRequest) String() string

type AssetModelModRequest 

type AssetModelModRequest struct {
	DisplayName *string `json:"display_name,omitempty"`

	Properties *[]PropertyModelRequest `json:"properties,omitempty"`

	Analyses *[]AnalysisModelRequest `json:"analyses,omitempty"`
}

func (AssetModelModRequest) String 

func (o AssetModelModRequest) String() string

type AssetModelResponse 

type AssetModelResponse struct {
	AssetModelId *string `json:"asset_model_id,omitempty"`

	Name *string `json:"name,omitempty"`

	DisplayName *string `json:"display_name,omitempty"`

	Properties *[]PropertyModelResponse `json:"properties,omitempty"`

	Analyses *[]AnalysisModelResponse `json:"analyses,omitempty"`

	CreatedTime *string `json:"created_time,omitempty"`

	ModifiedTime *string `json:"modified_time,omitempty"`
}

func (AssetModelResponse) String 

func (o AssetModelResponse) String() string

type AssetPropertyLastValue 

type AssetPropertyLastValue struct {
	PropertyName *string `json:"property_name,omitempty"`

	Value *interface{} `json:"value,omitempty"`

	Timestamp *string `json:"timestamp,omitempty"`
}

func (AssetPropertyLastValue) String 

func (o AssetPropertyLastValue) String() string

type AssetResponse 

type AssetResponse struct {
	AssetId *string `json:"asset_id,omitempty"`

	AssetModelId *string `json:"asset_model_id,omitempty"`

	AssetModelName *string `json:"asset_model_name,omitempty"`

	Name *string `json:"name,omitempty"`

	DisplayName *string `json:"display_name,omitempty"`

	Properties *[]PropertyResponse `json:"properties,omitempty"`

	Analyses *[]AnalysisResponse `json:"analyses,omitempty"`

	Root *string `json:"root,omitempty"`

	Parent *string `json:"parent,omitempty"`

	Children *[]string `json:"children,omitempty"`

	State *string `json:"state,omitempty"`

	PublishState *string `json:"publish_state,omitempty"`

	CreatedTime *string `json:"created_time,omitempty"`

	ModifiedTime *string `json:"modified_time,omitempty"`

	PublishedTime *string `json:"published_time,omitempty"`
}

func (AssetResponse) String 

func (o AssetResponse) String() string

type Column 

type Column struct {
	ColumnName string `json:"column_name"`

	Description *string `json:"description,omitempty"`

	Type string `json:"type"`

	IsPartitionColumn *bool `json:"is_partition_column,omitempty"`
}

func (Column) String 

func (o Column) String() string

type ComputingResource 

type ComputingResource struct {
	ComputingResourceId *string `json:"computing_resource_id,omitempty"`

	ComputingResourceName *string `json:"computing_resource_name,omitempty"`

	Description *string `json:"description,omitempty"`

	Owner *string `json:"owner,omitempty"`

	CreatedTime *string `json:"created_time,omitempty"`

	ComputingResourceType *string `json:"computing_resource_type,omitempty"`

	CuCount *int32 `json:"cu_count,omitempty"`

	ChargingMode *int32 `json:"charging_mode,omitempty"`

	ResourceMode *int32 `json:"resource_mode,omitempty"`
}

func (ComputingResource) String 

func (o ComputingResource) String() string

type ContentDetailReq 

type ContentDetailReq struct {
	IotdaContent *IotdaContentReq `json:"iotda_content,omitempty"`

	ObsContent *ObsContentReq `json:"obs_content,omitempty"`

	DisContent *DisContentReq `json:"dis_content,omitempty"`

	SmnContent *SmnContentReq `json:"smn_content,omitempty"`

	FunctionGraphContent *FunctionGraphContentReq `json:"function_graph_content,omitempty"`

	ModelArtsContent *ModelArtsContentReq `json:"model_arts_content,omitempty"`

	DcsContent *DcsContentReq `json:"dcs_content,omitempty"`

	KafkaContent *KafkaContentReq `json:"kafka_content,omitempty"`

	ApiContent *ApiContentReq `json:"api_content,omitempty"`

	NodeContent *NodeContentReq `json:"node_content,omitempty"`

	EdgeContent *EdgeContentReq `json:"edge_content,omitempty"`
}

IoTA服务各类数据源详细配置内容

func (ContentDetailReq) String 

func (o ContentDetailReq) String() string

type ContentDetailRsp 

type ContentDetailRsp struct {
	IotdaContent *IotdaContentRsp `json:"iotda_content,omitempty"`

	ObsContent *ObsContentRsp `json:"obs_content,omitempty"`

	DisContent *DisContentRsp `json:"dis_content,omitempty"`

	SmnContent *SmnContentRsp `json:"smn_content,omitempty"`

	FunctionGraphContent *FunctionGraphContentRsp `json:"function_graph_content,omitempty"`

	ModelArtsContent *ModelArtsContentRsp `json:"model_arts_content,omitempty"`

	DcsContent *DcsContentRsp `json:"dcs_content,omitempty"`

	KafkaContent *KafkaContentRsp `json:"kafka_content,omitempty"`

	ApiContent *ApiContentRsp `json:"api_content,omitempty"`

	NodeContent *NodeContentRsp `json:"node_content,omitempty"`

	EdgeContent *EdgeContentRsp `json:"edge_content,omitempty"`
}

IoTA服务各类数据源详细配置内容

func (ContentDetailRsp) String 

func (o ContentDetailRsp) String() string

type CreateAssetModelRequest 

type CreateAssetModelRequest struct {
	Body *AssetModelAddRequest `json:"body,omitempty"`
}

Request Object

func (CreateAssetModelRequest) String 

func (o CreateAssetModelRequest) String() string

type CreateAssetModelResponse 

type CreateAssetModelResponse struct {
	AssetModelId *string `json:"asset_model_id,omitempty"`

	Name *string `json:"name,omitempty"`

	DisplayName *string `json:"display_name,omitempty"`

	Properties *[]PropertyModelResponse `json:"properties,omitempty"`

	Analyses *[]AnalysisModelResponse `json:"analyses,omitempty"`

	CreatedTime *string `json:"created_time,omitempty"`

	ModifiedTime   *string `json:"modified_time,omitempty"`
	HttpStatusCode int     `json:"-"`
}

Response Object

func (CreateAssetModelResponse) String 

func (o CreateAssetModelResponse) String() string

type CreateAssetNewRequest 

type CreateAssetNewRequest struct {
	Body *AssetAddRequest `json:"body,omitempty"`
}

Request Object

func (CreateAssetNewRequest) String 

func (o CreateAssetNewRequest) String() string

type CreateAssetNewResponse 

type CreateAssetNewResponse struct {
	AssetId *string `json:"asset_id,omitempty"`

	AssetModelId *string `json:"asset_model_id,omitempty"`

	AssetModelName *string `json:"asset_model_name,omitempty"`

	Name *string `json:"name,omitempty"`

	DisplayName *string `json:"display_name,omitempty"`

	Properties *[]PropertyResponse `json:"properties,omitempty"`

	Analyses *[]AnalysisResponse `json:"analyses,omitempty"`

	Root *string `json:"root,omitempty"`

	Parent *string `json:"parent,omitempty"`

	Children *[]string `json:"children,omitempty"`

	State *string `json:"state,omitempty"`

	PublishState *string `json:"publish_state,omitempty"`

	CreatedTime *string `json:"created_time,omitempty"`

	ModifiedTime *string `json:"modified_time,omitempty"`

	PublishedTime  *string `json:"published_time,omitempty"`
	HttpStatusCode int     `json:"-"`
}

Response Object

func (CreateAssetNewResponse) String 

func (o CreateAssetNewResponse) String() string

type CreateBatchJobRequest 

type CreateBatchJobRequest struct {
	Body *Job `json:"body,omitempty"`
}

Request Object

func (CreateBatchJobRequest) String 

func (o CreateBatchJobRequest) String() string

type CreateBatchJobResponse 

type CreateBatchJobResponse struct {
	JobId *string `json:"job_id,omitempty"`

	JobName *string `json:"job_name,omitempty"`

	Tags *string `json:"tags,omitempty"`

	CreatedTime *string `json:"created_time,omitempty"`

	ModifiedTime *string `json:"modified_time,omitempty"`

	JobType *string `json:"job_type,omitempty"`

	ExportPath *string `json:"export_path,omitempty"`

	MergeResultFile *bool `json:"merge_result_file,omitempty"`

	SqlJob *SqlJob `json:"sql_job,omitempty"`

	Schedule       *Schedule `json:"schedule,omitempty"`
	HttpStatusCode int       `json:"-"`
}

Response Object

func (CreateBatchJobResponse) String 

func (o CreateBatchJobResponse) String() string

type CreateComputingResourceRequest 

type CreateComputingResourceRequest struct {
	Body *CreateComputingResourceRequestBody `json:"body,omitempty"`
}

Request Object

func (CreateComputingResourceRequest) String 

func (o CreateComputingResourceRequest) String() string

type CreateComputingResourceRequestBody 

type CreateComputingResourceRequestBody struct {
	ComputingResourceName string `json:"computing_resource_name"`

	ComputingResourceType *string `json:"computing_resource_type,omitempty"`

	Description *string `json:"description,omitempty"`

	CuCount int32 `json:"cu_count"`

	ChargingMode *int32 `json:"charging_mode,omitempty"`
}

func (CreateComputingResourceRequestBody) String 

func (o CreateComputingResourceRequestBody) String() string

type CreateComputingResourceResponse 

type CreateComputingResourceResponse struct {
	ComputingResourceId *string `json:"computing_resource_id,omitempty"`

	ComputingResourceName *string `json:"computing_resource_name,omitempty"`

	ComputingResourceType *string `json:"computing_resource_type,omitempty"`

	Description *string `json:"description,omitempty"`

	CuCount *int32 `json:"cu_count,omitempty"`

	ChargingMode *int32 `json:"charging_mode,omitempty"`

	CreatedTime    *string `json:"created_time,omitempty"`
	HttpStatusCode int     `json:"-"`
}

Response Object

func (CreateComputingResourceResponse) String 

func (o CreateComputingResourceResponse) String() string

type CreateDatasourceReqDto 

type CreateDatasourceReqDto struct {
	Name string `json:"name"`

	Type string `json:"type"`

	Content *ContentDetailReq `json:"content"`
}

func (CreateDatasourceReqDto) String 

func (o CreateDatasourceReqDto) String() string

type CreateDatasourceRequest 

type CreateDatasourceRequest struct {
	Body *CreateDatasourceReqDto `json:"body,omitempty"`
}

Request Object

func (CreateDatasourceRequest) String 

func (o CreateDatasourceRequest) String() string

type CreateDatasourceResponse 

type CreateDatasourceResponse struct {
	Id *string `json:"id,omitempty"`

	Name *string `json:"name,omitempty"`

	Type *string `json:"type,omitempty"`

	Content *ContentDetailRsp `json:"content,omitempty"`

	CreatedTime *string `json:"created_time,omitempty"`

	ModifiedTime   *string `json:"modified_time,omitempty"`
	HttpStatusCode int     `json:"-"`
}

Response Object

func (CreateDatasourceResponse) String 

func (o CreateDatasourceResponse) String() string

type CreateGroupRequest 

type CreateGroupRequest struct {
	Body *StorageGroup `json:"body,omitempty"`
}

Request Object

func (CreateGroupRequest) String 

func (o CreateGroupRequest) String() string

type CreateGroupResponse 

type CreateGroupResponse struct {
	GroupId *string `json:"group_id,omitempty"`

	Name *string `json:"name,omitempty"`

	Description *string `json:"description,omitempty"`

	WarmDataUsage *int64 `json:"warm_data_usage,omitempty"`

	DataStoreCount *int64 `json:"data_store_count,omitempty"`

	ColdDataUsage *int64 `json:"cold_data_usage,omitempty"`

	WarmDataRetentionPolicy *string `json:"warm_data_retention_policy,omitempty"`

	ColdDataRetentionPolicy *string `json:"cold_data_retention_policy,omitempty"`

	CreatedTime *string `json:"created_time,omitempty"`

	ModifiedTime *string `json:"modified_time,omitempty"`

	Type           *string `json:"type,omitempty"`
	HttpStatusCode int     `json:"-"`
}

Response Object

func (CreateGroupResponse) String 

func (o CreateGroupResponse) String() string

type CreateRunRequest 

type CreateRunRequest struct {
	JobId string `json:"job_id"`

	Body *CreateRunRequestBody `json:"body,omitempty"`
}

Request Object

func (CreateRunRequest) String 

func (o CreateRunRequest) String() string

type CreateRunRequestBody 

type CreateRunRequestBody struct {
	ComputingResourceId string `json:"computing_resource_id"`

	Conf *[]string `json:"conf,omitempty"`
}

func (CreateRunRequestBody) String 

func (o CreateRunRequestBody) String() string

type CreateRunResponse 

type CreateRunResponse struct {
	RunId *string `json:"run_id,omitempty"`

	JobId *string `json:"job_id,omitempty"`

	JobType *string `json:"job_type,omitempty"`

	CreatedTime *string `json:"created_time,omitempty"`

	SqlJob         *SqlJobRunResponseBody `json:"sql_job,omitempty"`
	HttpStatusCode int                    `json:"-"`
}

Response Object

func (CreateRunResponse) String 

func (o CreateRunResponse) String() string

type CreateStreamingJobRequest 

type CreateStreamingJobRequest struct {
	Check *bool `json:"check,omitempty"`

	Body map[string]interface{} `json:"body,omitempty"`
}

Request Object

func (CreateStreamingJobRequest) String 

func (o CreateStreamingJobRequest) String() string

type CreateStreamingJobResponse 

type CreateStreamingJobResponse struct {
	JobId *string `json:"job_id,omitempty"`

	CheckInfo      map[string]interface{} `json:"check_info,omitempty"`
	HttpStatusCode int                    `json:"-"`
}

Response Object

func (CreateStreamingJobResponse) String 

func (o CreateStreamingJobResponse) String() string

type CreateTableRequest 

type CreateTableRequest struct {
	Body *CreateTableRequestBody `json:"body,omitempty"`
}

Request Object

func (CreateTableRequest) String 

func (o CreateTableRequest) String() string

type CreateTableRequestBody 

type CreateTableRequestBody struct {
	Tags *string `json:"tags,omitempty"`

	TableName string `json:"table_name"`

	TableAlias *string `json:"table_alias,omitempty"`

	Description *string `json:"description,omitempty"`

	Columns []Column `json:"columns"`

	DataType string `json:"data_type"`

	DataSource *string `json:"data_source,omitempty"`

	DataStoreId *string `json:"data_store_id,omitempty"`

	WithColumnHeader *bool `json:"with_column_header,omitempty"`

	Delimiter *string `json:"delimiter,omitempty"`

	QuoteChar *string `json:"quote_char,omitempty"`

	EscapeChar *string `json:"escape_char,omitempty"`

	DateFormat *string `json:"date_format,omitempty"`

	TimestampFormat *string `json:"timestamp_format,omitempty"`
}

func (CreateTableRequestBody) String 

func (o CreateTableRequestBody) String() string

type CreateTableResponse 

type CreateTableResponse struct {
	TableId *string `json:"table_id,omitempty"`

	TableName *string `json:"table_name,omitempty"`

	TableAlias *string `json:"table_alias,omitempty"`

	CreatedTime *string `json:"created_time,omitempty"`

	ModifiedTime *string `json:"modified_time,omitempty"`

	DataLocation *string `json:"data_location,omitempty"`

	DataType *string `json:"data_type,omitempty"`

	DataSource *string `json:"data_source,omitempty"`

	TableType *string `json:"table_type,omitempty"`

	Description *string `json:"description,omitempty"`

	PartitionColumns *[]string `json:"partition_columns,omitempty"`

	DataStoreId *string `json:"data_store_id,omitempty"`

	Tags           *string `json:"tags,omitempty"`
	HttpStatusCode int     `json:"-"`
}

Response Object

func (CreateTableResponse) String 

func (o CreateTableResponse) String() string

type DataSchema 

type DataSchema struct {
	Min float32 `json:"min,omitempty"`

	Max float32 `json:"max,omitempty"`

	MinLength *int32 `json:"min_length,omitempty"`

	MaxLength *int32 `json:"max_length,omitempty"`

	DataType string `json:"data_type"`
}

数据格式

func (DataSchema) String 

func (o DataSchema) String() string

type DataStoreDto 

type DataStoreDto struct {
	DataStoreId *string `json:"data_store_id,omitempty"`

	DataStoreGroupId *string `json:"data_store_group_id,omitempty"`

	ProductId *string `json:"product_id,omitempty"`
}

存储信息

func (DataStoreDto) String 

func (o DataStoreDto) String() string

type DatasourceRestDto 

type DatasourceRestDto struct {
	Id *string `json:"id,omitempty"`

	Name *string `json:"name,omitempty"`

	Type *string `json:"type,omitempty"`

	Content *ContentDetailRsp `json:"content,omitempty"`

	CreatedTime *string `json:"created_time,omitempty"`

	ModifiedTime *string `json:"modified_time,omitempty"`
}

func (DatasourceRestDto) String 

func (o DatasourceRestDto) String() string

type DcsContentReq 

type DcsContentReq struct {
	EndpointServiceId string `json:"endpoint_service_id"`

	EndpointServiceName string `json:"endpoint_service_name"`

	Port int32 `json:"port"`

	DcsType string `json:"dcs_type"`

	Password string `json:"password"`
}

DCS数据源配置内容

func (DcsContentReq) String 

func (o DcsContentReq) String() string

type DcsContentRsp 

type DcsContentRsp struct {
	EndpointServiceId *string `json:"endpointServiceId,omitempty"`

	EndpointServiceName *string `json:"endpointServiceName,omitempty"`

	EndpointIp *string `json:"endpointIp,omitempty"`

	Port *int32 `json:"port,omitempty"`

	DcsType *string `json:"dcsType,omitempty"`

	Password *string `json:"password,omitempty"`
}

redis数据源配置内容

func (DcsContentRsp) String 

func (o DcsContentRsp) String() string

type DeleteAssetModelRequest 

type DeleteAssetModelRequest struct {
	ModelId string `json:"model_id"`
}

Request Object

func (DeleteAssetModelRequest) String 

func (o DeleteAssetModelRequest) String() string

type DeleteAssetModelResponse 

type DeleteAssetModelResponse struct {
	HttpStatusCode int `json:"-"`
}

Response Object

func (DeleteAssetModelResponse) String 

func (o DeleteAssetModelResponse) String() string

type DeleteAssetNewRequest 

type DeleteAssetNewRequest struct {
	AssetId string `json:"asset_id"`
}

Request Object

func (DeleteAssetNewRequest) String 

func (o DeleteAssetNewRequest) String() string

type DeleteAssetNewResponse 

type DeleteAssetNewResponse struct {
	HttpStatusCode int `json:"-"`
}

Response Object

func (DeleteAssetNewResponse) String 

func (o DeleteAssetNewResponse) String() string

type DeleteBatchJobRequest 

type DeleteBatchJobRequest struct {
	JobId string `json:"job_id"`
}

Request Object

func (DeleteBatchJobRequest) String 

func (o DeleteBatchJobRequest) String() string

type DeleteBatchJobResponse 

type DeleteBatchJobResponse struct {
	JobId          *string `json:"job_id,omitempty"`
	HttpStatusCode int     `json:"-"`
}

Response Object

func (DeleteBatchJobResponse) String 

func (o DeleteBatchJobResponse) String() string

type DeleteComputingResourceRequest 

type DeleteComputingResourceRequest struct {
	ComputingResourceId string `json:"computing_resource_id"`
}

Request Object

func (DeleteComputingResourceRequest) String 

func (o DeleteComputingResourceRequest) String() string

type DeleteComputingResourceResponse 

type DeleteComputingResourceResponse struct {
	ComputingResourceId *string `json:"computing_resource_id,omitempty"`
	HttpStatusCode      int     `json:"-"`
}

Response Object

func (DeleteComputingResourceResponse) String 

func (o DeleteComputingResourceResponse) String() string

type DeleteDataStoreRequest 

type DeleteDataStoreRequest struct {
	DataStoreId string `json:"data_store_id"`
}

Request Object

func (DeleteDataStoreRequest) String 

func (o DeleteDataStoreRequest) String() string

type DeleteDataStoreResponse 

type DeleteDataStoreResponse struct {
	HttpStatusCode int `json:"-"`
}

Response Object

func (DeleteDataStoreResponse) String 

func (o DeleteDataStoreResponse) String() string

type DeleteDatasourceRequest 

type DeleteDatasourceRequest struct {
	DatasourceId string `json:"datasource_id"`
}

Request Object

func (DeleteDatasourceRequest) String 

func (o DeleteDatasourceRequest) String() string

type DeleteDatasourceResponse 

type DeleteDatasourceResponse struct {
	Body           *string `json:"body,omitempty"`
	HttpStatusCode int     `json:"-"`
}

Response Object

func (DeleteDatasourceResponse) String 

func (o DeleteDatasourceResponse) String() string

type DeleteGroupRequest 

type DeleteGroupRequest struct {
	GroupId string `json:"group_id"`
}

Request Object

func (DeleteGroupRequest) String 

func (o DeleteGroupRequest) String() string

type DeleteGroupResponse 

type DeleteGroupResponse struct {
	HttpStatusCode int `json:"-"`
}

Response Object

func (DeleteGroupResponse) String 

func (o DeleteGroupResponse) String() string

type DeletePipelineJobRequest 

type DeletePipelineJobRequest struct {
	PipelineId string `json:"pipeline_id"`
}

Request Object

func (DeletePipelineJobRequest) String 

func (o DeletePipelineJobRequest) String() string

type DeletePipelineJobResponse 

type DeletePipelineJobResponse struct {
	Body           *string `json:"body,omitempty"`
	HttpStatusCode int     `json:"-"`
}

Response Object

func (DeletePipelineJobResponse) String 

func (o DeletePipelineJobResponse) String() string

type DeleteRunRequest 

type DeleteRunRequest struct {
	JobId string `json:"job_id"`

	RunId string `json:"run_id"`
}

Request Object

func (DeleteRunRequest) String 

func (o DeleteRunRequest) String() string

type DeleteRunResponse 

type DeleteRunResponse struct {
	RunId          *string `json:"run_id,omitempty"`
	HttpStatusCode int     `json:"-"`
}

Response Object

func (DeleteRunResponse) String 

func (o DeleteRunResponse) String() string

type DeleteStreamingJobByIdRequest 

type DeleteStreamingJobByIdRequest struct {
	JobId string `json:"job_id"`
}

Request Object

func (DeleteStreamingJobByIdRequest) String 

func (o DeleteStreamingJobByIdRequest) String() string

type DeleteStreamingJobByIdResponse 

type DeleteStreamingJobByIdResponse struct {
	Body           *string `json:"body,omitempty"`
	HttpStatusCode int     `json:"-"`
}

Response Object

func (DeleteStreamingJobByIdResponse) String 

func (o DeleteStreamingJobByIdResponse) String() string

type DeleteTableRequest 

type DeleteTableRequest struct {
	TableId string `json:"table_id"`
}

Request Object

func (DeleteTableRequest) String 

func (o DeleteTableRequest) String() string

type DeleteTableResponse 

type DeleteTableResponse struct {
	TableId *string `json:"table_id,omitempty"`

	TableName      *string `json:"table_name,omitempty"`
	HttpStatusCode int     `json:"-"`
}

Response Object

func (DeleteTableResponse) String 

func (o DeleteTableResponse) String() string

type DisContentReq 

type DisContentReq struct {
	ProjectId string `json:"project_id"`

	StreamName string `json:"stream_name"`

	Ak string `json:"ak"`

	Sk string `json:"sk"`
}

DIS数据源配置内容

func (DisContentReq) String 

func (o DisContentReq) String() string

type DisContentRsp 

type DisContentRsp struct {
	StreamName *string `json:"streamName,omitempty"`

	Ak *string `json:"ak,omitempty"`

	Sk *string `json:"sk,omitempty"`

	ProjectId *string `json:"projectId,omitempty"`
}

DIS数据源配置内容

func (DisContentRsp) String 

func (o DisContentRsp) String() string

type DtAggregateMetrics 

type DtAggregateMetrics struct {
	Inputs []MetricInput `json:"inputs"`

	Expression string `json:"expression"`

	MetricName string `json:"metric_name"`
}

聚合指标列表

func (DtAggregateMetrics) String 

func (o DtAggregateMetrics) String() string

type DtAggregateRequest 

type DtAggregateRequest struct {
	Inputs *[]InputRequest `json:"inputs,omitempty"`

	Outputs *[]OutputRequest `json:"outputs,omitempty"`
}

聚合计算

func (DtAggregateRequest) String 

func (o DtAggregateRequest) String() string

type DtSchedule 

type DtSchedule struct {
	Period string `json:"period"`
}

调度策略

func (DtSchedule) String 

func (o DtSchedule) String() string

type DtStreamRequest 

type DtStreamRequest struct {
	Inputs []InputRequest `json:"inputs"`
}

流计算

func (DtStreamRequest) String 

func (o DtStreamRequest) String() string

type DtTransformMetrics 

type DtTransformMetrics struct {
	Inputs []MetricInput `json:"inputs"`

	Expression string `json:"expression"`

	MetricName string `json:"metric_name"`
}

转换指标列表

func (DtTransformMetrics) String 

func (o DtTransformMetrics) String() string

type DtTransformRequest 

type DtTransformRequest struct {
	Inputs *[]InputRequest `json:"inputs,omitempty"`

	Outputs *[]OutputRequest `json:"outputs,omitempty"`
}

转换计算

func (DtTransformRequest) String 

func (o DtTransformRequest) String() string

type EdgeContentReq 

type EdgeContentReq struct {
	IotdaInstanceId *string `json:"iotda_instance_id,omitempty"`

	Rules []EdgeContentRuleReq `json:"rules"`
}

IoTDA数据源详细配置内容

func (EdgeContentReq) String 

func (o EdgeContentReq) String() string

type EdgeContentRsp 

type EdgeContentRsp struct {
	IotdaInstanceId string `json:"iotda_instance_id"`

	Rules []EdgeContentRuleRsp `json:"rules"`
}

IoTDA数据源详细配置内容

func (EdgeContentRsp) String 

func (o EdgeContentRsp) String() string

type EdgeContentRuleReq 

type EdgeContentRuleReq struct {
	AppId string `json:"app_id"`

	Products []string `json:"products"`
}

在Edge实例中要配置转发规则推送数据的资源空间和产品列表

func (EdgeContentRuleReq) String 

func (o EdgeContentRuleReq) String() string

type EdgeContentRuleRsp 

type EdgeContentRuleRsp struct {
	AppId string `json:"app_id"`

	Products []string `json:"products"`

	RuleActions []IotdaRuleAction `json:"rule_actions"`
}

在Edge实例中要配置转发规则推送数据的资源空间和产品列表

func (EdgeContentRuleRsp) String 

func (o EdgeContentRuleRsp) String() string

type ExportDatasetRequest 

type ExportDatasetRequest struct {
	JobId string `json:"job_id"`

	RunId string `json:"run_id"`
}

Request Object

func (ExportDatasetRequest) String 

func (o ExportDatasetRequest) String() string

type ExportDatasetResponse 

type ExportDatasetResponse struct {
	HttpStatusCode int           `json:"-"`
	Body           io.ReadCloser `json:"-" type:"stream"`
}

Response Object

func (ExportDatasetResponse) Consume 

func (o ExportDatasetResponse) Consume(writer io.Writer) (int64, error)

func (ExportDatasetResponse) String 

func (o ExportDatasetResponse) String() string

type Expression 

type Expression struct {
	Formula *string `json:"formula,omitempty"`

	Formulas *[]NamedFormula `json:"formulas,omitempty"`

	TimeRange string `json:"time_range"`
}

表达式

func (Expression) String 

func (o Expression) String() string

type Formula 

type Formula struct {
	Formula *string `json:"formula,omitempty"`

	Formulas *[]NamedFormula `json:"formulas,omitempty"`
}

表达式

func (Formula) String 

func (o Formula) String() string

type FunctionGraphContentReq 

type FunctionGraphContentReq struct {
	FunctionName string `json:"function_name"`

	OrigUrl string `json:"orig_url"`

	FinalUrl string `json:"final_url"`

	VerifyBody string `json:"verify_body"`

	Ak string `json:"ak"`

	Sk string `json:"sk"`

	ProjectId string `json:"project_id"`
}

FunctionGraph数据源配置内容

func (FunctionGraphContentReq) String 

func (o FunctionGraphContentReq) String() string

type FunctionGraphContentRsp 

type FunctionGraphContentRsp struct {
	FunctionName *string `json:"functionName,omitempty"`

	OrigUrl *string `json:"origUrl,omitempty"`

	FinalUrl *string `json:"finalUrl,omitempty"`

	VerifyBody *string `json:"verifyBody,omitempty"`

	Ak *string `json:"ak,omitempty"`

	Sk *string `json:"sk,omitempty"`

	ProjectId *string `json:"projectId,omitempty"`
}

SMN数据源配置内容

func (FunctionGraphContentRsp) String 

func (o FunctionGraphContentRsp) String() string

type GetDataStore 

type GetDataStore struct {
	DataStoreId *string `json:"data_store_id,omitempty"`

	Name *string `json:"name,omitempty"`

	GroupId *string `json:"group_id,omitempty"`

	Tags *[]Tag `json:"tags,omitempty"`

	Metrics *[]Metric `json:"metrics,omitempty"`

	Properties *[]Property `json:"properties,omitempty"`

	CreatedTime *string `json:"created_time,omitempty"`

	ModifiedTime *string `json:"modified_time,omitempty"`
}

func (GetDataStore) String 

func (o GetDataStore) String() string

type GetGroup 

type GetGroup struct {
	GroupId *string `json:"group_id,omitempty"`

	Name *string `json:"name,omitempty"`

	Description *string `json:"description,omitempty"`

	WarmDataUsage *int64 `json:"warm_data_usage,omitempty"`

	DataStoreCount *int64 `json:"data_store_count,omitempty"`

	ColdDataUsage *int64 `json:"cold_data_usage,omitempty"`

	WarmDataRetentionPolicy *string `json:"warm_data_retention_policy,omitempty"`

	ColdDataRetentionPolicy *string `json:"cold_data_retention_policy,omitempty"`

	CreatedTime *string `json:"created_time,omitempty"`

	ModifiedTime *string `json:"modified_time,omitempty"`

	Type *string `json:"type,omitempty"`
}

存储组信息

func (GetGroup) String 

func (o GetGroup) String() string

type GetHistoryRequest 

type GetHistoryRequest struct {
	TimeSpan *TimeSpan `json:"time_span"`

	Tags map[string]string `json:"tags"`

	PropertyNames []string `json:"property_names"`

	Limit *int32 `json:"limit,omitempty"`
}

查询历史值请求

func (GetHistoryRequest) String 

func (o GetHistoryRequest) String() string

type GetMetricsRequest 

type GetMetricsRequest struct {
	Type string `json:"type"`

	Transform *TransformMetrics `json:"transform,omitempty"`

	Aggregate *AggregateMetrics `json:"aggregate,omitempty"`
}

查询指标请求

func (GetMetricsRequest) String 

func (o GetMetricsRequest) String() string

type GetMetricsValue 

type GetMetricsValue struct {
	Type string `json:"type"`

	Transform *TransformMetricsRequest `json:"transform,omitempty"`

	Aggregate *AggregateMetricsRequest `json:"aggregate,omitempty"`
}

func (GetMetricsValue) String 

func (o GetMetricsValue) String() string

type GetPropertyRequest 

type GetPropertyRequest struct {
	Tags map[string]string `json:"tags"`

	PropertyNames *[]string `json:"property_names,omitempty"`
}

查询属性值请求

func (GetPropertyRequest) String 

func (o GetPropertyRequest) String() string

type HistoryValues 

type HistoryValues struct {
	PropertyName *string `json:"property_name,omitempty"`

	Values *[]interface{} `json:"values,omitempty"`
}

func (HistoryValues) String 

func (o HistoryValues) String() string

type ImportDataRequest 

type ImportDataRequest struct {
	Body *ImportDataRequestBody `json:"body,omitempty"`
}

Request Object

func (ImportDataRequest) String 

func (o ImportDataRequest) String() string

type ImportDataRequestBody 

type ImportDataRequestBody struct {
	DataPath string `json:"data_path"`

	DataType string `json:"data_type"`

	TableId string `json:"table_id"`

	WithColumnHeader *string `json:"with_column_header,omitempty"`

	Delimiter *string `json:"delimiter,omitempty"`

	QuoteChar *string `json:"quote_char,omitempty"`

	EscapeChar *string `json:"escape_char,omitempty"`

	DateFormat *string `json:"date_format,omitempty"`

	BadRecordsPath *string `json:"bad_records_path,omitempty"`

	TimestampFormat *string `json:"timestamp_format,omitempty"`

	ComputingResourceId string `json:"computing_resource_id"`
}

func (ImportDataRequestBody) String 

func (o ImportDataRequestBody) String() string

type ImportDataResponse 

type ImportDataResponse struct {
	TableId *string `json:"table_id,omitempty"`

	JobId *string `json:"job_id,omitempty"`

	RunId          *string `json:"run_id,omitempty"`
	HttpStatusCode int     `json:"-"`
}

Response Object

func (ImportDataResponse) String 

func (o ImportDataResponse) String() string

type InputModel 

type InputModel struct {
	Name string `json:"name"`

	PropertyReference *PropertyReferenceModel `json:"property_reference"`
}

func (InputModel) String 

func (o InputModel) String() string

type InputParam 

type InputParam struct {
	Name string `json:"name"`

	PropertyName string `json:"property_name"`
}

属性定义为输入参数

func (InputParam) String 

func (o InputParam) String() string

type InputRequest 

type InputRequest struct {
	Name string `json:"name"`

	PropertyReference *PropertyReferenceReq `json:"property_reference"`
}

func (InputRequest) String 

func (o InputRequest) String() string

type InputResponse 

type InputResponse struct {
	Name *string `json:"name,omitempty"`

	PropertyReference *PropertyReferenceResponse `json:"property_reference,omitempty"`
}

func (InputResponse) String 

func (o InputResponse) String() string

type IotdaContentReq 

type IotdaContentReq struct {
	IotdaInstanceId string `json:"iotda_instance_id"`

	Rules []IotdaContentRuleReq `json:"rules"`
}

IoTDA数据源详细配置内容

func (IotdaContentReq) String 

func (o IotdaContentReq) String() string

type IotdaContentRsp 

type IotdaContentRsp struct {
	IotdaInstanceId string `json:"iotda_instance_id"`

	Rules []IotdaContentRuleRsp `json:"rules"`
}

IoTDA数据源详细配置内容

func (IotdaContentRsp) String 

func (o IotdaContentRsp) String() string

type IotdaContentRuleReq 

type IotdaContentRuleReq struct {
	AppId string `json:"app_id"`

	Products []string `json:"products"`
}

在IoTDA实例中要配置转发规则推送数据的资源空间和产品列表

func (IotdaContentRuleReq) String 

func (o IotdaContentRuleReq) String() string

type IotdaContentRuleRsp 

type IotdaContentRuleRsp struct {
	AppId string `json:"app_id"`

	Products []string `json:"products"`

	RuleActions []IotdaRuleAction `json:"rule_actions"`
}

在IoTDA实例中要配置转发规则推送数据的资源空间和产品列表

func (IotdaContentRuleRsp) String 

func (o IotdaContentRuleRsp) String() string

type IotdaRuleAction 

type IotdaRuleAction struct {
	RuleId string `json:"rule_id"`

	ActionId string `json:"action_id"`
}

在IoTDA实例中的规则ID及其配套的推送数据动作ID

func (IotdaRuleAction) String 

func (o IotdaRuleAction) String() string

type Job 

type Job struct {
	JobId *string `json:"job_id,omitempty"`

	JobName string `json:"job_name"`

	Tags *string `json:"tags,omitempty"`

	CreatedTime *string `json:"created_time,omitempty"`

	ModifiedTime *string `json:"modified_time,omitempty"`

	JobType string `json:"job_type"`

	ExportPath *string `json:"export_path,omitempty"`

	MergeResultFile *bool `json:"merge_result_file,omitempty"`

	SqlJob *SqlJob `json:"sql_job,omitempty"`

	Schedule *Schedule `json:"schedule,omitempty"`
}

作业。

func (Job) String 

func (o Job) String() string

type KafkaAuthInfo 

type KafkaAuthInfo struct {
	SecurityProtocol string `json:"security_protocol"`

	SaslPlainAuthInfo *SaslPlainAuthInfo `json:"sasl_plain_auth_info,omitempty"`
}

Kafka 认证信息

func (KafkaAuthInfo) String 

func (o KafkaAuthInfo) String() string

type KafkaBrokerInfo 

type KafkaBrokerInfo struct {
	Ip string `json:"ip"`

	Port int32 `json:"port"`
}

Kafka Server地址

func (KafkaBrokerInfo) String 

func (o KafkaBrokerInfo) String() string

type KafkaContentReq 

type KafkaContentReq struct {
	ConnectionType string `json:"connection_type"`

	InstanceId *string `json:"instance_id,omitempty"`

	VpcepInfos *[]VpcepInfo `json:"vpcep_infos,omitempty"`

	BrokerInfos *[]KafkaBrokerInfo `json:"broker_infos,omitempty"`

	AuthInfo *KafkaAuthInfo `json:"auth_info,omitempty"`
}

Kafka数据源请求内容

func (KafkaContentReq) String 

func (o KafkaContentReq) String() string

type KafkaContentRsp 

type KafkaContentRsp struct {
	ConnectionType *string `json:"connection_type,omitempty"`

	InstanceId *string `json:"instance_id,omitempty"`

	VpcepInfos *[]VpcepInfoRsp `json:"vpcep_infos,omitempty"`

	BrokerInfos *[]KafkaBrokerInfo `json:"broker_infos,omitempty"`

	AuthInfo *KafkaAuthInfo `json:"auth_info,omitempty"`
}

Kafka数据源请求内容

func (KafkaContentRsp) String 

func (o KafkaContentRsp) String() string

type KeyValue 

type KeyValue struct {
	Key *string `json:"key,omitempty"`

	Value *string `json:"value,omitempty"`
}

func (KeyValue) String 

func (o KeyValue) String() string

type LastAssetPropertyValueRequest 

type LastAssetPropertyValueRequest struct {
	Tags map[string]interface{} `json:"tags,omitempty"`

	PropertyFilter *[]PropertyFilter `json:"property_filter,omitempty"`

	PropertyNames *[]string `json:"property_names,omitempty"`
}

查询资产属性最新值请求

func (LastAssetPropertyValueRequest) String 

func (o LastAssetPropertyValueRequest) String() string

type ListAssetModelsRequest 

type ListAssetModelsRequest struct {
	Filter *string `json:"filter,omitempty"`

	Limit *int32 `json:"limit,omitempty"`

	Offset *int32 `json:"offset,omitempty"`
}

Request Object

func (ListAssetModelsRequest) String 

func (o ListAssetModelsRequest) String() string

type ListAssetModelsResponse 

type ListAssetModelsResponse struct {
	Count *int64 `json:"count,omitempty"`

	AssetModels    *[]AssetModelResponse `json:"asset_models,omitempty"`
	HttpStatusCode int                   `json:"-"`
}

Response Object

func (ListAssetModelsResponse) String 

func (o ListAssetModelsResponse) String() string

type ListAssetsNewRequest 

type ListAssetsNewRequest struct {
	Limit *int32 `json:"limit,omitempty"`

	Offset *int32 `json:"offset,omitempty"`

	Filter *string `json:"filter,omitempty"`

	Type string `json:"type"`
}

Request Object

func (ListAssetsNewRequest) String 

func (o ListAssetsNewRequest) String() string

type ListAssetsNewResponse 

type ListAssetsNewResponse struct {
	Count *int64 `json:"count,omitempty"`

	Assets         *[]AssetResponse `json:"assets,omitempty"`
	HttpStatusCode int              `json:"-"`
}

Response Object

func (ListAssetsNewResponse) String 

func (o ListAssetsNewResponse) String() string

type ListBatchJobsRequest 

type ListBatchJobsRequest struct {
	Offset *int32 `json:"offset,omitempty"`

	Limit *int32 `json:"limit,omitempty"`

	HasSchedule *bool `json:"has_schedule,omitempty"`

	JobName *string `json:"job_name,omitempty"`

	ScheduleStatus *string `json:"schedule_status,omitempty"`

	OrderBy *string `json:"order_by,omitempty"`

	Order *string `json:"order,omitempty"`
}

Request Object

func (ListBatchJobsRequest) String 

func (o ListBatchJobsRequest) String() string

type ListBatchJobsResponse 

type ListBatchJobsResponse struct {
	Count *int64 `json:"count,omitempty"`

	Jobs           *[]Job `json:"jobs,omitempty"`
	HttpStatusCode int    `json:"-"`
}

Response Object

func (ListBatchJobsResponse) String 

func (o ListBatchJobsResponse) String() string

type ListComputingResourcesRequest 

type ListComputingResourcesRequest struct {
	ComputingResourceName *string `json:"computing_resource_name,omitempty"`

	Offset *int32 `json:"offset,omitempty"`

	Limit *int32 `json:"limit,omitempty"`
}

Request Object

func (ListComputingResourcesRequest) String 

func (o ListComputingResourcesRequest) String() string

type ListComputingResourcesResponse 

type ListComputingResourcesResponse struct {
	Count *int64 `json:"count,omitempty"`

	ComputingResources *[]ComputingResource `json:"computing_resources,omitempty"`
	HttpStatusCode     int                  `json:"-"`
}

Response Object

func (ListComputingResourcesResponse) String 

func (o ListComputingResourcesResponse) String() string

type ListDataStoresRequest 

type ListDataStoresRequest struct {
	GroupId *string `json:"group_id,omitempty"`

	DataStoreId *string `json:"data_store_id,omitempty"`

	Name *string `json:"name,omitempty"`

	Offset *int32 `json:"offset,omitempty"`

	Limit *int32 `json:"limit,omitempty"`
}

Request Object

func (ListDataStoresRequest) String 

func (o ListDataStoresRequest) String() string

type ListDataStoresResponse 

type ListDataStoresResponse struct {
	DataStores *[]GetDataStore `json:"data_stores,omitempty"`

	Count          *int32 `json:"count,omitempty"`
	HttpStatusCode int    `json:"-"`
}

Response Object

func (ListDataStoresResponse) String 

func (o ListDataStoresResponse) String() string

type ListGroupsRequest 

type ListGroupsRequest struct {
	Unit *ListGroupsRequestUnit `json:"unit,omitempty"`

	Type *string `json:"type,omitempty"`

	GroupId *string `json:"group_id,omitempty"`

	Name *string `json:"name,omitempty"`

	Offset *int32 `json:"offset,omitempty"`

	Limit *int32 `json:"limit,omitempty"`
}

Request Object

func (ListGroupsRequest) String 

func (o ListGroupsRequest) String() string

type ListGroupsRequestUnit 

type ListGroupsRequestUnit struct {
	// contains filtered or unexported fields
}

func (ListGroupsRequestUnit) MarshalJSON 

func (c ListGroupsRequestUnit) MarshalJSON() ([]byte, error)

func (*ListGroupsRequestUnit) UnmarshalJSON 

func (c *ListGroupsRequestUnit) UnmarshalJSON(b []byte) error

type ListGroupsRequestUnitEnum 

type ListGroupsRequestUnitEnum struct {
	MB ListGroupsRequestUnit
}

func GetListGroupsRequestUnitEnum 

func GetListGroupsRequestUnitEnum() ListGroupsRequestUnitEnum

type ListGroupsResponse 

type ListGroupsResponse struct {
	Groups *[]GetGroup `json:"groups,omitempty"`

	Count          *int32 `json:"count,omitempty"`
	HttpStatusCode int    `json:"-"`
}

Response Object

func (ListGroupsResponse) String 

func (o ListGroupsResponse) String() string

type ListHistoryRequest 

type ListHistoryRequest struct {
	DataStoreId string `json:"data_store_id"`

	Body *GetHistoryRequest `json:"body,omitempty"`
}

Request Object

func (ListHistoryRequest) String 

func (o ListHistoryRequest) String() string

type ListHistoryResponse 

type ListHistoryResponse struct {
	Timestamps *[]string `json:"timestamps,omitempty"`

	Properties     *[]HistoryValues `json:"properties,omitempty"`
	HttpStatusCode int              `json:"-"`
}

Response Object

func (ListHistoryResponse) String 

func (o ListHistoryResponse) String() string

type ListMetricsRequest 

type ListMetricsRequest struct {
	DataStoreId string `json:"data_store_id"`

	Body *GetMetricsRequest `json:"body,omitempty"`
}

Request Object

func (ListMetricsRequest) String 

func (o ListMetricsRequest) String() string

type ListMetricsResponse 

type ListMetricsResponse struct {
	Timestamps *[]string `json:"timestamps,omitempty"`

	Metrics        *[]MetricList `json:"metrics,omitempty"`
	HttpStatusCode int           `json:"-"`
}

Response Object

func (ListMetricsResponse) String 

func (o ListMetricsResponse) String() string

type ListPipelineJobsRequest 

type ListPipelineJobsRequest struct {
	DataStoreId *string `json:"data_store_id,omitempty"`

	DataStoreGroupId *string `json:"data_store_group_id,omitempty"`

	DataSourceId *string `json:"data_source_id,omitempty"`

	PipelineName *string `json:"pipeline_name,omitempty"`

	OperatorClassName *string `json:"operator_class_name,omitempty"`

	Offset *int64 `json:"offset,omitempty"`

	Limit *int32 `json:"limit,omitempty"`

	SyncStatus *bool `json:"sync_status,omitempty"`
}

Request Object

func (ListPipelineJobsRequest) String 

func (o ListPipelineJobsRequest) String() string

type ListPipelineJobsResponse 

type ListPipelineJobsResponse struct {
	Count *int64 `json:"count,omitempty"`

	Pipelines      *[]PipelineJobInfoDto `json:"pipelines,omitempty"`
	HttpStatusCode int                   `json:"-"`
}

Response Object

func (ListPipelineJobsResponse) String 

func (o ListPipelineJobsResponse) String() string

type ListRunsRequest 

type ListRunsRequest struct {
	Offset *int32 `json:"offset,omitempty"`

	Limit *int32 `json:"limit,omitempty"`

	StartTime *string `json:"start_time,omitempty"`

	EndTime *string `json:"end_time,omitempty"`

	SqlPattern *string `json:"sql_pattern,omitempty"`

	SqlType *string `json:"sql_type,omitempty"`

	JobType *string `json:"job_type,omitempty"`

	Status *string `json:"status,omitempty"`

	OrderBy *string `json:"order_by,omitempty"`

	Order *ListRunsRequestOrder `json:"order,omitempty"`

	JobName *string `json:"job_name,omitempty"`
}

Request Object

func (ListRunsRequest) String 

func (o ListRunsRequest) String() string

type ListRunsRequestOrder 

type ListRunsRequestOrder struct {
	// contains filtered or unexported fields
}

func (ListRunsRequestOrder) MarshalJSON 

func (c ListRunsRequestOrder) MarshalJSON() ([]byte, error)

func (*ListRunsRequestOrder) UnmarshalJSON 

func (c *ListRunsRequestOrder) UnmarshalJSON(b []byte) error

type ListRunsRequestOrderEnum 

type ListRunsRequestOrderEnum struct {
	ASC  ListRunsRequestOrder
	DESC ListRunsRequestOrder
}

func GetListRunsRequestOrderEnum 

func GetListRunsRequestOrderEnum() ListRunsRequestOrderEnum

type ListRunsResponse 

type ListRunsResponse struct {
	Count *int64 `json:"count,omitempty"`

	Runs           *[]Run `json:"runs,omitempty"`
	HttpStatusCode int    `json:"-"`
}

Response Object

func (ListRunsResponse) String 

func (o ListRunsResponse) String() string

type ListTablesRequest 

type ListTablesRequest struct {
	Keyword *string `json:"keyword,omitempty"`

	Tag *string `json:"tag,omitempty"`

	Offset *int32 `json:"offset,omitempty"`

	Limit *int32 `json:"limit,omitempty"`

	OrderBy *string `json:"order_by,omitempty"`

	Order *string `json:"order,omitempty"`
}

Request Object

func (ListTablesRequest) String 

func (o ListTablesRequest) String() string

type ListTablesResponse 

type ListTablesResponse struct {
	Tables *[]Table `json:"tables,omitempty"`

	Count          *int64 `json:"count,omitempty"`
	HttpStatusCode int    `json:"-"`
}

Response Object

func (ListTablesResponse) String 

func (o ListTablesResponse) String() string

type ListTagValuesRequest 

type ListTagValuesRequest struct {
	DataStoreId string `json:"data_store_id"`

	TagName string `json:"tag_name"`

	Filters *string `json:"filters,omitempty"`

	Offset *int32 `json:"offset,omitempty"`

	Limit *int32 `json:"limit,omitempty"`
}

Request Object

func (ListTagValuesRequest) String 

func (o ListTagValuesRequest) String() string

type ListTagValuesResponse 

type ListTagValuesResponse struct {
	TagName *string `json:"tag_name,omitempty"`

	TagValues *[]string `json:"tag_values,omitempty"`

	Count          *int32 `json:"count,omitempty"`
	HttpStatusCode int    `json:"-"`
}

Response Object

func (ListTagValuesResponse) String 

func (o ListTagValuesResponse) String() string

type Metric 

type Metric struct {
	Name *string `json:"name,omitempty"`

	Type *string `json:"type,omitempty"`

	Description *string `json:"description,omitempty"`

	Unit *string `json:"unit,omitempty"`
}

func (Metric) String 

func (o Metric) String() string

type MetricInput 

type MetricInput struct {
	Name string `json:"name"`

	PropertyName string `json:"property_name"`
}

定义指标计算查询的输入资产属性

func (MetricInput) String 

func (o MetricInput) String() string

type MetricList 

type MetricList struct {
	MetricName *string `json:"metric_name,omitempty"`

	Values *[]interface{} `json:"values,omitempty"`
}

func (MetricList) String 

func (o MetricList) String() string

type MetricValue 

type MetricValue struct {
	MetricName *string `json:"metric_name,omitempty"`

	Values *[]interface{} `json:"values,omitempty"`
}

func (MetricValue) String 

func (o MetricValue) String() string

type ModelArtsContentReq 

type ModelArtsContentReq struct {
	ServiceName string `json:"service_name"`

	AccessAddress string `json:"access_address"`

	VerifyBody string `json:"verify_body"`

	Ak string `json:"ak"`

	Sk string `json:"sk"`

	ProjectId string `json:"project_id"`
}

ModelArts数据源配置内容

func (ModelArtsContentReq) String 

func (o ModelArtsContentReq) String() string

type ModelArtsContentRsp 

type ModelArtsContentRsp struct {
	ServiceName *string `json:"serviceName,omitempty"`

	AccessAddress *string `json:"accessAddress,omitempty"`

	VerifyBody *string `json:"verifyBody,omitempty"`

	Ak *string `json:"ak,omitempty"`

	Sk *string `json:"sk,omitempty"`

	ProjectId *string `json:"projectId,omitempty"`
}

SMN数据源配置内容

func (ModelArtsContentRsp) String 

func (o ModelArtsContentRsp) String() string

type NamedFormula 

type NamedFormula struct {
	Name string `json:"name"`

	Formula string `json:"formula"`
}

带名称的公式

func (NamedFormula) String 

func (o NamedFormula) String() string

type NodeContentReq 

type NodeContentReq struct {
	SiteId string `json:"site_id"`

	Sqllist []string `json:"sqllist"`
}

节点数据源请求内容

func (NodeContentReq) String 

func (o NodeContentReq) String() string

type NodeContentRsp 

type NodeContentRsp struct {
	SiteId *string `json:"site_id,omitempty"`

	Sqllist *[]string `json:"sqllist,omitempty"`
}

节点数据源配置内容

func (NodeContentRsp) String 

func (o NodeContentRsp) String() string

type ObsContentReq 

type ObsContentReq struct {
	BucketName string `json:"bucket_name"`

	Ak string `json:"ak"`

	Sk string `json:"sk"`
}

OBS数据源配置内容

func (ObsContentReq) String 

func (o ObsContentReq) String() string

type ObsContentRsp 

type ObsContentRsp struct {
	BucketName *string `json:"bucketName,omitempty"`

	Ak *string `json:"ak,omitempty"`

	Sk *string `json:"sk,omitempty"`
}

OBS数据源配置内容

func (ObsContentRsp) String 

func (o ObsContentRsp) String() string

type OutputRequest 

type OutputRequest struct {
	Name string `json:"name"`

	OutputStaticAssetId *string `json:"output_static_asset_id,omitempty"`

	OutputDynamicAssetId *string `json:"output_dynamic_asset_id,omitempty"`
}

输出配置请求

func (OutputRequest) String 

func (o OutputRequest) String() string

type OutputResponse 

type OutputResponse struct {
	Name string `json:"name"`

	OutputStaticAssetId *string `json:"output_static_asset_id,omitempty"`

	OutputDynamicAssetId *string `json:"output_dynamic_asset_id,omitempty"`

	OutputAssetModelId *string `json:"output_asset_model_id,omitempty"`

	OutputProperty *string `json:"output_property,omitempty"`
}

输出配置响应

func (OutputResponse) String 

func (o OutputResponse) String() string

type OutputWithModel 

type OutputWithModel struct {
	Name string `json:"name"`

	OutputAssetModelId *string `json:"output_asset_model_id,omitempty"`

	OutputAssetModelName *string `json:"output_asset_model_name,omitempty"`

	OutputProperty string `json:"output_property"`
}

输出映射

func (OutputWithModel) String 

func (o OutputWithModel) String() string

type PipelineJobInfoDto 

type PipelineJobInfoDto struct {
	PipelineId *string `json:"pipeline_id,omitempty"`

	PipelineName *string `json:"pipeline_name,omitempty"`

	DataSourceId *string `json:"data_source_id,omitempty"`

	DataStoreList *[]DataStoreDto `json:"data_store_list,omitempty"`

	PipelineDescription *string `json:"pipeline_description,omitempty"`

	TagList *[]TagInfoDto `json:"tag_list,omitempty"`

	PipelineState *string `json:"pipeline_state,omitempty"`

	Status *string `json:"status,omitempty"`

	Rtu *int32 `json:"rtu,omitempty"`

	CreatedTime *string `json:"created_time,omitempty"`

	ModifiedTime *string `json:"modified_time,omitempty"`

	UserId *string `json:"user_id,omitempty"`

	HasSavepoint *bool `json:"has_savepoint,omitempty"`
}

管道作业基础信息，包括：管道ID、管道名称、管道类型等。

func (PipelineJobInfoDto) String 

func (o PipelineJobInfoDto) String() string

type Property 

type Property struct {
	Name *string `json:"name,omitempty"`

	Type *string `json:"type,omitempty"`

	Description *string `json:"description,omitempty"`

	Unit *string `json:"unit,omitempty"`
}

func (Property) String 

func (o Property) String() string

type PropertyFilter 

type PropertyFilter struct {
	PropertyName string `json:"property_name"`

	Operator string `json:"operator"`

	Value *interface{} `json:"value"`
}

属性过滤器

func (PropertyFilter) String 

func (o PropertyFilter) String() string

type PropertyModelRequest 

type PropertyModelRequest struct {
	Name string `json:"name"`

	DisplayName *string `json:"display_name,omitempty"`

	SourceType string `json:"source_type"`

	DataSchema *DataSchema `json:"data_schema"`

	Unit *string `json:"unit,omitempty"`

	Value *interface{} `json:"value,omitempty"`

	IsTag *bool `json:"is_tag,omitempty"`
}

func (PropertyModelRequest) String 

func (o PropertyModelRequest) String() string

type PropertyModelResponse 

type PropertyModelResponse struct {
	Name string `json:"name"`

	DisplayName *string `json:"display_name,omitempty"`

	SourceType string `json:"source_type"`

	DataSchema *DataSchema `json:"data_schema"`

	Unit *string `json:"unit,omitempty"`

	Value *interface{} `json:"value,omitempty"`

	IsTag *bool `json:"is_tag,omitempty"`

	PropertyId *string `json:"property_id,omitempty"`
}

func (PropertyModelResponse) String 

func (o PropertyModelResponse) String() string

type PropertyReferenceModel 

type PropertyReferenceModel struct {
	Type string `json:"type"`

	AssetModelId *string `json:"asset_model_id,omitempty"`

	AssetModelName *string `json:"asset_model_name,omitempty"`

	PropertyName string `json:"property_name"`
}

属性引用

func (PropertyReferenceModel) String 

func (o PropertyReferenceModel) String() string

type PropertyReferenceReq 

type PropertyReferenceReq struct {
	AssetId *string `json:"asset_id,omitempty"`
}

属性引用

func (PropertyReferenceReq) String 

func (o PropertyReferenceReq) String() string

type PropertyReferenceResponse 

type PropertyReferenceResponse struct {
	Type string `json:"type"`

	AssetModelId *string `json:"asset_model_id,omitempty"`

	AssetModelName *string `json:"asset_model_name,omitempty"`

	PropertyName string `json:"property_name"`

	AssetId *string `json:"asset_id,omitempty"`
}

属性引用

func (PropertyReferenceResponse) String 

func (o PropertyReferenceResponse) String() string

type PropertyRequest 

type PropertyRequest struct {
	Name string `json:"name"`

	Value *interface{} `json:"value,omitempty"`

	DeviceId *string `json:"device_id,omitempty"`
}

func (PropertyRequest) String 

func (o PropertyRequest) String() string

type PropertyResponse 

type PropertyResponse struct {
	DeviceId *string `json:"device_id,omitempty"`

	PropertyId *string `json:"property_id,omitempty"`

	Name string `json:"name"`

	DisplayName *string `json:"display_name,omitempty"`

	SourceType string `json:"source_type"`

	DataSchema *DataSchema `json:"data_schema"`

	Unit *string `json:"unit,omitempty"`

	Value *interface{} `json:"value,omitempty"`

	IsTag *bool `json:"is_tag,omitempty"`
}

func (PropertyResponse) String 

func (o PropertyResponse) String() string

type PropertyValue 

type PropertyValue struct {
	PropertyName *string `json:"property_name,omitempty"`

	Value *interface{} `json:"value,omitempty"`

	Timestamp *string `json:"timestamp,omitempty"`
}

func (PropertyValue) String 

func (o PropertyValue) String() string

type PublishRootAssetRequest 

type PublishRootAssetRequest struct {
	RootAssetId string `json:"root_asset_id"`
}

Request Object

func (PublishRootAssetRequest) String 

func (o PublishRootAssetRequest) String() string

type PublishRootAssetResponse 

type PublishRootAssetResponse struct {
	HttpStatusCode int `json:"-"`
}

Response Object

func (PublishRootAssetResponse) String 

func (o PublishRootAssetResponse) String() string

type RawRequest 

type RawRequest struct {
	TimeSpan *TimeSpanDt `json:"time_span,omitempty"`

	Tags map[string]interface{} `json:"tags,omitempty"`

	PropertyFilter *[]PropertyFilter `json:"property_filter,omitempty"`

	PropertyNames []string `json:"property_names"`

	Limit *int32 `json:"limit,omitempty"`
}

资产属性历史数据查询

func (RawRequest) String 

func (o RawRequest) String() string

type RawValue 

type RawValue struct {
	PropertyName *string `json:"property_name,omitempty"`

	Values *[]interface{} `json:"values,omitempty"`
}

func (RawValue) String 

func (o RawValue) String() string

type Run 

type Run struct {
	RunId string `json:"run_id"`

	JobId *string `json:"job_id,omitempty"`

	JobName string `json:"job_name"`

	JobType RunJobType `json:"job_type"`

	StartTime string `json:"start_time"`

	Duration int64 `json:"duration"`

	Status string `json:"status"`

	IsScheduleJob *bool `json:"is_schedule_job,omitempty"`

	ComputingResourceName *string `json:"computing_resource_name,omitempty"`

	SqlJob *SqlJobRun `json:"sql_job,omitempty"`
}

func (Run) String 

func (o Run) String() string

type RunDetail 

type RunDetail struct {
	DetailId string `json:"detail_id"`

	Status *string `json:"status,omitempty"`

	SqlJob *SqlJobRunDetail `json:"sql_job,omitempty"`
}

func (RunDetail) String 

func (o RunDetail) String() string

type RunJobType 

type RunJobType struct {
	// contains filtered or unexported fields
}

func (RunJobType) MarshalJSON 

func (c RunJobType) MarshalJSON() ([]byte, error)

func (*RunJobType) UnmarshalJSON 

func (c *RunJobType) UnmarshalJSON(b []byte) error

type RunJobTypeEnum 

type RunJobTypeEnum struct {
	SQL_JOB RunJobType
}

func GetRunJobTypeEnum 

func GetRunJobTypeEnum() RunJobTypeEnum

type SaslPlainAuthInfo 

type SaslPlainAuthInfo struct {
	Username *string `json:"username,omitempty"`

	Password *string `json:"password,omitempty"`
}

sasl plain 认证信息

func (SaslPlainAuthInfo) String 

func (o SaslPlainAuthInfo) String() string

type Schedule 

type Schedule struct {
	StartTime string `json:"start_time"`

	EndTime string `json:"end_time"`

	CronExpression string `json:"cron_expression"`

	ComputingResourceId string `json:"computing_resource_id"`

	Enable bool `json:"enable"`

	Conf *[]string `json:"conf,omitempty"`

	ScheduleStatus *string `json:"schedule_status,omitempty"`

	NextFireTime *string `json:"next_fire_time,omitempty"`

	PrevFireTime *string `json:"prev_fire_time,omitempty"`
}

SQL作业。

func (Schedule) String 

func (o Schedule) String() string

type ShowAllDataSourceRequest 

type ShowAllDataSourceRequest struct {
	Name *string `json:"name,omitempty"`

	Type *string `json:"type,omitempty"`

	Limit *int32 `json:"limit,omitempty"`

	Offset *int32 `json:"offset,omitempty"`
}

Request Object

func (ShowAllDataSourceRequest) String 

func (o ShowAllDataSourceRequest) String() string

type ShowAllDataSourceResponse 

type ShowAllDataSourceResponse struct {
	Count *int32 `json:"count,omitempty"`

	Datasources    *[]DatasourceRestDto `json:"datasources,omitempty"`
	HttpStatusCode int                  `json:"-"`
}

Response Object

func (ShowAllDataSourceResponse) String 

func (o ShowAllDataSourceResponse) String() string

type ShowAssetModelRequest 

type ShowAssetModelRequest struct {
	ModelId string `json:"model_id"`
}

Request Object

func (ShowAssetModelRequest) String 

func (o ShowAssetModelRequest) String() string

type ShowAssetModelResponse 

type ShowAssetModelResponse struct {
	AssetModelId *string `json:"asset_model_id,omitempty"`

	Name *string `json:"name,omitempty"`

	DisplayName *string `json:"display_name,omitempty"`

	Properties *[]PropertyModelResponse `json:"properties,omitempty"`

	Analyses *[]AnalysisModelResponse `json:"analyses,omitempty"`

	CreatedTime *string `json:"created_time,omitempty"`

	ModifiedTime   *string `json:"modified_time,omitempty"`
	HttpStatusCode int     `json:"-"`
}

Response Object

func (ShowAssetModelResponse) String 

func (o ShowAssetModelResponse) String() string

type ShowAssetNewRequest 

type ShowAssetNewRequest struct {
	AssetId string `json:"asset_id"`

	Type string `json:"type"`
}

Request Object

func (ShowAssetNewRequest) String 

func (o ShowAssetNewRequest) String() string

type ShowAssetNewResponse 

type ShowAssetNewResponse struct {
	AssetId *string `json:"asset_id,omitempty"`

	AssetModelId *string `json:"asset_model_id,omitempty"`

	AssetModelName *string `json:"asset_model_name,omitempty"`

	Name *string `json:"name,omitempty"`

	DisplayName *string `json:"display_name,omitempty"`

	Properties *[]PropertyResponse `json:"properties,omitempty"`

	Analyses *[]AnalysisResponse `json:"analyses,omitempty"`

	Root *string `json:"root,omitempty"`

	Parent *string `json:"parent,omitempty"`

	Children *[]string `json:"children,omitempty"`

	State *string `json:"state,omitempty"`

	PublishState *string `json:"publish_state,omitempty"`

	CreatedTime *string `json:"created_time,omitempty"`

	ModifiedTime *string `json:"modified_time,omitempty"`

	PublishedTime  *string `json:"published_time,omitempty"`
	HttpStatusCode int     `json:"-"`
}

Response Object

func (ShowAssetNewResponse) String 

func (o ShowAssetNewResponse) String() string

type ShowBatchJobRequest 

type ShowBatchJobRequest struct {
	JobId string `json:"job_id"`
}

Request Object

func (ShowBatchJobRequest) String 

func (o ShowBatchJobRequest) String() string

type ShowBatchJobResponse 

type ShowBatchJobResponse struct {
	JobId *string `json:"job_id,omitempty"`

	JobName *string `json:"job_name,omitempty"`

	Tags *string `json:"tags,omitempty"`

	CreatedTime *string `json:"created_time,omitempty"`

	ModifiedTime *string `json:"modified_time,omitempty"`

	JobType *string `json:"job_type,omitempty"`

	ExportPath *string `json:"export_path,omitempty"`

	MergeResultFile *bool `json:"merge_result_file,omitempty"`

	SqlJob *SqlJob `json:"sql_job,omitempty"`

	Schedule       *Schedule `json:"schedule,omitempty"`
	HttpStatusCode int       `json:"-"`
}

Response Object

func (ShowBatchJobResponse) String 

func (o ShowBatchJobResponse) String() string

type ShowDataSourceRequest 

type ShowDataSourceRequest struct {
	DatasourceId string `json:"datasource_id"`
}

Request Object

func (ShowDataSourceRequest) String 

func (o ShowDataSourceRequest) String() string

type ShowDataSourceResponse 

type ShowDataSourceResponse struct {
	Id *string `json:"id,omitempty"`

	Name *string `json:"name,omitempty"`

	Type *string `json:"type,omitempty"`

	Content *ContentDetailRsp `json:"content,omitempty"`

	CreatedTime *string `json:"created_time,omitempty"`

	ModifiedTime   *string `json:"modified_time,omitempty"`
	HttpStatusCode int     `json:"-"`
}

Response Object

func (ShowDataSourceResponse) String 

func (o ShowDataSourceResponse) String() string

type ShowDatasetRequest 

type ShowDatasetRequest struct {
	JobId string `json:"job_id"`

	RunId string `json:"run_id"`

	Offset *int32 `json:"offset,omitempty"`

	Limit *int32 `json:"limit,omitempty"`
}

Request Object

func (ShowDatasetRequest) String 

func (o ShowDatasetRequest) String() string

type ShowDatasetResponse 

type ShowDatasetResponse struct {
	Count *int64 `json:"count,omitempty"`

	RunId *string `json:"run_id,omitempty"`

	JobType *string `json:"job_type,omitempty"`

	SqlJob         *SqlJobQueryDataset `json:"sql_job,omitempty"`
	HttpStatusCode int                 `json:"-"`
}

Response Object

func (ShowDatasetResponse) String 

func (o ShowDatasetResponse) String() string

type ShowJobByIdRequest 

type ShowJobByIdRequest struct {
	JobId string `json:"job_id"`
}

Request Object

func (ShowJobByIdRequest) String 

func (o ShowJobByIdRequest) String() string

type ShowJobByIdResponse 

type ShowJobByIdResponse struct {
	JobConfig map[string]interface{} `json:"job_config,omitempty"`

	JobInfo        *StreamingJobInfoDto `json:"job_info,omitempty"`
	HttpStatusCode int                  `json:"-"`
}

Response Object

func (ShowJobByIdResponse) String 

func (o ShowJobByIdResponse) String() string

type ShowJobsRequest 

type ShowJobsRequest struct {
	JobInputType *ShowJobsRequestJobInputType `json:"job_input_type,omitempty"`

	Offset *int64 `json:"offset,omitempty"`

	Limit *int32 `json:"limit,omitempty"`

	SyncStatus *bool `json:"sync_status,omitempty"`
}

Request Object

func (ShowJobsRequest) String 

func (o ShowJobsRequest) String() string

type ShowJobsRequestJobInputType 

type ShowJobsRequestJobInputType struct {
	// contains filtered or unexported fields
}

func (ShowJobsRequestJobInputType) MarshalJSON 

func (c ShowJobsRequestJobInputType) MarshalJSON() ([]byte, error)

func (*ShowJobsRequestJobInputType) UnmarshalJSON 

func (c *ShowJobsRequestJobInputType) UnmarshalJSON(b []byte) error

type ShowJobsRequestJobInputTypeEnum 

type ShowJobsRequestJobInputTypeEnum struct {
	ASSET_DATA ShowJobsRequestJobInputType
	OLD_DATA   ShowJobsRequestJobInputType
}

func GetShowJobsRequestJobInputTypeEnum 

func GetShowJobsRequestJobInputTypeEnum() ShowJobsRequestJobInputTypeEnum

type ShowJobsResponse 

type ShowJobsResponse struct {
	Count *int64 `json:"count,omitempty"`

	Jobs           *[]StreamingJobInfoDto `json:"jobs,omitempty"`
	HttpStatusCode int                    `json:"-"`
}

Response Object

func (ShowJobsResponse) String 

func (o ShowJobsResponse) String() string

type ShowLastPropertyValueRequest 

type ShowLastPropertyValueRequest struct {
	AssetId string `json:"asset_id"`

	Body *LastAssetPropertyValueRequest `json:"body,omitempty"`
}

Request Object

func (ShowLastPropertyValueRequest) String 

func (o ShowLastPropertyValueRequest) String() string

type ShowLastPropertyValueResponse 

type ShowLastPropertyValueResponse struct {
	Properties     *[]AssetPropertyLastValue `json:"properties,omitempty"`
	HttpStatusCode int                       `json:"-"`
}

Response Object

func (ShowLastPropertyValueResponse) String 

func (o ShowLastPropertyValueResponse) String() string

type ShowMetricValueRequest 

type ShowMetricValueRequest struct {
	AssetId string `json:"asset_id"`

	Body *GetMetricsValue `json:"body,omitempty"`
}

Request Object

func (ShowMetricValueRequest) String 

func (o ShowMetricValueRequest) String() string

type ShowMetricValueResponse 

type ShowMetricValueResponse struct {
	Timestamps *[]string `json:"timestamps,omitempty"`

	Metrics        *[]MetricValue `json:"metrics,omitempty"`
	HttpStatusCode int            `json:"-"`
}

Response Object

func (ShowMetricValueResponse) String 

func (o ShowMetricValueResponse) String() string

type ShowPipelineJobRequest 

type ShowPipelineJobRequest struct {
	PipelineId string `json:"pipeline_id"`
}

Request Object

func (ShowPipelineJobRequest) String 

func (o ShowPipelineJobRequest) String() string

type ShowPipelineJobResponse 

type ShowPipelineJobResponse struct {
	PipelineConfig map[string]interface{} `json:"pipeline_config,omitempty"`

	PipelineInfo   *PipelineJobInfoDto `json:"pipeline_info,omitempty"`
	HttpStatusCode int                 `json:"-"`
}

Response Object

func (ShowPipelineJobResponse) String 

func (o ShowPipelineJobResponse) String() string

type ShowPropertyRawValueRequest 

type ShowPropertyRawValueRequest struct {
	AssetId string `json:"asset_id"`

	Body *RawRequest `json:"body,omitempty"`
}

Request Object

func (ShowPropertyRawValueRequest) String 

func (o ShowPropertyRawValueRequest) String() string

type ShowPropertyRawValueResponse 

type ShowPropertyRawValueResponse struct {
	Timestamps *[]string `json:"timestamps,omitempty"`

	Properties     *[]RawValue `json:"properties,omitempty"`
	HttpStatusCode int         `json:"-"`
}

Response Object

func (ShowPropertyRawValueResponse) String 

func (o ShowPropertyRawValueResponse) String() string

type ShowPropertyValuesRequest 

type ShowPropertyValuesRequest struct {
	DataStoreId string `json:"data_store_id"`

	Body *GetPropertyRequest `json:"body,omitempty"`
}

Request Object

func (ShowPropertyValuesRequest) String 

func (o ShowPropertyValuesRequest) String() string

type ShowPropertyValuesResponse 

type ShowPropertyValuesResponse struct {
	Properties     *[]PropertyValue `json:"properties,omitempty"`
	HttpStatusCode int              `json:"-"`
}

Response Object

func (ShowPropertyValuesResponse) String 

func (o ShowPropertyValuesResponse) String() string

type ShowRunRequest 

type ShowRunRequest struct {
	JobId string `json:"job_id"`

	RunId string `json:"run_id"`

	WithDetails *bool `json:"with_details,omitempty"`
}

Request Object

func (ShowRunRequest) String 

func (o ShowRunRequest) String() string

type ShowRunResponse 

type ShowRunResponse struct {
	RunId *string `json:"run_id,omitempty"`

	JobId *string `json:"job_id,omitempty"`

	JobType *string `json:"job_type,omitempty"`

	Status *string `json:"status,omitempty"`

	CreatedTime *string `json:"created_time,omitempty"`

	Message *string `json:"message,omitempty"`

	Details        *[]RunDetail `json:"details,omitempty"`
	HttpStatusCode int          `json:"-"`
}

Response Object

func (ShowRunResponse) String 

func (o ShowRunResponse) String() string

type ShowTablePreviewRequest 

type ShowTablePreviewRequest struct {
	TableId string `json:"table_id"`
}

Request Object

func (ShowTablePreviewRequest) String 

func (o ShowTablePreviewRequest) String() string

type ShowTablePreviewResponse 

type ShowTablePreviewResponse struct {
	Schema *[]interface{} `json:"schema,omitempty"`

	Rows           *[]interface{} `json:"rows,omitempty"`
	HttpStatusCode int            `json:"-"`
}

Response Object

func (ShowTablePreviewResponse) String 

func (o ShowTablePreviewResponse) String() string

type ShowTableSchemaRequest 

type ShowTableSchemaRequest struct {
	TableId string `json:"table_id"`
}

Request Object

func (ShowTableSchemaRequest) String 

func (o ShowTableSchemaRequest) String() string

type ShowTableSchemaResponse 

type ShowTableSchemaResponse struct {
	TableId *string `json:"table_id,omitempty"`

	TableName *string `json:"table_name,omitempty"`

	TableAlias *string `json:"table_alias,omitempty"`

	Tags *string `json:"tags,omitempty"`

	ColumnCount *int32 `json:"column_count,omitempty"`

	Columns *[]Column `json:"columns,omitempty"`

	TableType *string `json:"table_type,omitempty"`

	DataType *string `json:"data_type,omitempty"`

	DataLocation *string `json:"data_location,omitempty"`

	StorageProperties *[]KeyValue `json:"storage_properties,omitempty"`
	HttpStatusCode    int         `json:"-"`
}

Response Object

func (ShowTableSchemaResponse) String 

func (o ShowTableSchemaResponse) String() string

type SmnContentReq 

type SmnContentReq struct {
	ProjectId string `json:"project_id"`

	Ak string `json:"ak"`

	Sk string `json:"sk"`
}

SMN数据源配置内容

func (SmnContentReq) String 

func (o SmnContentReq) String() string

type SmnContentRsp 

type SmnContentRsp struct {
	ProjectId *string `json:"projectId,omitempty"`

	Ak *string `json:"ak,omitempty"`

	Sk *string `json:"sk,omitempty"`
}

SMN数据源配置内容

func (SmnContentRsp) String 

func (o SmnContentRsp) String() string

type SqlJob 

type SqlJob struct {
	Sql string `json:"sql"`
}

可选。SQL作业。

func (SqlJob) String 

func (o SqlJob) String() string

type SqlJobQueryDataset 

type SqlJobQueryDataset struct {
	SqlType string `json:"sql_type"`

	Schema *[]interface{} `json:"schema,omitempty"`

	Rows *[]interface{} `json:"rows,omitempty"`
}

SQL作业运行结果。

func (SqlJobQueryDataset) String 

func (o SqlJobQueryDataset) String() string

type SqlJobRun 

type SqlJobRun struct {
	SqlType string `json:"sql_type"`
}

SQL作业运行。

func (SqlJobRun) String 

func (o SqlJobRun) String() string

type SqlJobRunDetail 

type SqlJobRunDetail struct {
	SqlType *string `json:"sql_type,omitempty"`

	StartTime *string `json:"start_time,omitempty"`

	Duration *int64 `json:"duration,omitempty"`

	InputRowCount *int64 `json:"input_row_count,omitempty"`

	BadRowCount *int64 `json:"bad_row_count,omitempty"`

	InputSize *int64 `json:"input_size,omitempty"`

	ResultCount *int64 `json:"result_count,omitempty"`

	TableName *string `json:"table_name,omitempty"`

	WithColumnHeader *bool `json:"with_column_header,omitempty"`

	Detail *string `json:"detail,omitempty"`

	Statement *string `json:"statement,omitempty"`

	Message *string `json:"message,omitempty"`
}

func (SqlJobRunDetail) String 

func (o SqlJobRunDetail) String() string

type SqlJobRunResponseBody 

type SqlJobRunResponseBody struct {
	SqlType string `json:"sql_type"`

	Schema *[]interface{} `json:"schema,omitempty"`

	Rows *[]interface{} `json:"rows,omitempty"`

	JobMode *string `json:"job_mode,omitempty"`
}

SQL作业运行响应。

func (SqlJobRunResponseBody) String 

func (o SqlJobRunResponseBody) String() string

type StartJobRequest 

type StartJobRequest struct {
	JobId string `json:"job_id"`

	Parallel *int32 `json:"parallel,omitempty"`

	Rtu *int32 `json:"rtu,omitempty"`

	ResumeSavepoint *bool `json:"resume_savepoint,omitempty"`
}

Request Object

func (StartJobRequest) String 

func (o StartJobRequest) String() string

type StartJobResponse 

type StartJobResponse struct {
	JobId          *string `json:"job_id,omitempty"`
	HttpStatusCode int     `json:"-"`
}

Response Object

func (StartJobResponse) String 

func (o StartJobResponse) String() string

type StartPipelineJobRequest 

type StartPipelineJobRequest struct {
	PipelineId string `json:"pipeline_id"`

	Parallel *int32 `json:"parallel,omitempty"`

	Rtu *int32 `json:"rtu,omitempty"`

	ResumeSavepoint *bool `json:"resume_savepoint,omitempty"`
}

Request Object

func (StartPipelineJobRequest) String 

func (o StartPipelineJobRequest) String() string

type StartPipelineJobResponse 

type StartPipelineJobResponse struct {
	PipelineId     *string `json:"pipeline_id,omitempty"`
	HttpStatusCode int     `json:"-"`
}

Response Object

func (StartPipelineJobResponse) String 

func (o StartPipelineJobResponse) String() string

type StopJobRequest 

type StopJobRequest struct {
	JobId string `json:"job_id"`

	TriggerSavepoint *bool `json:"trigger_savepoint,omitempty"`
}

Request Object

func (StopJobRequest) String 

func (o StopJobRequest) String() string

type StopJobResponse 

type StopJobResponse struct {
	JobId          *string `json:"job_id,omitempty"`
	HttpStatusCode int     `json:"-"`
}

Response Object

func (StopJobResponse) String 

func (o StopJobResponse) String() string

type StopPipelineJobRequest 

type StopPipelineJobRequest struct {
	PipelineId string `json:"pipeline_id"`

	TriggerSavepoint *bool `json:"trigger_savepoint,omitempty"`
}

Request Object

func (StopPipelineJobRequest) String 

func (o StopPipelineJobRequest) String() string

type StopPipelineJobResponse 

type StopPipelineJobResponse struct {
	PipelineId     *string `json:"pipeline_id,omitempty"`
	HttpStatusCode int     `json:"-"`
}

Response Object

func (StopPipelineJobResponse) String 

func (o StopPipelineJobResponse) String() string

type StorageGroup 

type StorageGroup struct {
	Name *string `json:"name,omitempty"`

	Description *string `json:"description,omitempty"`

	WarmDataRetentionPolicy *string `json:"warm_data_retention_policy,omitempty"`

	ColdDataRetentionPolicy *string `json:"cold_data_retention_policy,omitempty"`
}

存储组信息

func (StorageGroup) String 

func (o StorageGroup) String() string

type StreamModel 

type StreamModel struct {
	Inputs []InputModel `json:"inputs"`

	JobId string `json:"job_id"`

	Outputs []StreamOutput `json:"outputs"`
}

流计算

func (StreamModel) String 

func (o StreamModel) String() string

type StreamOutput 

type StreamOutput struct {
	Name string `json:"name"`

	OutputProperty string `json:"output_property"`
}

流计算输出映射

func (StreamOutput) String 

func (o StreamOutput) String() string

type StreamResponse 

type StreamResponse struct {
	Inputs *[]InputResponse `json:"inputs,omitempty"`

	JobId *string `json:"job_id,omitempty"`

	Outputs *[]StreamOutput `json:"outputs,omitempty"`
}

流计算

func (StreamResponse) String 

func (o StreamResponse) String() string

type StreamingJobInfoDto 

type StreamingJobInfoDto struct {
	JobId *string `json:"job_id,omitempty"`

	JobName *string `json:"job_name,omitempty"`

	JobInputType *string `json:"job_input_type,omitempty"`

	JobDescription *string `json:"job_description,omitempty"`

	JobState *string `json:"job_state,omitempty"`

	Status *string `json:"status,omitempty"`

	Rtu *int32 `json:"rtu,omitempty"`

	CreatedTime *string `json:"created_time,omitempty"`

	ModifiedTime *string `json:"modified_time,omitempty"`

	UserId *string `json:"user_id,omitempty"`

	HasSavepoint *bool `json:"has_savepoint,omitempty"`
}

实时分析作业基础信息，包括：实时分析作业ID、实时分析作业名称、作业类型等。

func (StreamingJobInfoDto) String 

func (o StreamingJobInfoDto) String() string

type Table 

type Table struct {
	TableId *string `json:"table_id,omitempty"`

	TableName *string `json:"table_name,omitempty"`

	TableAlias *string `json:"table_alias,omitempty"`

	CreatedTime *string `json:"created_time,omitempty"`

	ModifiedTime *string `json:"modified_time,omitempty"`

	DataLocation *string `json:"data_location,omitempty"`

	DataType *string `json:"data_type,omitempty"`

	DataSource *string `json:"data_source,omitempty"`

	TableType *string `json:"table_type,omitempty"`

	Description *string `json:"description,omitempty"`

	PartitionColumns *[]string `json:"partition_columns,omitempty"`

	DataStoreId *string `json:"data_store_id,omitempty"`

	Tags *string `json:"tags,omitempty"`
}

func (Table) String 

func (o Table) String() string

type Tag 

type Tag struct {
	Name *string `json:"name,omitempty"`

	Description *string `json:"description,omitempty"`
}

func (Tag) String 

func (o Tag) String() string

type TagInfoDto 

type TagInfoDto struct {
	OperatorId *string `json:"operator_id,omitempty"`

	DataStoreId *string `json:"data_store_id,omitempty"`

	Tag *string `json:"tag,omitempty"`
}

标签信息

func (TagInfoDto) String 

func (o TagInfoDto) String() string

type TimeSpan 

type TimeSpan struct {
	From string `json:"from"`

	To string `json:"to"`
}

起止时间范围

func (TimeSpan) String 

func (o TimeSpan) String() string

type TimeSpanDt 

type TimeSpanDt struct {
	From *string `json:"from,omitempty"`

	To *string `json:"to,omitempty"`
}

起止时间

func (TimeSpanDt) String 

func (o TimeSpanDt) String() string

type TransformMetric 

type TransformMetric struct {
	Inputs []InputParam `json:"inputs"`

	MetricName string `json:"metric_name"`

	Expression string `json:"expression"`
}

查询指标

func (TransformMetric) String 

func (o TransformMetric) String() string

type TransformMetrics 

type TransformMetrics struct {
	TimeSpan *TimeSpan `json:"time_span"`

	Tags map[string]string `json:"tags"`

	Metrics []TransformMetric `json:"metrics"`

	Limit *int32 `json:"limit,omitempty"`
}

转换计算定义

func (TransformMetrics) String 

func (o TransformMetrics) String() string

type TransformMetricsRequest 

type TransformMetricsRequest struct {
	TimeSpan *TimeSpanDt `json:"time_span,omitempty"`

	Tags map[string]interface{} `json:"tags,omitempty"`

	PropertyFilter *[]PropertyFilter `json:"property_filter,omitempty"`

	Metrics []DtTransformMetrics `json:"metrics"`

	Limit *int32 `json:"limit,omitempty"`
}

查询经过转换计算的序列值定义

func (TransformMetricsRequest) String 

func (o TransformMetricsRequest) String() string

type TransformModel 

type TransformModel struct {
	Inputs []InputModel `json:"inputs"`

	Expression *Formula `json:"expression"`

	OutputProperty *string `json:"output_property,omitempty"`

	Outputs *[]OutputWithModel `json:"outputs,omitempty"`
}

转换计算

func (TransformModel) String 

func (o TransformModel) String() string

type TransformResponse 

type TransformResponse struct {
	Inputs *[]InputResponse `json:"inputs,omitempty"`

	Expression *Formula `json:"expression,omitempty"`

	OutputProperty *string `json:"output_property,omitempty"`

	Outputs *[]OutputResponse `json:"outputs,omitempty"`
}

转换计算

func (TransformResponse) String 

func (o TransformResponse) String() string

type UpdateAssetModelRequest 

type UpdateAssetModelRequest struct {
	ModelId string `json:"model_id"`

	Body *AssetModelModRequest `json:"body,omitempty"`
}

Request Object

func (UpdateAssetModelRequest) String 

func (o UpdateAssetModelRequest) String() string

type UpdateAssetModelResponse 

type UpdateAssetModelResponse struct {
	AssetModelId *string `json:"asset_model_id,omitempty"`

	Name *string `json:"name,omitempty"`

	DisplayName *string `json:"display_name,omitempty"`

	Properties *[]PropertyModelResponse `json:"properties,omitempty"`

	Analyses *[]AnalysisModelResponse `json:"analyses,omitempty"`

	CreatedTime *string `json:"created_time,omitempty"`

	ModifiedTime   *string `json:"modified_time,omitempty"`
	HttpStatusCode int     `json:"-"`
}

Response Object

func (UpdateAssetModelResponse) String 

func (o UpdateAssetModelResponse) String() string

type UpdateAssetNewRequest 

type UpdateAssetNewRequest struct {
	AssetId string `json:"asset_id"`

	Body *AssetModRequest `json:"body,omitempty"`
}

Request Object

func (UpdateAssetNewRequest) String 

func (o UpdateAssetNewRequest) String() string

type UpdateAssetNewResponse 

type UpdateAssetNewResponse struct {
	AssetId *string `json:"asset_id,omitempty"`

	AssetModelId *string `json:"asset_model_id,omitempty"`

	AssetModelName *string `json:"asset_model_name,omitempty"`

	Name *string `json:"name,omitempty"`

	DisplayName *string `json:"display_name,omitempty"`

	Properties *[]PropertyResponse `json:"properties,omitempty"`

	Analyses *[]AnalysisResponse `json:"analyses,omitempty"`

	Root *string `json:"root,omitempty"`

	Parent *string `json:"parent,omitempty"`

	Children *[]string `json:"children,omitempty"`

	State *string `json:"state,omitempty"`

	PublishState *string `json:"publish_state,omitempty"`

	CreatedTime *string `json:"created_time,omitempty"`

	ModifiedTime *string `json:"modified_time,omitempty"`

	PublishedTime  *string `json:"published_time,omitempty"`
	HttpStatusCode int     `json:"-"`
}

Response Object

func (UpdateAssetNewResponse) String 

func (o UpdateAssetNewResponse) String() string

type UpdateBatchJobRequest 

type UpdateBatchJobRequest struct {
	JobId string `json:"job_id"`

	Body *Job `json:"body,omitempty"`
}

Request Object

func (UpdateBatchJobRequest) String 

func (o UpdateBatchJobRequest) String() string

type UpdateBatchJobResponse 

type UpdateBatchJobResponse struct {
	JobId *string `json:"job_id,omitempty"`

	JobName *string `json:"job_name,omitempty"`

	Tags *string `json:"tags,omitempty"`

	CreatedTime *string `json:"created_time,omitempty"`

	ModifiedTime *string `json:"modified_time,omitempty"`

	JobType *string `json:"job_type,omitempty"`

	ExportPath *string `json:"export_path,omitempty"`

	MergeResultFile *bool `json:"merge_result_file,omitempty"`

	SqlJob *SqlJob `json:"sql_job,omitempty"`

	Schedule       *Schedule `json:"schedule,omitempty"`
	HttpStatusCode int       `json:"-"`
}

Response Object

func (UpdateBatchJobResponse) String 

func (o UpdateBatchJobResponse) String() string

type UpdateDataSourceRequest 

type UpdateDataSourceRequest struct {
	DatasourceId string `json:"datasource_id"`

	Body *UpdateDatasourceReqDto `json:"body,omitempty"`
}

Request Object

func (UpdateDataSourceRequest) String 

func (o UpdateDataSourceRequest) String() string

type UpdateDataSourceResponse 

type UpdateDataSourceResponse struct {
	Id *string `json:"id,omitempty"`

	Name *string `json:"name,omitempty"`

	Type *string `json:"type,omitempty"`

	Content *ContentDetailRsp `json:"content,omitempty"`

	CreatedTime *string `json:"created_time,omitempty"`

	ModifiedTime   *string `json:"modified_time,omitempty"`
	HttpStatusCode int     `json:"-"`
}

Response Object

func (UpdateDataSourceResponse) String 

func (o UpdateDataSourceResponse) String() string

type UpdateDataStore 

type UpdateDataStore struct {
	Name *string `json:"name,omitempty"`

	Tags *[]Tag `json:"tags,omitempty"`

	Metrics *[]Metric `json:"metrics,omitempty"`

	Properties *[]Property `json:"properties,omitempty"`
}

func (UpdateDataStore) String 

func (o UpdateDataStore) String() string

type UpdateDataStoreRequest 

type UpdateDataStoreRequest struct {
	DataStoreId string `json:"data_store_id"`

	Body *UpdateDataStore `json:"body,omitempty"`
}

Request Object

func (UpdateDataStoreRequest) String 

func (o UpdateDataStoreRequest) String() string

type UpdateDataStoreResponse 

type UpdateDataStoreResponse struct {
	DataStoreId *string `json:"data_store_id,omitempty"`

	Name *string `json:"name,omitempty"`

	GroupId *string `json:"group_id,omitempty"`

	Tags *[]Tag `json:"tags,omitempty"`

	Metrics *[]Metric `json:"metrics,omitempty"`

	Properties *[]Property `json:"properties,omitempty"`

	CreatedTime *string `json:"created_time,omitempty"`

	ModifiedTime   *string `json:"modified_time,omitempty"`
	HttpStatusCode int     `json:"-"`
}

Response Object

func (UpdateDataStoreResponse) String 

func (o UpdateDataStoreResponse) String() string

type UpdateDatasourceReqDto 

type UpdateDatasourceReqDto struct {
	Name string `json:"name"`

	Type string `json:"type"`

	Content *ContentDetailReq `json:"content,omitempty"`
}

func (UpdateDatasourceReqDto) String 

func (o UpdateDatasourceReqDto) String() string

type UpdateGroupRequest 

type UpdateGroupRequest struct {
	GroupId string `json:"group_id"`

	Body *StorageGroup `json:"body,omitempty"`
}

Request Object

func (UpdateGroupRequest) String 

func (o UpdateGroupRequest) String() string

type UpdateGroupResponse 

type UpdateGroupResponse struct {
	GroupId *string `json:"group_id,omitempty"`

	Name *string `json:"name,omitempty"`

	Description *string `json:"description,omitempty"`

	WarmDataUsage *int64 `json:"warm_data_usage,omitempty"`

	DataStoreCount *int64 `json:"data_store_count,omitempty"`

	ColdDataUsage *int64 `json:"cold_data_usage,omitempty"`

	WarmDataRetentionPolicy *string `json:"warm_data_retention_policy,omitempty"`

	ColdDataRetentionPolicy *string `json:"cold_data_retention_policy,omitempty"`

	CreatedTime *string `json:"created_time,omitempty"`

	ModifiedTime *string `json:"modified_time,omitempty"`

	Type           *string `json:"type,omitempty"`
	HttpStatusCode int     `json:"-"`
}

Response Object

func (UpdateGroupResponse) String 

func (o UpdateGroupResponse) String() string

type UpdatePipelineJobRequest 

type UpdatePipelineJobRequest struct {
	Check *bool `json:"check,omitempty"`

	PipelineId string `json:"pipeline_id"`

	Body map[string]interface{} `json:"body,omitempty"`
}

Request Object

func (UpdatePipelineJobRequest) String 

func (o UpdatePipelineJobRequest) String() string

type UpdatePipelineJobResponse 

type UpdatePipelineJobResponse struct {
	PipelineId *string `json:"pipeline_id,omitempty"`

	PipelineState *string `json:"pipeline_state,omitempty"`

	Status *string `json:"status,omitempty"`

	CheckInfo      map[string]interface{} `json:"check_info,omitempty"`
	HttpStatusCode int                    `json:"-"`
}

Response Object

func (UpdatePipelineJobResponse) String 

func (o UpdatePipelineJobResponse) String() string

type UpdateStreamingJobRequest 

type UpdateStreamingJobRequest struct {
	Check *bool `json:"check,omitempty"`

	JobId string `json:"job_id"`

	Body map[string]interface{} `json:"body,omitempty"`
}

Request Object

func (UpdateStreamingJobRequest) String 

func (o UpdateStreamingJobRequest) String() string

type UpdateStreamingJobResponse 

type UpdateStreamingJobResponse struct {
	JobId *string `json:"job_id,omitempty"`

	JobState *string `json:"job_state,omitempty"`

	Status *string `json:"status,omitempty"`

	CheckInfo      map[string]interface{} `json:"check_info,omitempty"`
	HttpStatusCode int                    `json:"-"`
}

Response Object

func (UpdateStreamingJobResponse) String 

func (o UpdateStreamingJobResponse) String() string

type ValidateSqlRequest 

type ValidateSqlRequest struct {
	Body *ValidateSqlRequestBody `json:"body,omitempty"`
}

Request Object

func (ValidateSqlRequest) String 

func (o ValidateSqlRequest) String() string

type ValidateSqlRequestBody 

type ValidateSqlRequestBody struct {
	Sql *string `json:"sql,omitempty"`
}

func (ValidateSqlRequestBody) String 

func (o ValidateSqlRequestBody) String() string

type ValidateSqlResponse 

type ValidateSqlResponse struct {
	Valid          *bool `json:"valid,omitempty"`
	HttpStatusCode int   `json:"-"`
}

Response Object

func (ValidateSqlResponse) String 

func (o ValidateSqlResponse) String() string

type VpcepInfo 

type VpcepInfo struct {
	KafkaBrokerIp string `json:"kafka_broker_ip"`

	VpcepServiceId string `json:"vpcep_service_id"`

	VpcepServiceName string `json:"vpcep_service_name"`

	VpcepClientPort int32 `json:"vpcep_client_port"`
}

VPCEP信息

func (VpcepInfo) String 

func (o VpcepInfo) String() string

type VpcepInfoRsp 

type VpcepInfoRsp struct {
	VpcepServiceId string `json:"vpcep_service_id"`

	VpcepServiceName string `json:"vpcep_service_name"`

	VpcepClientIp *string `json:"vpcep_client_ip,omitempty"`

	VpcepClientPort int32 `json:"vpcep_client_port"`

	KafkaBrokerIp string `json:"kafka_broker_ip"`
}

VPCEP信息

func (VpcepInfoRsp) String 

func (o VpcepInfoRsp) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

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