model

package
v0.1.112 Latest Latest
Warning

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

 Go to latest Published: Aug 29, 2024 License: Apache-2.0, BSD-2-Clause, BSD-3-Clause Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type BatchCreateTagsReq 

type BatchCreateTagsReq struct {

	// 操作标识：仅限于create  - create：批量创建
	Action BatchCreateTagsReqAction `json:"action"`

	// 标签列表。
	Tags []Tag `json:"tags"`
}

func (BatchCreateTagsReq) String 

func (o BatchCreateTagsReq) String() string

type BatchCreateTagsReqAction 

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

func (BatchCreateTagsReqAction) MarshalJSON 

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

func (*BatchCreateTagsReqAction) UnmarshalJSON 

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

func (BatchCreateTagsReqAction) Value 

func (c BatchCreateTagsReqAction) Value() string

type BatchCreateTagsReqActionEnum 

type BatchCreateTagsReqActionEnum struct {
	CREATE BatchCreateTagsReqAction
}

func GetBatchCreateTagsReqActionEnum 

func GetBatchCreateTagsReqActionEnum() BatchCreateTagsReqActionEnum

type BatchCreateTagsRequest 

type BatchCreateTagsRequest struct {

	// 通道ID。
	StreamId string `json:"stream_id"`

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

BatchCreateTagsRequest Request Object

func (BatchCreateTagsRequest) String 

func (o BatchCreateTagsRequest) String() string

type BatchCreateTagsResponse 

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

BatchCreateTagsResponse Response Object

func (BatchCreateTagsResponse) String 

func (o BatchCreateTagsResponse) String() string

type BatchDeleteTagsReq 

type BatchDeleteTagsReq struct {

	// 操作标识：仅限于delete  - delete：批量删除
	Action BatchDeleteTagsReqAction `json:"action"`

	// 标签列表。
	Tags []Tag `json:"tags"`
}

func (BatchDeleteTagsReq) String 

func (o BatchDeleteTagsReq) String() string

type BatchDeleteTagsReqAction 

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

func (BatchDeleteTagsReqAction) MarshalJSON 

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

func (*BatchDeleteTagsReqAction) UnmarshalJSON 

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

func (BatchDeleteTagsReqAction) Value 

func (c BatchDeleteTagsReqAction) Value() string

type BatchDeleteTagsReqActionEnum 

type BatchDeleteTagsReqActionEnum struct {
	DELETE BatchDeleteTagsReqAction
}

func GetBatchDeleteTagsReqActionEnum 

func GetBatchDeleteTagsReqActionEnum() BatchDeleteTagsReqActionEnum

type BatchDeleteTagsRequest 

type BatchDeleteTagsRequest struct {

	// 通道ID。
	StreamId string `json:"stream_id"`

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

BatchDeleteTagsRequest Request Object

func (BatchDeleteTagsRequest) String 

func (o BatchDeleteTagsRequest) String() string

type BatchDeleteTagsResponse 

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

BatchDeleteTagsResponse Response Object

func (BatchDeleteTagsResponse) String 

func (o BatchDeleteTagsResponse) String() string

type BatchStartTransferTaskReq 

type BatchStartTransferTaskReq struct {

	// 转储任务操作，目前支持：  - start：启动转储任务
	Action BatchStartTransferTaskReqAction `json:"action"`

	// 待操作的转储任务列表。
	Tasks []BatchTransferTask `json:"tasks"`
}

func (BatchStartTransferTaskReq) String 

func (o BatchStartTransferTaskReq) String() string

type BatchStartTransferTaskReqAction 

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

func (BatchStartTransferTaskReqAction) MarshalJSON 

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

func (*BatchStartTransferTaskReqAction) UnmarshalJSON 

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

func (BatchStartTransferTaskReqAction) Value 

func (c BatchStartTransferTaskReqAction) Value() string

type BatchStartTransferTaskReqActionEnum 

type BatchStartTransferTaskReqActionEnum struct {
	START BatchStartTransferTaskReqAction
}

func GetBatchStartTransferTaskReqActionEnum 

func GetBatchStartTransferTaskReqActionEnum() BatchStartTransferTaskReqActionEnum

type BatchStartTransferTaskRequest 

type BatchStartTransferTaskRequest struct {

	// 需要查询的通道名称。
	StreamName string `json:"stream_name"`

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

BatchStartTransferTaskRequest Request Object

func (BatchStartTransferTaskRequest) String 

func (o BatchStartTransferTaskRequest) String() string

type BatchStartTransferTaskResponse 

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

BatchStartTransferTaskResponse Response Object

func (BatchStartTransferTaskResponse) String 

func (o BatchStartTransferTaskResponse) String() string

type BatchStopTransferTaskReq 

type BatchStopTransferTaskReq struct {

	// 转储任务操作，目前支持：  - stop：停止转储任务
	Action BatchStopTransferTaskReqAction `json:"action"`

	// 待暂停的转储任务列表。
	Tasks []BatchTransferTask `json:"tasks"`
}

func (BatchStopTransferTaskReq) String 

func (o BatchStopTransferTaskReq) String() string

type BatchStopTransferTaskReqAction 

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

func (BatchStopTransferTaskReqAction) MarshalJSON 

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

func (*BatchStopTransferTaskReqAction) UnmarshalJSON 

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

func (BatchStopTransferTaskReqAction) Value 

func (c BatchStopTransferTaskReqAction) Value() string

type BatchStopTransferTaskReqActionEnum 

type BatchStopTransferTaskReqActionEnum struct {
	STOP BatchStopTransferTaskReqAction
}

func GetBatchStopTransferTaskReqActionEnum 

func GetBatchStopTransferTaskReqActionEnum() BatchStopTransferTaskReqActionEnum

type BatchStopTransferTaskRequest 

type BatchStopTransferTaskRequest struct {

	// 需要查询的通道名称。
	StreamName string `json:"stream_name"`

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

BatchStopTransferTaskRequest Request Object

func (BatchStopTransferTaskRequest) String 

func (o BatchStopTransferTaskRequest) String() string

type BatchStopTransferTaskResponse 

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

BatchStopTransferTaskResponse Response Object

func (BatchStopTransferTaskResponse) String 

func (o BatchStopTransferTaskResponse) String() string

type BatchTransferTask 

type BatchTransferTask struct {

	// 转储任务ID
	Id string `json:"id"`
}

func (BatchTransferTask) String 

func (o BatchTransferTask) String() string

type CloudtableDestinationDescriptorRequest 

type CloudtableDestinationDescriptorRequest struct {

	// 转储任务的名称。  任务名称由英文字母、数字、中划线和下划线组成。长度为1～64个字符。
	TaskName string `json:"task_name"`

	// 在统一身份认证服务(IAM)中创建委托的名称，DIS需要获取IAM委托信息去访问您指定的资源。创建委托的参数设置如下： - 委托类型：云服务 - 云服务：DIS - 持续时间：永久 - “所属区域”为“全局服务”，“项目”为“对象存储服务”对应的“策略”包含“Tenant Administrator”。 如果已经创建过委托，可以使用IAM服务提供的查询委托列表接口，获取有效可用的委托名称。 取值范围：长度不超过64位，且不可配置为空。  如果有在Console控制台使用转储任务，会提示自动创建委托，自动创建的委托名称为：dis_admin_agency
	AgencyName string `json:"agency_name"`

	// 根据用户配置的时间，周期性的将数据导入OBS，若某个时间段内无数据，则此时间段不会生成打包文件。  单位：秒
	DeliverTimeInterval int32 `json:"deliver_time_interval"`

	// 偏移量。  - LATEST：最大偏移量，即获取最新的数据。 - TRIM_HORIZON：最小偏移量，即读取最早的数据。
	ConsumerStrategy *CloudtableDestinationDescriptorRequestConsumerStrategy `json:"consumer_strategy,omitempty"`

	// 存储该通道数据的CloudTable集群名称。  如果选择转储OpenTSDB，则集群必须开启OpenTSDB。
	CloudtableClusterName string `json:"cloudtable_cluster_name"`

	// 存储该通道数据的CloudTable集群ID。  如果选择转储OpenTSDB，则集群必须开启OpenTSDB。
	CloudtableClusterId string `json:"cloudtable_cluster_id"`

	// 转储HBase时必选，表示存储该通道数据的CloudTable集群HBase表名称。
	CloudtableTableName *string `json:"cloudtable_table_name,omitempty"`

	CloudtableSchema *CloudtableSchema `json:"cloudtable_schema,omitempty"`

	// 转储OpenTSDB时必选，与“cloudtable_schema”二选一，表示CloudTable集群OpenTSDB数据的Schema配置。用于将通道内的JSON数据进行格式转换并导入Cloudtable的OpenTSDB。
	OpentsdbSchema *[]OpenTsdbSchema `json:"opentsdb_schema,omitempty"`

	// 转储HBase的rowkey分隔符，用于分隔生成rowKey的用户数据。取值范围：”, ”、 ”. ”、 ”|”、 ”; ”、 ”\\”、 ”-”、 ”_”、 ”~”  缺省值：”.”
	CloudtableRowKeyDelimiter *string `json:"cloudtable_row_key_delimiter,omitempty"`

	// 用户数据转储CloudTable服务失败时，可选择将转储失败的数据备份至OBS服务，此参数为OBS服务的桶名称。
	ObsBackupBucketPath *string `json:"obs_backup_bucket_path,omitempty"`

	// 用户数据转储CloudTable服务失败时，可选择将转储失败的数据备份至OBS服务，此参数为OBS桶下的自定义目录，多级目录可用“/”进行分隔，不可以“/”开头。  取值范围：英文字母、数字和下划线。  最大长度：最大长度为50个字符。  默认配置为空。
	BackupFilePrefix *string `json:"backup_file_prefix,omitempty"`

	// 用户数据导入CloudTable服务失败的失效重试时间。超出此时效，转储CloudTable失败的数据将备份至“OBS桶/ backup_file_prefix /cloudtable_error”或“OBS桶/ backup_file_prefix /opentsdb_error”目录下。  取值范围： 0～7200。  单位：秒。  默认配置为1800。
	RetryDuration *string `json:"retry_duration,omitempty"`
}

CloudtableDestinationDescriptorRequest 转储目的地为CloudTable的参数列表。

func (CloudtableDestinationDescriptorRequest) String 

func (o CloudtableDestinationDescriptorRequest) String() string

type CloudtableDestinationDescriptorRequestConsumerStrategy 

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

func (CloudtableDestinationDescriptorRequestConsumerStrategy) MarshalJSON 

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

func (*CloudtableDestinationDescriptorRequestConsumerStrategy) UnmarshalJSON 

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

func (CloudtableDestinationDescriptorRequestConsumerStrategy) Value 

func (c CloudtableDestinationDescriptorRequestConsumerStrategy) Value() string

type CloudtableDestinationDescriptorRequestConsumerStrategyEnum 

type CloudtableDestinationDescriptorRequestConsumerStrategyEnum struct {
	LATEST       CloudtableDestinationDescriptorRequestConsumerStrategy
	TRIM_HORIZON CloudtableDestinationDescriptorRequestConsumerStrategy
}

func GetCloudtableDestinationDescriptorRequestConsumerStrategyEnum 

func GetCloudtableDestinationDescriptorRequestConsumerStrategyEnum() CloudtableDestinationDescriptorRequestConsumerStrategyEnum

type CloudtableSchema 

type CloudtableSchema struct {

	// CloudTable集群HBase数据rowkey的Schema配置，用于将通道内的JSON数据生成HBase数据的rowkey。  取值范围：1～64。
	RowKey []RowKey `json:"row_key"`

	// CloudTable集群HBase数据列的Schema配置，用于将通道内的JSON数据生成HBase数据的列。  取值范围：1～4096。
	Columns []Column `json:"columns"`
}

CloudtableSchema 转储HBase时必选，与“opentsdb_schema”二选一，表示CloudTable集群HBase数据的Schema配置。用于将通道内的JSON数据进行格式转换并导入Cloudtable的HBase表中。

func (CloudtableSchema) String 

func (o CloudtableSchema) String() string

type Column 

type Column struct {

	// 存储该通道数据的HBase表数据的列族名称。
	ColumnFamilyName string `json:"column_family_name"`

	// 存储该通道数据的HBase表数据的列名称。  取值范围：1～32，只能包含英文字母、数字和下划线。
	ColumnName string `json:"column_name"`

	// 通道内JSON数据的JSON属性名，用于生成HBase数据的列值。
	Value string `json:"value"`

	// 通道内JSON数据的JSON属性的类型名称。
	Type ColumnType `json:"type"`
}

func (Column) String 

func (o Column) String() string

type ColumnType 

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

func (ColumnType) MarshalJSON 

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

func (*ColumnType) UnmarshalJSON 

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

func (ColumnType) Value 

func (c ColumnType) Value() string

type ColumnTypeEnum 

type ColumnTypeEnum struct {
	BIGINT    ColumnType
	DOUBLE    ColumnType
	BOOLEAN   ColumnType
	TIMESTAMP ColumnType
	STRING    ColumnType
	DECIMAL   ColumnType
}

func GetColumnTypeEnum 

func GetColumnTypeEnum() ColumnTypeEnum

type CommitCheckpointReq 

type CommitCheckpointReq struct {

	// APP的名称，用户数据消费程序的唯一标识符，需要先通过创建App接口创建。
	AppName string `json:"app_name"`

	// Checkpoint类型。  - LAST_READ：在数据库中只记录序列号。
	CheckpointType CommitCheckpointReqCheckpointType `json:"checkpoint_type"`

	// 已创建的通道名称。
	StreamName string `json:"stream_name"`

	// 通道的分区标识符。 可定义为如下两种样式： - shardId-0000000000 - 0 比如一个通道有三个分区，那么分区标识符分别为0, 1, 2，或者shardId-0000000000, shardId-0000000001, shardId-0000000002
	PartitionId string `json:"partition_id"`

	// 需要提交的序列号，用来记录该通道的消费检查点，需要保证该序列号处于有效范围内。
	SequenceNumber string `json:"sequence_number"`

	// 用户消费程序端的元数据信息。  元数据信息的最大长度为1000个字符。
	Metadata *string `json:"metadata,omitempty"`
}

func (CommitCheckpointReq) String 

func (o CommitCheckpointReq) String() string

type CommitCheckpointReqCheckpointType 

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

func (CommitCheckpointReqCheckpointType) MarshalJSON 

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

func (*CommitCheckpointReqCheckpointType) UnmarshalJSON 

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

func (CommitCheckpointReqCheckpointType) Value 

func (c CommitCheckpointReqCheckpointType) Value() string

type CommitCheckpointReqCheckpointTypeEnum 

type CommitCheckpointReqCheckpointTypeEnum struct {
	LAST_READ CommitCheckpointReqCheckpointType
}

func GetCommitCheckpointReqCheckpointTypeEnum 

func GetCommitCheckpointReqCheckpointTypeEnum() CommitCheckpointReqCheckpointTypeEnum

type CommitCheckpointRequest 

type CommitCheckpointRequest struct {
	Body *CommitCheckpointReq `json:"body,omitempty"`
}

CommitCheckpointRequest Request Object

func (CommitCheckpointRequest) String 

func (o CommitCheckpointRequest) String() string

type CommitCheckpointResponse 

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

CommitCheckpointResponse Response Object

func (CommitCheckpointResponse) String 

func (o CommitCheckpointResponse) String() string

type CommonDestinationDescriptor 

type CommonDestinationDescriptor struct {

	// 转储任务的名称。  任务名称由英文字母、数字、中划线和下划线组成。长度为1～64个字符。
	TaskName string `json:"task_name"`

	// 在统一身份认证服务(IAM)中创建委托的名称，DIS需要获取IAM委托信息去访问您指定的资源。创建委托的参数设置如下： - 委托类型：云服务 - 云服务：DIS - 持续时间：永久 - “所属区域”为“全局服务”，“项目”为“对象存储服务”对应的“策略”包含“Tenant Administrator”。 如果已经创建过委托，可以使用IAM服务提供的查询委托列表接口，获取有效可用的委托名称。 取值范围：长度不超过64位，且不可配置为空。  如果有在Console控制台使用转储任务，会提示自动创建委托，自动创建的委托名称为：dis_admin_agency
	AgencyName string `json:"agency_name"`

	// 根据用户配置的时间，周期性的将数据导入OBS，若某个时间段内无数据，则此时间段不会生成打包文件。  单位：秒
	DeliverTimeInterval int32 `json:"deliver_time_interval"`

	// 偏移量。  - LATEST：最大偏移量，即获取最新的数据。 - TRIM_HORIZON：最小偏移量，即读取最早的数据。
	ConsumerStrategy *CommonDestinationDescriptorConsumerStrategy `json:"consumer_strategy,omitempty"`
}

CommonDestinationDescriptor 转储任务请求体公共部分。

func (CommonDestinationDescriptor) String 

func (o CommonDestinationDescriptor) String() string

type CommonDestinationDescriptorConsumerStrategy 

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

func (CommonDestinationDescriptorConsumerStrategy) MarshalJSON 

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

func (*CommonDestinationDescriptorConsumerStrategy) UnmarshalJSON 

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

func (CommonDestinationDescriptorConsumerStrategy) Value 

func (c CommonDestinationDescriptorConsumerStrategy) Value() string

type CommonDestinationDescriptorConsumerStrategyEnum 

type CommonDestinationDescriptorConsumerStrategyEnum struct {
	LATEST       CommonDestinationDescriptorConsumerStrategy
	TRIM_HORIZON CommonDestinationDescriptorConsumerStrategy
}

func GetCommonDestinationDescriptorConsumerStrategyEnum 

func GetCommonDestinationDescriptorConsumerStrategyEnum() CommonDestinationDescriptorConsumerStrategyEnum

type ConsumeRecordsRequest 

type ConsumeRecordsRequest struct {

	// 数据游标，需要先通过获取数据游标的接口获取。  取值范围：1~512个字符。  说明：  数据游标有效期为5分钟。
	PartitionCursor string `json:"partition-cursor"`

	// 每个请求获取记录的最大字节数。  注意：  该值如果小于分区中单条记录的大小，会导致一直无法获取到记录。
	MaxFetchBytes *int32 `json:"max_fetch_bytes,omitempty"`
}

ConsumeRecordsRequest Request Object

func (ConsumeRecordsRequest) String 

func (o ConsumeRecordsRequest) String() string

type ConsumeRecordsResponse 

type ConsumeRecordsResponse struct {

	// 下载的记录列表。
	Records *[]Record `json:"records,omitempty"`

	// 下一个迭代器。  说明：  数据游标有效期为5分钟。
	NextPartitionCursor *string `json:"next_partition_cursor,omitempty"`
	HttpStatusCode      int     `json:"-"`
}

ConsumeRecordsResponse Response Object

func (ConsumeRecordsResponse) String 

func (o ConsumeRecordsResponse) String() string

type CreateAppReq 

type CreateAppReq struct {

	// APP的名称，用户数据消费程序的唯一标识符。  应用名称由字母、数字、下划线和中划线组成，长度为1～200个字符。
	AppName string `json:"app_name"`
}

func (CreateAppReq) String 

func (o CreateAppReq) String() string

type CreateAppRequest 

type CreateAppRequest struct {
	Body *CreateAppReq `json:"body,omitempty"`
}

CreateAppRequest Request Object

func (CreateAppRequest) String 

func (o CreateAppRequest) String() string

type CreateAppResponse 

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

CreateAppResponse Response Object

func (CreateAppResponse) String 

func (o CreateAppResponse) String() string

type CreateObsTransferTaskRequest 

type CreateObsTransferTaskRequest struct {

	// 已创建的通道名称。
	StreamName string `json:"stream_name"`

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

CreateObsTransferTaskRequest Request Object

func (CreateObsTransferTaskRequest) String 

func (o CreateObsTransferTaskRequest) String() string

type CreateObsTransferTaskResponse 

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

CreateObsTransferTaskResponse Response Object

func (CreateObsTransferTaskResponse) String 

func (o CreateObsTransferTaskResponse) String() string

type CreateStreamReq 

type CreateStreamReq struct {

	// 通道名称。  通道名称由字母、数字、下划线和中划线组成，长度为1～64字符。
	StreamName string `json:"stream_name"`

	// 分区数量。  分区是DIS数据通道的基本吞吐量单位。
	PartitionCount int32 `json:"partition_count"`

	// 通道类型。  - COMMON：普通通道，表示1MB带宽。 - ADVANCED：高级通道，表示5MB带宽。
	StreamType *CreateStreamReqStreamType `json:"stream_type,omitempty"`

	// 源数据类型。  - BLOB：存储在数据库管理系统中的一组二进制数据。 - JSON：一种开放的文件格式，以易读的文字为基础，用来传输由属性值或者序列性的值组成的数据对象。 - CSV：纯文本形式存储的表格数据，分隔符默认采用逗号。  缺省值：BLOB。
	DataType *CreateStreamReqDataType `json:"data_type,omitempty"`

	// 数据保留时长。  取值范围：24~72。  单位：小时。  空表示使用缺省值。
	DataDuration *int32 `json:"data_duration,omitempty"`

	// 是否开启自动扩缩容。  - true：开启自动扩缩容。 - false：关闭自动扩缩容。  默认不开启。
	AutoScaleEnabled *bool `json:"auto_scale_enabled,omitempty"`

	// 当自动扩缩容启用时，自动缩容的最小分片数。
	AutoScaleMinPartitionCount *int64 `json:"auto_scale_min_partition_count,omitempty"`

	// 当自动扩缩容启用时，自动扩容的最大分片数。
	AutoScaleMaxPartitionCount *int32 `json:"auto_scale_max_partition_count,omitempty"`

	// 用于描述用户JSON、CSV格式的源数据结构，采用Avro Schema的语法描述。
	DataSchema *string `json:"data_schema,omitempty"`

	CsvProperties *CsvProperties `json:"csv_properties,omitempty"`

	// 数据的压缩类型，目前支持：  - snappy  - gzip  - zip  默认不压缩。
	CompressionFormat *CreateStreamReqCompressionFormat `json:"compression_format,omitempty"`

	// 通道标签列表。
	Tags *[]Tag `json:"tags,omitempty"`

	// 通道企业项目列表。
	SysTags *[]SysTag `json:"sys_tags,omitempty"`
}

func (CreateStreamReq) String 

func (o CreateStreamReq) String() string

type CreateStreamReqCompressionFormat 

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

func (CreateStreamReqCompressionFormat) MarshalJSON 

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

func (*CreateStreamReqCompressionFormat) UnmarshalJSON 

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

func (CreateStreamReqCompressionFormat) Value 

func (c CreateStreamReqCompressionFormat) Value() string

type CreateStreamReqCompressionFormatEnum 

type CreateStreamReqCompressionFormatEnum struct {
	SNAPPY CreateStreamReqCompressionFormat
	GZIP   CreateStreamReqCompressionFormat
	ZIP    CreateStreamReqCompressionFormat
}

func GetCreateStreamReqCompressionFormatEnum 

func GetCreateStreamReqCompressionFormatEnum() CreateStreamReqCompressionFormatEnum

type CreateStreamReqDataType 

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

func (CreateStreamReqDataType) MarshalJSON 

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

func (*CreateStreamReqDataType) UnmarshalJSON 

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

func (CreateStreamReqDataType) Value 

func (c CreateStreamReqDataType) Value() string

type CreateStreamReqDataTypeEnum 

type CreateStreamReqDataTypeEnum struct {
	BLOB CreateStreamReqDataType
	JSON CreateStreamReqDataType
	CSV  CreateStreamReqDataType
}

func GetCreateStreamReqDataTypeEnum 

func GetCreateStreamReqDataTypeEnum() CreateStreamReqDataTypeEnum

type CreateStreamReqStreamType 

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

func (CreateStreamReqStreamType) MarshalJSON 

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

func (*CreateStreamReqStreamType) UnmarshalJSON 

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

func (CreateStreamReqStreamType) Value 

func (c CreateStreamReqStreamType) Value() string

type CreateStreamReqStreamTypeEnum 

type CreateStreamReqStreamTypeEnum struct {
	COMMON   CreateStreamReqStreamType
	ADVANCED CreateStreamReqStreamType
}

func GetCreateStreamReqStreamTypeEnum 

func GetCreateStreamReqStreamTypeEnum() CreateStreamReqStreamTypeEnum

type CreateStreamRequest 

type CreateStreamRequest struct {
	Body *CreateStreamReq `json:"body,omitempty"`
}

CreateStreamRequest Request Object

func (CreateStreamRequest) String 

func (o CreateStreamRequest) String() string

type CreateStreamResponse 

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

CreateStreamResponse Response Object

func (CreateStreamResponse) String 

func (o CreateStreamResponse) String() string

type CreateTagReq 

type CreateTagReq struct {
	Tag *Tag `json:"tag"`
}

func (CreateTagReq) String 

func (o CreateTagReq) String() string

type CreateTagRequest 

type CreateTagRequest struct {

	// 通道ID。
	StreamId string `json:"stream_id"`

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

CreateTagRequest Request Object

func (CreateTagRequest) String 

func (o CreateTagRequest) String() string

type CreateTagResponse 

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

CreateTagResponse Response Object

func (CreateTagResponse) String 

func (o CreateTagResponse) String() string

type CreateTransferTaskReq 

type CreateTransferTaskReq struct {

	// 转储任务类型。  - OBS：转储到OBS - MRS：转储到MRS - DLI：转储到DLI - CLOUDTABLE：转储到CloudTable - DWS：转储到DWS
	DestinationType CreateTransferTaskReqDestinationType `json:"destination_type"`

	ObsDestinationDescriptor *ObsDestinationDescriptorRequest `json:"obs_destination_descriptor,omitempty"`
}

func (CreateTransferTaskReq) String 

func (o CreateTransferTaskReq) String() string

type CreateTransferTaskReqDestinationType 

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

func (CreateTransferTaskReqDestinationType) MarshalJSON 

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

func (*CreateTransferTaskReqDestinationType) UnmarshalJSON 

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

func (CreateTransferTaskReqDestinationType) Value 

func (c CreateTransferTaskReqDestinationType) Value() string

type CreateTransferTaskReqDestinationTypeEnum 

type CreateTransferTaskReqDestinationTypeEnum struct {
	OBS CreateTransferTaskReqDestinationType
}

func GetCreateTransferTaskReqDestinationTypeEnum 

func GetCreateTransferTaskReqDestinationTypeEnum() CreateTransferTaskReqDestinationTypeEnum

type CsvProperties 

type CsvProperties struct {

	// 数据分隔符。
	Delimiter *string `json:"delimiter,omitempty"`
}

CsvProperties CSV 格式数据的相关属性，比如分隔符 delimiter

func (CsvProperties) String 

func (o CsvProperties) String() string

type DataPoint 

type DataPoint struct {

	// 时间戳。
	Timestamp *int64 `json:"timestamp,omitempty"`

	// 时间戳对应的监控值。
	Value *int64 `json:"value,omitempty"`
}

DataPoint 监控数据。

func (DataPoint) String 

func (o DataPoint) String() string

type DeleteAppRequest 

type DeleteAppRequest struct {

	// 需要删除的App名称。
	AppName string `json:"app_name"`
}

DeleteAppRequest Request Object

func (DeleteAppRequest) String 

func (o DeleteAppRequest) String() string

type DeleteAppResponse 

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

DeleteAppResponse Response Object

func (DeleteAppResponse) String 

func (o DeleteAppResponse) String() string

type DeleteCheckpointRequest 

type DeleteCheckpointRequest struct {

	// 该Checkpoint所属的通道名称。
	StreamName string `json:"stream_name"`

	// 该Checkpoint关联App名称。
	AppName string `json:"app_name"`

	// Checkpoint类型。  LAST_READ：在数据库中只记录序列号。
	CheckpointType DeleteCheckpointRequestCheckpointType `json:"checkpoint_type"`

	// 该Checkpoint所属的通道分区标识符。  可定义为如下两种样式：  - shardId-0000000000 - 0  比如一个通道有三个分区，那么分区标识符分别为0, 1, 2，或者shardId-0000000000, shardId-0000000001, shardId-0000000002
	PartitionId *string `json:"partition_id,omitempty"`
}

DeleteCheckpointRequest Request Object

func (DeleteCheckpointRequest) String 

func (o DeleteCheckpointRequest) String() string

type DeleteCheckpointRequestCheckpointType 

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

func (DeleteCheckpointRequestCheckpointType) MarshalJSON 

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

func (*DeleteCheckpointRequestCheckpointType) UnmarshalJSON 

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

func (DeleteCheckpointRequestCheckpointType) Value 

func (c DeleteCheckpointRequestCheckpointType) Value() string

type DeleteCheckpointRequestCheckpointTypeEnum 

type DeleteCheckpointRequestCheckpointTypeEnum struct {
	LAST_READ DeleteCheckpointRequestCheckpointType
}

func GetDeleteCheckpointRequestCheckpointTypeEnum 

func GetDeleteCheckpointRequestCheckpointTypeEnum() DeleteCheckpointRequestCheckpointTypeEnum

type DeleteCheckpointResponse 

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

DeleteCheckpointResponse Response Object

func (DeleteCheckpointResponse) String 

func (o DeleteCheckpointResponse) String() string

type DeleteStreamRequest 

type DeleteStreamRequest struct {

	// 需要删除的通道名称。
	StreamName string `json:"stream_name"`
}

DeleteStreamRequest Request Object

func (DeleteStreamRequest) String 

func (o DeleteStreamRequest) String() string

type DeleteStreamResponse 

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

DeleteStreamResponse Response Object

func (DeleteStreamResponse) String 

func (o DeleteStreamResponse) String() string

type DeleteTagRequest 

type DeleteTagRequest struct {

	// 通道ID。
	StreamId string `json:"stream_id"`

	// 标签键。
	Key string `json:"key"`
}

DeleteTagRequest Request Object

func (DeleteTagRequest) String 

func (o DeleteTagRequest) String() string

type DeleteTagResponse 

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

DeleteTagResponse Response Object

func (DeleteTagResponse) String 

func (o DeleteTagResponse) String() string

type DeleteTransferTaskRequest 

type DeleteTransferTaskRequest struct {

	// 已创建的通道的名称。
	StreamName string `json:"stream_name"`

	// 待删除的转储任务名称。
	TaskName string `json:"task_name"`
}

DeleteTransferTaskRequest Request Object

func (DeleteTransferTaskRequest) String 

func (o DeleteTransferTaskRequest) String() string

type DeleteTransferTaskResponse 

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

DeleteTransferTaskResponse Response Object

func (DeleteTransferTaskResponse) String 

func (o DeleteTransferTaskResponse) String() string

type DescribeAppResult 

type DescribeAppResult struct {

	// App的名称。
	AppName *string `json:"app_name,omitempty"`

	// App的唯一标识符。
	AppId *string `json:"app_id,omitempty"`

	// App创建的时间，单位毫秒。
	CreateTime *int64 `json:"create_time,omitempty"`

	// 关联通道列表。
	CommitCheckpointStreamNames *[]string `json:"commit_checkpoint_stream_names,omitempty"`
}

func (DescribeAppResult) String 

func (o DescribeAppResult) String() string

type DliDestinationDescriptorRequest 

type DliDestinationDescriptorRequest struct {

	// 转储任务的名称。  任务名称由英文字母、数字、中划线和下划线组成。长度为1～64个字符。
	TaskName string `json:"task_name"`

	// 在统一身份认证服务(IAM)中创建委托的名称，DIS需要获取IAM委托信息去访问您指定的资源。创建委托的参数设置如下： - 委托类型：云服务 - 云服务：DIS - 持续时间：永久 - “所属区域”为“全局服务”，“项目”为“对象存储服务”对应的“策略”包含“Tenant Administrator”。 如果已经创建过委托，可以使用IAM服务提供的查询委托列表接口，获取有效可用的委托名称。 取值范围：长度不超过64位，且不可配置为空。  如果有在Console控制台使用转储任务，会提示自动创建委托，自动创建的委托名称为：dis_admin_agency
	AgencyName string `json:"agency_name"`

	// 根据用户配置的时间，周期性的将数据导入OBS，若某个时间段内无数据，则此时间段不会生成打包文件。  单位：秒
	DeliverTimeInterval int32 `json:"deliver_time_interval"`

	// 偏移量。  - LATEST：最大偏移量，即获取最新的数据。 - TRIM_HORIZON：最小偏移量，即读取最早的数据。
	ConsumerStrategy *DliDestinationDescriptorRequestConsumerStrategy `json:"consumer_strategy,omitempty"`

	// 存储该通道数据的DLI数据库名称。
	DliDatabaseName string `json:"dli_database_name"`

	// 存储该通道数据的DLI表名称。  说明：  仅支持数据位置为DLI的表，且用户需具有该表的插入权限。
	DliTableName string `json:"dli_table_name"`

	// 临时存储该通道数据的OBS桶名称。
	ObsBucketPath string `json:"obs_bucket_path"`

	// 临时存储该通道数据的OBS桶下的自定义目录，多级目录可用“/”进行分隔，不可以“/”开头。  取值范围：英文字母、数字、下划线和斜杠，最大长度为50个字符。  默认配置为空。
	FilePrefix *string `json:"file_prefix,omitempty"`

	// 用户数据导入DLI失败的失效重试时间。重试时间超过该配置项配置的值，则将转储失败的数据备份至“OBS桶/ file_prefix/dli_error”目录下。 取值范围：0~7200。 单位：秒。 默认配置为1800。 配置为“0”表示DIS服务不会在转储失败时进行重试。
	RetryDuration *string `json:"retry_duration,omitempty"`
}

DliDestinationDescriptorRequest 转储目的地为DLI的参数列表。

func (DliDestinationDescriptorRequest) String 

func (o DliDestinationDescriptorRequest) String() string

type DliDestinationDescriptorRequestConsumerStrategy 

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

func (DliDestinationDescriptorRequestConsumerStrategy) MarshalJSON 

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

func (*DliDestinationDescriptorRequestConsumerStrategy) UnmarshalJSON 

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

func (DliDestinationDescriptorRequestConsumerStrategy) Value 

func (c DliDestinationDescriptorRequestConsumerStrategy) Value() string

type DliDestinationDescriptorRequestConsumerStrategyEnum 

type DliDestinationDescriptorRequestConsumerStrategyEnum struct {
	LATEST       DliDestinationDescriptorRequestConsumerStrategy
	TRIM_HORIZON DliDestinationDescriptorRequestConsumerStrategy
}

func GetDliDestinationDescriptorRequestConsumerStrategyEnum 

func GetDliDestinationDescriptorRequestConsumerStrategyEnum() DliDestinationDescriptorRequestConsumerStrategyEnum

type DwsDestinationDescriptorRequest 

type DwsDestinationDescriptorRequest struct {

	// 转储任务的名称。  任务名称由英文字母、数字、中划线和下划线组成。长度为1～64个字符。
	TaskName string `json:"task_name"`

	// 在统一身份认证服务(IAM)中创建委托的名称，DIS需要获取IAM委托信息去访问您指定的资源。创建委托的参数设置如下： - 委托类型：云服务 - 云服务：DIS - 持续时间：永久 - “所属区域”为“全局服务”，“项目”为“对象存储服务”对应的“策略”包含“Tenant Administrator”。 如果已经创建过委托，可以使用IAM服务提供的查询委托列表接口，获取有效可用的委托名称。 取值范围：长度不超过64位，且不可配置为空。  如果有在Console控制台使用转储任务，会提示自动创建委托，自动创建的委托名称为：dis_admin_agency
	AgencyName string `json:"agency_name"`

	// 根据用户配置的时间，周期性的将数据导入OBS，若某个时间段内无数据，则此时间段不会生成打包文件。  单位：秒
	DeliverTimeInterval int32 `json:"deliver_time_interval"`

	// 偏移量。  - LATEST：最大偏移量，即获取最新的数据。 - TRIM_HORIZON：最小偏移量，即读取最早的数据。
	ConsumerStrategy *DwsDestinationDescriptorRequestConsumerStrategy `json:"consumer_strategy,omitempty"`

	// 存储该通道数据的DWS集群名称。
	DwsClusterName string `json:"dws_cluster_name"`

	// 存储该通道数据的DWS集群ID。
	DwsClusterId string `json:"dws_cluster_id"`

	// 存储该通道数据的DWS数据库名称。
	DwsDatabaseName string `json:"dws_database_name"`

	// 存储该通道数据的DWS数据库模式。
	DwsSchema string `json:"dws_schema"`

	// 存储该通道数据的DWS数据库模式下的数据表。
	DwsTableName string `json:"dws_table_name"`

	// 用户数据的字段分隔符，根据此分隔符分隔用户数据插入DWS数据表的相应列。  取值范围：“，”、“；”和“|”三种字符中的一个。
	DwsDelimiter string `json:"dws_delimiter"`

	// 存储该通道数据的DWS数据库的用户名。
	UserName string `json:"user_name"`

	// 存储该通道数据的DWS数据库的密码。
	UserPassword string `json:"user_password"`

	// 用户在密钥管理服务（简称KMS）创建的用户主密钥名称，用于加密存储DWS数据库的密码。
	KmsUserKeyName string `json:"kms_user_key_name"`

	// 用户在密钥管理服务（简称KMS）创建的用户主密钥ID，用于加密存储DWS数据库的密码。
	KmsUserKeyId string `json:"kms_user_key_id"`

	// 临时存储该通道数据的OBS桶名称。
	ObsBucketPath string `json:"obs_bucket_path"`

	// 临时存储该通道数据的OBS桶下的自定义目录，多级目录可用“/”进行分隔，不可以“/”开头。  取值范围：英文字母、数字、下划线和斜杠，最大长度为50个字符。  默认配置为空。
	FilePrefix *string `json:"file_prefix,omitempty"`

	// 用户数据导入DWS集群失败的重试失效时间。超出此配置项配置的时间，转储DWS失败的数据将备份至“OBS桶/ file_prefix/dws_error”目录下。  取值范围： 0～7200。  单位：秒。  默认配置为1800。
	RetryDuration *string `json:"retry_duration,omitempty"`

	// 指定要转储到DWS表中的列，为null或者为空则默认全列。比如“c1,c2”表示将Schema中c1和c2这两列转储到DWS。  默认为空。
	DwsTableColumns *string `json:"dws_table_columns,omitempty"`

	Options *Options `json:"options,omitempty"`
}

DwsDestinationDescriptorRequest 转储目的地为DWS的参数列表。

func (DwsDestinationDescriptorRequest) String 

func (o DwsDestinationDescriptorRequest) String() string

type DwsDestinationDescriptorRequestConsumerStrategy 

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

func (DwsDestinationDescriptorRequestConsumerStrategy) MarshalJSON 

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

func (*DwsDestinationDescriptorRequestConsumerStrategy) UnmarshalJSON 

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

func (DwsDestinationDescriptorRequestConsumerStrategy) Value 

func (c DwsDestinationDescriptorRequestConsumerStrategy) Value() string

type DwsDestinationDescriptorRequestConsumerStrategyEnum 

type DwsDestinationDescriptorRequestConsumerStrategyEnum struct {
	LATEST       DwsDestinationDescriptorRequestConsumerStrategy
	TRIM_HORIZON DwsDestinationDescriptorRequestConsumerStrategy
}

func GetDwsDestinationDescriptorRequestConsumerStrategyEnum 

func GetDwsDestinationDescriptorRequestConsumerStrategyEnum() DwsDestinationDescriptorRequestConsumerStrategyEnum

type ListAppRequest 

type ListAppRequest struct {

	// 单次请求返回APP列表的最大数量。
	Limit *int32 `json:"limit,omitempty"`

	// 从该app名称开始返回app列表，返回的app列表不包括此app名称。
	StartAppName *string `json:"start_app_name,omitempty"`

	// 返回该通道下的app列表。
	StreamName *string `json:"stream_name,omitempty"`
}

ListAppRequest Request Object

func (ListAppRequest) String 

func (o ListAppRequest) String() string

type ListAppResponse 

type ListAppResponse struct {

	// 是否还有更多满足条件的App。  - true：是。 - false：否。
	HasMoreApp *bool `json:"has_more_app,omitempty"`

	// AppEntry list that meets the current request.
	Apps *[]DescribeAppResult `json:"apps,omitempty"`

	// 满足条件的App总数。
	TotalNumber    *int32 `json:"total_number,omitempty"`
	HttpStatusCode int    `json:"-"`
}

ListAppResponse Response Object

func (ListAppResponse) String 

func (o ListAppResponse) String() string

type ListPoliciesRequest 

type ListPoliciesRequest struct {

	// 通道名称。
	StreamName string `json:"stream_name"`
}

ListPoliciesRequest Request Object

func (ListPoliciesRequest) String 

func (o ListPoliciesRequest) String() string

type ListPoliciesResponse 

type ListPoliciesResponse struct {

	// 通道唯一标识符。
	StreamId *string `json:"stream_id,omitempty"`

	// 通道授权信息列表。
	Rules          *[]PrincipalRule `json:"rules,omitempty"`
	HttpStatusCode int              `json:"-"`
}

ListPoliciesResponse Response Object

func (ListPoliciesResponse) String 

func (o ListPoliciesResponse) String() string

type ListResourceInstancesReq 

type ListResourceInstancesReq struct {

	// 操作标识(仅限于filter，count)  - filter：分页查询 - count：查询总条数，只需按照条件将总条数返回即可
	Action ListResourceInstancesReqAction `json:"action"`

	// 查询记录数(action为count时无此参数)如果action为filter默认为1000，limit最多为1000，不能为负数，最小值为1
	Limit *string `json:"limit,omitempty"`

	// 索引位置, 从offset指定的下一条数据开始查询。 查询第一页数据时，不需要传入此参数，查询后续页码数据时，将查询前一页数据时响应体中的值带入此参数(action为count时无此参数)如果action为filter默认为0，必须为数字，不能为负数
	Offset *string `json:"offset,omitempty"`

	// 返回结果包含该参数中所有标签对应的资源，该参数最多包含10个key，每个key下面的value最多10个，结构体不能缺失，key不能为空或者空字符串。
	Tags *[]Tags `json:"tags,omitempty"`

	// 返回结果包含该参数中任意一个标签对应的资源，该参数最多包含10个key，每个key下面的value最多10个，结构体不能缺失，key不能为空或者空字符串。Key不能重复，同一个key中values不能重复。
	TagsAny *[]Tags `json:"tags_any,omitempty"`

	// 返回结果不包含该参数中所有标签对应的资源，该参数最多包含10个key，每个key下面的value最多10个, 结构体不能缺失，key不能为空或者空字符串。Key不能重复，同一个key中values不能重复。
	NotTags *[]Tags `json:"not_tags,omitempty"`

	// 返回结果不包含该参数中任意一个标签对应的资源，该参数最多包含10个key，每个key下面的value最多10个，结构体不能缺失，key不能为空或者空字符串。Key不能重复，同一个key中values不能重复。
	NotTagsAny *[]Tags `json:"not_tags_any,omitempty"`

	// 搜索字段，key为要匹配的字段，当前仅支持resource_name。value为匹配的值。此字段为固定字典值
	Matches *string `json:"matches,omitempty"`
}

func (ListResourceInstancesReq) String 

func (o ListResourceInstancesReq) String() string

type ListResourceInstancesReqAction 

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

func (ListResourceInstancesReqAction) MarshalJSON 

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

func (*ListResourceInstancesReqAction) UnmarshalJSON 

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

func (ListResourceInstancesReqAction) Value 

func (c ListResourceInstancesReqAction) Value() string

type ListResourceInstancesReqActionEnum 

type ListResourceInstancesReqActionEnum struct {
	FILTER ListResourceInstancesReqAction
	COUNT  ListResourceInstancesReqAction
}

func GetListResourceInstancesReqActionEnum 

func GetListResourceInstancesReqActionEnum() ListResourceInstancesReqActionEnum

type ListResourcesByTagsRequest 

type ListResourcesByTagsRequest struct {
	Body *ListResourceInstancesReq `json:"body,omitempty"`
}

ListResourcesByTagsRequest Request Object

func (ListResourcesByTagsRequest) String 

func (o ListResourcesByTagsRequest) String() string

type ListResourcesByTagsResponse 

type ListResourcesByTagsResponse struct {

	// 操作标识(仅限于filter，count)  - filter：分页查询 - count：查询总条数，只需按照条件将总条数返回即可
	Action *ListResourcesByTagsResponseAction `json:"action,omitempty"`

	// 查询记录数(action为count时无此参数)如果action为filter默认为1000，limit最多为1000，不能为负数，最小值为1
	Limit *string `json:"limit,omitempty"`

	// 索引位置, 从offset指定的下一条数据开始查询。 查询第一页数据时，不需要传入此参数，查询后续页码数据时，将查询前一页数据时响应体中的值带入此参数(action为count时无此参数)如果action为filter默认为0，必须为数字，不能为负数
	Offset *string `json:"offset,omitempty"`

	// 返回结果包含该参数中所有标签对应的资源，该参数最多包含10个key，每个key下面的value最多10个，结构体不能缺失，key不能为空或者空字符串。
	Tags *[]Tags `json:"tags,omitempty"`

	// 返回结果包含该参数中任意一个标签对应的资源，该参数最多包含10个key，每个key下面的value最多10个，结构体不能缺失，key不能为空或者空字符串。Key不能重复，同一个key中values不能重复。
	TagsAny *[]Tags `json:"tags_any,omitempty"`

	// 返回结果不包含该参数中所有标签对应的资源，该参数最多包含10个key，每个key下面的value最多10个, 结构体不能缺失，key不能为空或者空字符串。Key不能重复，同一个key中values不能重复。
	NotTags *[]Tags `json:"not_tags,omitempty"`

	// 返回结果不包含该参数中任意一个标签对应的资源，该参数最多包含10个key，每个key下面的value最多10个，结构体不能缺失，key不能为空或者空字符串。Key不能重复，同一个key中values不能重复。
	NotTagsAny *[]Tags `json:"not_tags_any,omitempty"`

	// 搜索字段，key为要匹配的字段，当前仅支持resource_name。value为匹配的值。此字段为固定字典值
	Matches        *string `json:"matches,omitempty"`
	HttpStatusCode int     `json:"-"`
}

ListResourcesByTagsResponse Response Object

func (ListResourcesByTagsResponse) String 

func (o ListResourcesByTagsResponse) String() string

type ListResourcesByTagsResponseAction 

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

func (ListResourcesByTagsResponseAction) MarshalJSON 

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

func (*ListResourcesByTagsResponseAction) UnmarshalJSON 

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

func (ListResourcesByTagsResponseAction) Value 

func (c ListResourcesByTagsResponseAction) Value() string

type ListResourcesByTagsResponseActionEnum 

type ListResourcesByTagsResponseActionEnum struct {
	FILTER ListResourcesByTagsResponseAction
	COUNT  ListResourcesByTagsResponseAction
}

func GetListResourcesByTagsResponseActionEnum 

func GetListResourcesByTagsResponseActionEnum() ListResourcesByTagsResponseActionEnum

type ListStreamsRequest 

type ListStreamsRequest struct {

	// 单次请求返回通道列表的最大数量。
	Limit *int32 `json:"limit,omitempty"`

	// 从该通道开始返回通道列表，返回的通道列表不包括此通道名称。  如果需要分页查询，第一页查询时不传该字段。返回结果has_more_streams为true时，进行下一页查询，start_stream_name传入第一页查询结果的最后一条通道名称。
	StartStreamName *string `json:"start_stream_name,omitempty"`
}

ListStreamsRequest Request Object

func (ListStreamsRequest) String 

func (o ListStreamsRequest) String() string

type ListStreamsResponse 

type ListStreamsResponse struct {

	// 当前租户所有通道数量。
	TotalNumber *int64 `json:"total_number,omitempty"`

	// 满足当前请求条件的通道名称的列表。
	StreamNames *[]string `json:"stream_names,omitempty"`

	// 是否还有更多满足条件的通道。  - true：是 - false：否
	HasMoreStreams *bool `json:"has_more_streams,omitempty"`

	// 通道列表详情。
	StreamInfoList *[]StreamInfo `json:"stream_info_list,omitempty"`
	HttpStatusCode int           `json:"-"`
}

ListStreamsResponse Response Object

func (ListStreamsResponse) String 

func (o ListStreamsResponse) String() string

type ListTagsRequest 

type ListTagsRequest struct {
}

ListTagsRequest Request Object

func (ListTagsRequest) String 

func (o ListTagsRequest) String() string

type ListTagsResponse 

type ListTagsResponse struct {

	// 标签列表。
	Tags           *[]Tags `json:"tags,omitempty"`
	HttpStatusCode int     `json:"-"`
}

ListTagsResponse Response Object

func (ListTagsResponse) String 

func (o ListTagsResponse) String() string

type ListTransferTasksRequest 

type ListTransferTasksRequest struct {

	// 需要查询的通道名称。
	StreamName string `json:"stream_name"`
}

ListTransferTasksRequest Request Object

func (ListTransferTasksRequest) String 

func (o ListTransferTasksRequest) String() string

type ListTransferTasksResponse 

type ListTransferTasksResponse struct {

	// 转储任务总数。
	TotalNumber *int32 `json:"total_number,omitempty"`

	// 可创建的转储任务配额。
	Quota *int32 `json:"quota,omitempty"`

	// 转储任务列表。
	Tasks          *[]TransferTask `json:"tasks,omitempty"`
	HttpStatusCode int             `json:"-"`
}

ListTransferTasksResponse Response Object

func (ListTransferTasksResponse) String 

func (o ListTransferTasksResponse) String() string

type Metrics 

type Metrics struct {

	// 监控数据。
	DataPoints *[]DataPoint `json:"dataPoints,omitempty"`

	// 监控指标。
	Label *string `json:"label,omitempty"`
}

Metrics 数据对象。

func (Metrics) String 

func (o Metrics) String() string

type MrsDestinationDescriptorRequest 

type MrsDestinationDescriptorRequest struct {

	// 转储任务的名称。  任务名称由英文字母、数字、中划线和下划线组成。长度为1～64个字符。
	TaskName string `json:"task_name"`

	// 在统一身份认证服务(IAM)中创建委托的名称，DIS需要获取IAM委托信息去访问您指定的资源。创建委托的参数设置如下： - 委托类型：云服务 - 云服务：DIS - 持续时间：永久 - “所属区域”为“全局服务”，“项目”为“对象存储服务”对应的“策略”包含“Tenant Administrator”。 如果已经创建过委托，可以使用IAM服务提供的查询委托列表接口，获取有效可用的委托名称。 取值范围：长度不超过64位，且不可配置为空。  如果有在Console控制台使用转储任务，会提示自动创建委托，自动创建的委托名称为：dis_admin_agency
	AgencyName string `json:"agency_name"`

	// 根据用户配置的时间，周期性的将数据导入OBS，若某个时间段内无数据，则此时间段不会生成打包文件。  单位：秒
	DeliverTimeInterval int32 `json:"deliver_time_interval"`

	// 偏移量。  - LATEST：最大偏移量，即获取最新的数据。 - TRIM_HORIZON：最小偏移量，即读取最早的数据。
	ConsumerStrategy *MrsDestinationDescriptorRequestConsumerStrategy `json:"consumer_strategy,omitempty"`

	// 存储该通道数据的MRS集群名称。  说明：  仅支持非Kerberos认证的MRS集群。
	MrsClusterName string `json:"mrs_cluster_name"`

	// 存储该通道数据的MRS集群ID。
	MrsClusterId string `json:"mrs_cluster_id"`

	// 存储该通道数据的MRS集群的HDFS路径。
	MrsHdfsPath string `json:"mrs_hdfs_path"`

	// 临时存储该通道数据的OBS桶下的自定义目录，多级目录可用“/”进行分隔，不可以“/”开头。  取值范围：英文字母、数字、下划线和斜杠，最大长度为50个字符。  默认配置为空。
	FilePrefix *string `json:"file_prefix,omitempty"`

	// 在MRS集群HDFS中存储通道文件的自定义目录，多级目录可用\"/\"进行分隔。  取值范围：0~50个字符。  默认配置为空。
	HdfsPrefixFolder *string `json:"hdfs_prefix_folder,omitempty"`

	// 临时存储该通道数据的OBS桶名称。
	ObsBucketPath string `json:"obs_bucket_path"`

	// 用户数据转储失败的失效重试时间。重试时间超过该配置项配置的值，则将转储失败的数据备份至“OBS桶/ file_prefix/mrs_error”目录下。  取值范围：0~7200。  单位：秒。  默认配置为1800。  配置为“0”表示DIS服务不会在转储失败时进行重试。
	RetryDuration *string `json:"retry_duration,omitempty"`
}

MrsDestinationDescriptorRequest 转储目的地为MRS的参数列表。

func (MrsDestinationDescriptorRequest) String 

func (o MrsDestinationDescriptorRequest) String() string

type MrsDestinationDescriptorRequestConsumerStrategy 

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

func (MrsDestinationDescriptorRequestConsumerStrategy) MarshalJSON 

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

func (*MrsDestinationDescriptorRequestConsumerStrategy) UnmarshalJSON 

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

func (MrsDestinationDescriptorRequestConsumerStrategy) Value 

func (c MrsDestinationDescriptorRequestConsumerStrategy) Value() string

type MrsDestinationDescriptorRequestConsumerStrategyEnum 

type MrsDestinationDescriptorRequestConsumerStrategyEnum struct {
	LATEST       MrsDestinationDescriptorRequestConsumerStrategy
	TRIM_HORIZON MrsDestinationDescriptorRequestConsumerStrategy
}

func GetMrsDestinationDescriptorRequestConsumerStrategyEnum 

func GetMrsDestinationDescriptorRequestConsumerStrategyEnum() MrsDestinationDescriptorRequestConsumerStrategyEnum

type ObsDestinationDescriptorRequest 

type ObsDestinationDescriptorRequest struct {

	// 转储任务的名称。  任务名称由英文字母、数字、中划线和下划线组成。长度为1～64个字符。
	TaskName string `json:"task_name"`

	// 在统一身份认证服务(IAM)中创建委托的名称，DIS需要获取IAM委托信息去访问您指定的资源。创建委托的参数设置如下： - 委托类型：云服务 - 云服务：DIS - 持续时间：永久 - “所属区域”为“全局服务”，“项目”为“对象存储服务”对应的“策略”包含“Tenant Administrator”。 如果已经创建过委托，可以使用IAM服务提供的查询委托列表接口，获取有效可用的委托名称。 取值范围：长度不超过64位，且不可配置为空。  如果有在Console控制台使用转储任务，会提示自动创建委托，自动创建的委托名称为：dis_admin_agency
	AgencyName string `json:"agency_name"`

	// 根据用户配置的时间，周期性的将数据导入OBS，若某个时间段内无数据，则此时间段不会生成打包文件。  单位：秒
	DeliverTimeInterval int32 `json:"deliver_time_interval"`

	// 偏移量。  - LATEST：最大偏移量，即获取最新的数据。 - TRIM_HORIZON：最小偏移量，即读取最早的数据。
	ConsumerStrategy *ObsDestinationDescriptorRequestConsumerStrategy `json:"consumer_strategy,omitempty"`

	// 在OBS中存储通道文件的自定义目录，多级目录可用“/”进行分隔，不可以“/”开头。  取值范围：英文字母、数字、下划线和斜杠，最大长度为50个字符。  默认配置为空。
	FilePrefix *string `json:"file_prefix,omitempty"`

	// 将转储文件的生成时间使用“yyyy/MM/dd/HH/mm”格式生成分区字符串，用来定义写到OBS的Object文件所在的目录层次结构。  - N/A：置空，不使用日期时间目录。 - yyyy：年 - yyyy/MM：年/ - yyyy/MM/dd：年/月/日 - yyyy/MM/dd/HH：年/月/日/时 - yyyy/MM/dd/HH/mm：年/月/日/时/分  例如：2017/11/10/14/49，目录结构就是“2017 > 11 > 10 > 14 > 49”，“2017”表示最外层文件夹。  默认值：空  说明：  数据转储成功后，存储的目录结构为“obs_bucket_path/file_prefix/partition_format”。
	PartitionFormat *ObsDestinationDescriptorRequestPartitionFormat `json:"partition_format,omitempty"`

	// 存储该通道数据的OBS桶名称。
	ObsBucketPath string `json:"obs_bucket_path"`

	// 转储文件格式。  - text：转储目标格式为TEXT，缺省值 - parquet：转储目标格式为Parquet - carbon：转储目标格式为Carbon  说明：  “源数据类型”为“JSON”，“转储服务类型”为“OBS”时才可选择“parquet”或“carbon”格式。
	DestinationFileType *ObsDestinationDescriptorRequestDestinationFileType `json:"destination_file_type,omitempty"`

	ProcessingSchema *ProcessingSchema `json:"processing_schema,omitempty"`

	// 转储文件的记录分隔符，用于分隔写入转储文件的用户数据。  取值范围：  - 逗号 \",\"，默认值 - 分号 \";\" - 竖线 \"|\" - 换行符 \"\\n\"
	RecordDelimiter *string `json:"record_delimiter,omitempty"`
}

ObsDestinationDescriptorRequest 转储目的地为OBS的参数列表。

func (ObsDestinationDescriptorRequest) String 

func (o ObsDestinationDescriptorRequest) String() string

type ObsDestinationDescriptorRequestConsumerStrategy 

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

func (ObsDestinationDescriptorRequestConsumerStrategy) MarshalJSON 

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

func (*ObsDestinationDescriptorRequestConsumerStrategy) UnmarshalJSON 

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

func (ObsDestinationDescriptorRequestConsumerStrategy) Value 

func (c ObsDestinationDescriptorRequestConsumerStrategy) Value() string

type ObsDestinationDescriptorRequestConsumerStrategyEnum 

type ObsDestinationDescriptorRequestConsumerStrategyEnum struct {
	LATEST       ObsDestinationDescriptorRequestConsumerStrategy
	TRIM_HORIZON ObsDestinationDescriptorRequestConsumerStrategy
}

func GetObsDestinationDescriptorRequestConsumerStrategyEnum 

func GetObsDestinationDescriptorRequestConsumerStrategyEnum() ObsDestinationDescriptorRequestConsumerStrategyEnum

type ObsDestinationDescriptorRequestDestinationFileType 

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

func (ObsDestinationDescriptorRequestDestinationFileType) MarshalJSON 

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

func (*ObsDestinationDescriptorRequestDestinationFileType) UnmarshalJSON 

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

func (ObsDestinationDescriptorRequestDestinationFileType) Value 

func (c ObsDestinationDescriptorRequestDestinationFileType) Value() string

type ObsDestinationDescriptorRequestDestinationFileTypeEnum 

type ObsDestinationDescriptorRequestDestinationFileTypeEnum struct {
	TEXT    ObsDestinationDescriptorRequestDestinationFileType
	PARQUET ObsDestinationDescriptorRequestDestinationFileType
	CARBON  ObsDestinationDescriptorRequestDestinationFileType
}

func GetObsDestinationDescriptorRequestDestinationFileTypeEnum 

func GetObsDestinationDescriptorRequestDestinationFileTypeEnum() ObsDestinationDescriptorRequestDestinationFileTypeEnum

type ObsDestinationDescriptorRequestPartitionFormat 

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

func (ObsDestinationDescriptorRequestPartitionFormat) MarshalJSON 

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

func (*ObsDestinationDescriptorRequestPartitionFormat) UnmarshalJSON 

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

func (ObsDestinationDescriptorRequestPartitionFormat) Value 

func (c ObsDestinationDescriptorRequestPartitionFormat) Value() string

type ObsDestinationDescriptorRequestPartitionFormatEnum 

type ObsDestinationDescriptorRequestPartitionFormatEnum struct {
	YYYY             ObsDestinationDescriptorRequestPartitionFormat
	YYYY_MM          ObsDestinationDescriptorRequestPartitionFormat
	YYYY_MM_DD       ObsDestinationDescriptorRequestPartitionFormat
	YYYY_MM_DD_HH    ObsDestinationDescriptorRequestPartitionFormat
	YYYY_MM_DD_HH_MM ObsDestinationDescriptorRequestPartitionFormat
}

func GetObsDestinationDescriptorRequestPartitionFormatEnum 

func GetObsDestinationDescriptorRequestPartitionFormatEnum() ObsDestinationDescriptorRequestPartitionFormatEnum

type OpenTsdbMetric 

type OpenTsdbMetric struct {

	// - Constant表示metric为常量value的值。 - String表示metric为通道内用户数据对应JSON属性的取值，且该JOSN属性的取值为String。
	Type OpenTsdbMetricType `json:"type"`

	// 常量或通道内用户数据的JSON属性名称。  取值范围：1～32，只能包含英文字母、数字和点。
	Value string `json:"value"`
}

func (OpenTsdbMetric) String 

func (o OpenTsdbMetric) String() string

type OpenTsdbMetricType 

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

func (OpenTsdbMetricType) MarshalJSON 

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

func (*OpenTsdbMetricType) UnmarshalJSON 

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

func (OpenTsdbMetricType) Value 

func (c OpenTsdbMetricType) Value() string

type OpenTsdbMetricTypeEnum 

type OpenTsdbMetricTypeEnum struct {
	CONSTANT OpenTsdbMetricType
	STRING   OpenTsdbMetricType
}

func GetOpenTsdbMetricTypeEnum 

func GetOpenTsdbMetricTypeEnum() OpenTsdbMetricTypeEnum

type OpenTsdbSchema 

type OpenTsdbSchema struct {

	// CloudTable集群OpenTSDB数据metric的Schema配置，用于将通道内的JSON数据进行格式转换生成OpenTSDB数据的metric。
	Metric []OpenTsdbMetric `json:"metric"`

	Timestamp *OpenTsdbTimestamp `json:"timestamp"`

	Value *OpenTsdbValue `json:"value"`

	// CloudTable集群OpenTSDB数据tags的Schema配置，用于将通道内的JSON数据进行格式转换生成OpenTSDB数据的tags。
	Tags []OpenTsdbTags `json:"tags"`
}

OpenTsdbSchema 转储OpenTSDB时必选，与“cloudtable_schema”二选一，表示CloudTable集群OpenTSDB数据的Schema配置。用于将通道内的JSON数据进行格式转换并导入Cloudtable的OpenTSDB。

func (OpenTsdbSchema) String 

func (o OpenTsdbSchema) String() string

type OpenTsdbTags 

type OpenTsdbTags struct {

	// 存储该通道数据的OpenTSDB数据的tag名称。  取值范围：1～32，只能包含英文字母、数字和下划线。
	Name string `json:"name"`

	// 通道内用户JSON数据对应JSON属性的类型名称。  取值范围：  - Bigint - Double - Boolean - Timestamp - String - Decimal
	Type string `json:"type"`

	// 常量或通道内用户数据的JSON属性名称。  取值范围：1～32，只能包含英文字母、数字和下划线。
	Value string `json:"value"`
}

func (OpenTsdbTags) String 

func (o OpenTsdbTags) String() string

type OpenTsdbTimestamp 

type OpenTsdbTimestamp struct {

	// - Timestamp类型表示通道内用户数据对应JSON属性的取值为Timestamp类型，不需要进行数据格式转换就可以生成OpenTSDB的timestamp。 - String类型表示通道内用户数据对应JSON属性的取值为Date格式，需要进行数据格式转换才能生成OpenTSDB的timestamp。
	Type string `json:"type"`

	// 通道内用户数据的JSON属性名称。  取值范围：1～32，只能包含英文字母、数字和下划线。
	Value string `json:"value"`

	// “type”为“String”类型时必选。表示通道内用户数据对应JSON属性的取值为Date格式，需要根据format字段进行数据格式转换生成OpenTSDB的timestamp。  取值范围：  - yyyy/MM/dd HH:mm:ss - MM/dd/yyyy HH:mm:ss - dd/MM/yyyy HH:mm:ss - yyyy-MM-dd HH:mm:ss - MM-dd-yyyy HH:mm:ss - dd-MM-yyyy HH:mm:ss
	Format string `json:"format"`
}

OpenTsdbTimestamp CloudTable集群OpenTSDB 数据timestamp的Schema配置，用于将通道内的JSON数据进行格式转换生成OpenTSDB数据的timestamp。

func (OpenTsdbTimestamp) String 

func (o OpenTsdbTimestamp) String() string

type OpenTsdbValue 

type OpenTsdbValue struct {

	// 通道内用户JSON数据对应JSON属性的类型名称。  取值范围：  - Bigint - Double - Boolean - Timestamp - String - Decimal
	Type string `json:"type"`

	// 常量或通道内用户数据的JSON属性名称。  取值范围：1～32，只能包含英文字母、数字和下划线。
	Value string `json:"value"`
}

OpenTsdbValue CloudTable集群OpenTSDB 数据value的Schema配置，用于将通道内的JSON数据进行格式转换生成OpenTSDB 数据的value。

func (OpenTsdbValue) String 

func (o OpenTsdbValue) String() string

type Options 

type Options struct {

	// 数据入库时，数据源文件中某行的最后一个字段缺失时，请选择是直接将字段设为Null，还是在错误表中报错提示。  取值范围：   - true/on - false/off  缺省值：false/off
	FillMissingFields *OptionsFillMissingFields `json:"fill_missing_fields,omitempty"`

	// 数据源文件中的字段比外表定义列数多时，是否忽略多出的列。该参数只在数据导入过程中使用。  取值范围：  - true/on - false/off  缺省值：false/off
	IgnoreExtraData *OptionsIgnoreExtraData `json:"ignore_extra_data,omitempty"`

	// 导入非法字符容错参数。是将非法字符按照转换规则转换后入库，还是报错中止导入。  取值范围：  - true/on - false/off  缺省值：false/off
	CompatibleIllegalChars *OptionsCompatibleIllegalChars `json:"compatible_illegal_chars,omitempty"`

	// 指定本次数据导入允许出现的数据格式错误个数，当导入过程中出现的数据格式错误未达到限定值时，本次数据导入可以成功。  取值范围：  - 整型值 - unlimited（无限制）  缺省值为0，有错误信息立即返回。
	RejectLimit *string `json:"reject_limit,omitempty"`

	// 用于记录数据格式错误信息的错误表表名。并行导入结束后查询此错误信息表，能够获取详细的错误信息。
	ErrorTableName *string `json:"error_table_name,omitempty"`
}

Options DWS容错性选项（用于指定外表数据的各类参数）。

func (Options) String 

func (o Options) String() string

type OptionsCompatibleIllegalChars 

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

func (OptionsCompatibleIllegalChars) MarshalJSON 

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

func (*OptionsCompatibleIllegalChars) UnmarshalJSON 

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

func (OptionsCompatibleIllegalChars) Value 

func (c OptionsCompatibleIllegalChars) Value() string

type OptionsCompatibleIllegalCharsEnum 

type OptionsCompatibleIllegalCharsEnum struct {
	TRUE_ON   OptionsCompatibleIllegalChars
	FALSE_OFF OptionsCompatibleIllegalChars
}

func GetOptionsCompatibleIllegalCharsEnum 

func GetOptionsCompatibleIllegalCharsEnum() OptionsCompatibleIllegalCharsEnum

type OptionsFillMissingFields 

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

func (OptionsFillMissingFields) MarshalJSON 

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

func (*OptionsFillMissingFields) UnmarshalJSON 

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

func (OptionsFillMissingFields) Value 

func (c OptionsFillMissingFields) Value() string

type OptionsFillMissingFieldsEnum 

type OptionsFillMissingFieldsEnum struct {
	TRUE_ON   OptionsFillMissingFields
	FALSE_OFF OptionsFillMissingFields
}

func GetOptionsFillMissingFieldsEnum 

func GetOptionsFillMissingFieldsEnum() OptionsFillMissingFieldsEnum

type OptionsIgnoreExtraData 

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

func (OptionsIgnoreExtraData) MarshalJSON 

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

func (*OptionsIgnoreExtraData) UnmarshalJSON 

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

func (OptionsIgnoreExtraData) Value 

func (c OptionsIgnoreExtraData) Value() string

type OptionsIgnoreExtraDataEnum 

type OptionsIgnoreExtraDataEnum struct {
	TRUE_ON   OptionsIgnoreExtraData
	FALSE_OFF OptionsIgnoreExtraData
}

func GetOptionsIgnoreExtraDataEnum 

func GetOptionsIgnoreExtraDataEnum() OptionsIgnoreExtraDataEnum

type PartitionResult 

type PartitionResult struct {

	// 分区的当前状态。  - CREATING：创建中 - ACTIVE：可用 - DELETED：删除中 - EXPIRED：已过期
	Status *PartitionResultStatus `json:"status,omitempty"`

	// 分区的唯一标识符。
	PartitionId *string `json:"partition_id,omitempty"`

	// 分区的可能哈希键值范围。
	HashRange *string `json:"hash_range,omitempty"`

	// 分区的序列号范围。
	SequenceNumberRange *string `json:"sequence_number_range,omitempty"`

	// 父分区。
	ParentPartitions *string `json:"parent_partitions,omitempty"`
}

func (PartitionResult) String 

func (o PartitionResult) String() string

type PartitionResultStatus 

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

func (PartitionResultStatus) MarshalJSON 

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

func (*PartitionResultStatus) UnmarshalJSON 

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

func (PartitionResultStatus) Value 

func (c PartitionResultStatus) Value() string

type PartitionResultStatusEnum 

type PartitionResultStatusEnum struct {
	CREATING PartitionResultStatus
	ACTIVE   PartitionResultStatus
	DELETED  PartitionResultStatus
	EXPIRED  PartitionResultStatus
}

func GetPartitionResultStatusEnum 

func GetPartitionResultStatusEnum() PartitionResultStatusEnum

type PrincipalRule 

type PrincipalRule struct {

	// 授权用户ID。
	Principal *string `json:"principal,omitempty"`

	// 授权用户名。  如果授权给租户下的所有子用户，格式为：domainName.*；如果授权给租户下的指定子用户，则格式为：domainName.userName
	PrincipalName *string `json:"principal_name,omitempty"`

	// 授权操作类型。  - putRecords：上传数据。 - getRecords：下载数据。
	ActionType *PrincipalRuleActionType `json:"action_type,omitempty"`

	// 授权影响类型。  - accept：允许该授权操作。
	Effect *PrincipalRuleEffect `json:"effect,omitempty"`
}

func (PrincipalRule) String 

func (o PrincipalRule) String() string

type PrincipalRuleActionType 

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

func (PrincipalRuleActionType) MarshalJSON 

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

func (*PrincipalRuleActionType) UnmarshalJSON 

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

func (PrincipalRuleActionType) Value 

func (c PrincipalRuleActionType) Value() string

type PrincipalRuleActionTypeEnum 

type PrincipalRuleActionTypeEnum struct {
	PUT_RECORDS PrincipalRuleActionType
	GET_RECORDS PrincipalRuleActionType
}

func GetPrincipalRuleActionTypeEnum 

func GetPrincipalRuleActionTypeEnum() PrincipalRuleActionTypeEnum

type PrincipalRuleEffect 

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

func (PrincipalRuleEffect) MarshalJSON 

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

func (*PrincipalRuleEffect) UnmarshalJSON 

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

func (PrincipalRuleEffect) Value 

func (c PrincipalRuleEffect) Value() string

type PrincipalRuleEffectEnum 

type PrincipalRuleEffectEnum struct {
	ACCEPT PrincipalRuleEffect
}

func GetPrincipalRuleEffectEnum 

func GetPrincipalRuleEffectEnum() PrincipalRuleEffectEnum

type ProcessingSchema 

type ProcessingSchema struct {

	// 源数据时间戳的属性名称。
	TimestampName string `json:"timestamp_name"`

	// 源数据时间戳的类型。  - String - Timestamp：Long类型的13位时间戳
	TimestampType string `json:"timestamp_type"`

	// 源数据时间戳的类型为String时必选，用于根据时间戳格式生成OBS的时间目录。
	TimestampFormat *string `json:"timestamp_format,omitempty"`
}

ProcessingSchema 根据源数据的时间戳和已配置的\"partition_format\"生成对应的转储时间目录。将源数据的时间戳使用“yyyy/MM/dd/HH/mm”格式生成分区字符串，用来定义写到OBS的Object文件所在的目录层次结构。

func (ProcessingSchema) String 

func (o ProcessingSchema) String() string

type PutRecordsRequest 

type PutRecordsRequest struct {

	// 已创建的通道名称。
	StreamName string `json:"stream_name"`

	// 通道唯一标识符。  当使用stream_name没有找到对应通道且stream_id不为空时，会使用stream_id去查找通道。  说明：  上传数据到被授权的通道时，必须配置此参数。
	StreamId *string `json:"stream_id,omitempty"`

	// 待上传的记录列表。
	Records []PutRecordsRequestEntry `json:"records"`
}

func (PutRecordsRequest) String 

func (o PutRecordsRequest) String() string

type PutRecordsRequestEntry 

type PutRecordsRequestEntry struct {

	// 需要上传的数据。  上传的数据为序列化之后的二进制数据（Base64编码后的字符串）。  比如需要上传字符串“data”，“data”经过Base64编码之后是“ZGF0YQ==”。
	Data string `json:"data"`

	// 用于明确数据需要写入分区的哈希值，此哈希值将覆盖“partition_key”的哈希值。  取值范围：0~long.max
	ExplicitHashKey *string `json:"explicit_hash_key,omitempty"`

	// 通道的分区标识符。 可定义为如下两种样式： - shardId-0000000000 - 0  比如一个通道有三个分区，那么分区标识符分别为0, 1, 2，或者shardId-0000000000, shardId-0000000001, shardId-0000000002
	PartitionId *string `json:"partition_id,omitempty"`

	// 数据将写入的分区。  说明：  如果传了partition_id参数，则优先使用partition_id参数。如果partition_id没有传，则使用partition_key。
	PartitionKey *string `json:"partition_key,omitempty"`
}

func (PutRecordsRequestEntry) String 

func (o PutRecordsRequestEntry) String() string

type PutRecordsResultEntry 

type PutRecordsResultEntry struct {

	// 数据上传到的分区ID。
	PartitionId *string `json:"partition_id,omitempty"`

	// 数据上传到的序列号。序列号是每个记录的唯一标识符。序列号由DIS在数据生产者调用PutRecords操作以添加数据到DIS数据通道时DIS服务自动分配的。同一分区键的序列号通常会随时间变化增加。PutRecords请求之间的时间段越长，序列号越大。
	SequenceNumber *string `json:"sequence_number,omitempty"`

	// 错误码。
	ErrorCode *string `json:"error_code,omitempty"`

	// 错误消息。
	ErrorMessage *string `json:"error_message,omitempty"`
}

func (PutRecordsResultEntry) String 

func (o PutRecordsResultEntry) String() string

type Record 

type Record struct {

	// 用户上传数据时设置的partition_key。  说明：  上传数据时，如果传了partition_key参数，则下载数据时可返回此参数。如果上传数据时，未传partition_key参数，而是传入partition_id，则不返回partition_key。
	PartitionKey *string `json:"partition_key,omitempty"`

	// 该条数据的序列号。
	SequenceNumber *string `json:"sequence_number,omitempty"`

	// 下载的数据。  下载的数据为序列化之后的二进制数据（Base64编码后的字符串）。  比如下载数据接口返回的数据是“ZGF0YQ==”，“ZGF0YQ==”经过Base64解码之后是“data”。
	Data *string `json:"data,omitempty"`

	// 记录写入DIS的时间戳。
	Timestamp *int64 `json:"timestamp,omitempty"`

	// 时间戳类型。  - CreateTime：创建时间。
	TimestampType *string `json:"timestamp_type,omitempty"`
}

func (Record) String 

func (o Record) String() string

type RowKey 

type RowKey struct {

	// 通道内JSON数据的JSON属性名，用于生成HBase数据的rowkey。
	Value string `json:"value"`

	// 通道内JSON数据的JSON属性的类型名称。
	Type RowKeyType `json:"type"`
}

func (RowKey) String 

func (o RowKey) String() string

type RowKeyType 

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

func (RowKeyType) MarshalJSON 

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

func (*RowKeyType) UnmarshalJSON 

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

func (RowKeyType) Value 

func (c RowKeyType) Value() string

type RowKeyTypeEnum 

type RowKeyTypeEnum struct {
	BIGINT    RowKeyType
	DOUBLE    RowKeyType
	BOOLEAN   RowKeyType
	TIMESTAMP RowKeyType
	STRING    RowKeyType
	DECIMAL   RowKeyType
}

func GetRowKeyTypeEnum 

func GetRowKeyTypeEnum() RowKeyTypeEnum

type SendRecordsRequest 

type SendRecordsRequest struct {
	Body *PutRecordsRequest `json:"body,omitempty"`
}

SendRecordsRequest Request Object

func (SendRecordsRequest) String 

func (o SendRecordsRequest) String() string

type SendRecordsResponse 

type SendRecordsResponse struct {

	// 上传失败的数据数量。
	FailedRecordCount *int32 `json:"failed_record_count,omitempty"`

	// 上传结果列表。
	Records        *[]PutRecordsResultEntry `json:"records,omitempty"`
	HttpStatusCode int                      `json:"-"`
}

SendRecordsResponse Response Object

func (SendRecordsResponse) String 

func (o SendRecordsResponse) String() string

type ShowAppRequest 

type ShowAppRequest struct {

	// 需要查询的App名称。
	AppName string `json:"app_name"`
}

ShowAppRequest Request Object

func (ShowAppRequest) String 

func (o ShowAppRequest) String() string

type ShowAppResponse 

type ShowAppResponse struct {

	// App的名称。
	AppName *string `json:"app_name,omitempty"`

	// App的唯一标识符。
	AppId *string `json:"app_id,omitempty"`

	// App创建的时间，单位毫秒。
	CreateTime *int64 `json:"create_time,omitempty"`

	// 关联通道列表。
	CommitCheckpointStreamNames *[]string `json:"commit_checkpoint_stream_names,omitempty"`
	HttpStatusCode              int       `json:"-"`
}

ShowAppResponse Response Object

func (ShowAppResponse) String 

func (o ShowAppResponse) String() string

type ShowCheckpointRequest 

type ShowCheckpointRequest struct {

	// 该Checkpoint所属的通道名称。
	StreamName string `json:"stream_name"`

	// 该Checkpoint所属的通道分区标识符。  可定义为如下两种样式：  - shardId-0000000000 - 0  比如一个通道有三个分区，那么分区标识符分别为0, 1, 2，或者shardId-0000000000, shardId-0000000001, shardId-0000000002
	PartitionId string `json:"partition_id"`

	// 该Checkpoint关联App名称。
	AppName string `json:"app_name"`

	// Checkpoint类型。  - LAST_READ：在数据库中只记录序列号。
	CheckpointType ShowCheckpointRequestCheckpointType `json:"checkpoint_type"`
}

ShowCheckpointRequest Request Object

func (ShowCheckpointRequest) String 

func (o ShowCheckpointRequest) String() string

type ShowCheckpointRequestCheckpointType 

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

func (ShowCheckpointRequestCheckpointType) MarshalJSON 

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

func (*ShowCheckpointRequestCheckpointType) UnmarshalJSON 

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

func (ShowCheckpointRequestCheckpointType) Value 

func (c ShowCheckpointRequestCheckpointType) Value() string

type ShowCheckpointRequestCheckpointTypeEnum 

type ShowCheckpointRequestCheckpointTypeEnum struct {
	LAST_READ ShowCheckpointRequestCheckpointType
}

func GetShowCheckpointRequestCheckpointTypeEnum 

func GetShowCheckpointRequestCheckpointTypeEnum() ShowCheckpointRequestCheckpointTypeEnum

type ShowCheckpointResponse 

type ShowCheckpointResponse struct {

	// 序列号，用来记录该通道的消费检查点。
	SequenceNumber *string `json:"sequence_number,omitempty"`

	// 用户消费程序端的元数据信息。
	Metadata       *string `json:"metadata,omitempty"`
	HttpStatusCode int     `json:"-"`
}

ShowCheckpointResponse Response Object

func (ShowCheckpointResponse) String 

func (o ShowCheckpointResponse) String() string

type ShowConsumerStateRequest 

type ShowConsumerStateRequest struct {

	// 需要查询的App名称。
	AppName string `json:"app_name"`

	// 需要查询的通道名称。
	StreamName string `json:"stream_name"`

	// 单次请求返回的最大分区数。最小值是1，最大值是1000；默认值是100。
	Limit *int32 `json:"limit,omitempty"`

	// 从该分区值开始返回分区列表，返回的分区列表不包括此分区。
	StartPartitionId *string `json:"start_partition_id,omitempty"`

	// Checkpoint类型。  - LAST_READ：在数据库中只记录序列号。
	CheckpointType ShowConsumerStateRequestCheckpointType `json:"checkpoint_type"`
}

ShowConsumerStateRequest Request Object

func (ShowConsumerStateRequest) String 

func (o ShowConsumerStateRequest) String() string

type ShowConsumerStateRequestCheckpointType 

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

func (ShowConsumerStateRequestCheckpointType) MarshalJSON 

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

func (*ShowConsumerStateRequestCheckpointType) UnmarshalJSON 

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

func (ShowConsumerStateRequestCheckpointType) Value 

func (c ShowConsumerStateRequestCheckpointType) Value() string

type ShowConsumerStateRequestCheckpointTypeEnum 

type ShowConsumerStateRequestCheckpointTypeEnum struct {
	LAST_READ ShowConsumerStateRequestCheckpointType
}

func GetShowConsumerStateRequestCheckpointTypeEnum 

func GetShowConsumerStateRequestCheckpointTypeEnum() ShowConsumerStateRequestCheckpointTypeEnum

type ShowConsumerStateResponse 

type ShowConsumerStateResponse struct {

	// App的名称。
	AppName *string `json:"app_name,omitempty"`

	// App的唯一标识符。
	AppId *string `json:"app_id,omitempty"`

	// App创建的时间，单位毫秒。
	CreateTime *int64 `json:"create_time,omitempty"`

	// 关联通道列表。
	CommitCheckpointStreamNames *[]string `json:"commit_checkpoint_stream_names,omitempty"`
	HttpStatusCode              int       `json:"-"`
}

ShowConsumerStateResponse Response Object

func (ShowConsumerStateResponse) String 

func (o ShowConsumerStateResponse) String() string

type ShowCursorRequest 

type ShowCursorRequest struct {

	// 已创建的通道名称。
	StreamName string `json:"stream-name"`

	// 通道的分区标识符。  可定义为如下两种样式：  - shardId-0000000000 - 0  比如一个通道有三个分区，那么分区标识符分别为0, 1, 2，或者shardId-0000000000, shardId-0000000001, shardId-0000000002
	PartitionId string `json:"partition-id"`

	// 游标类型。  - AT_SEQUENCE_NUMBER：从特定序列号（即starting-sequence-number定义的序列号）所在的记录开始读取数据。此类型为默认游标类型。  - AFTER_SEQUENCE_NUMBER：从特定序列号（即starting-sequence-number定义的序列号）后的记录开始读取数据。  - TRIM_HORIZON：从最早被存储至分区的有效记录开始读取。例如，某租户使用DIS的通道，分别上传了三条数据A1，A2，A3。N天后（设定A1已过期，A2和A3仍在有效期范围内），该租户需要下载此三条数据，并选择了TRIM_HORIZON这种下载方式。那么用户可下载的数据将从A2开始读取。  - LATEST：从分区中的最新记录开始读取，此设置可以保证你总是读到分区中最新记录。  - AT_TIMESTAMP：从特定时间戳（即timestamp定义的时间戳）开始读取。
	CursorType *ShowCursorRequestCursorType `json:"cursor-type,omitempty"`

	// 序列号。序列号是每个记录的唯一标识符。序列号由DIS在数据生产者调用PutRecords操作以添加数据到DIS数据通道时DIS服务自动分配的。同一分区键的序列号通常会随时间变化增加。PutRecords请求之间的时间段越长，序列号越大。  序列号与游标类型AT_SEQUENCE_NUMBER和AFTER_SEQUENCE_NUMBER强相关，二者共同确定读取数据的位置。  取值范围：0~9223372036854775807。
	StartingSequenceNumber *string `json:"starting-sequence-number,omitempty"`

	// 开始读取数据记录的时间戳，与游标类型AT_TIMESTAMP强相关，二者共同确定读取数据的位置。  说明：  此时间戳精确到毫秒。
	Timestamp *int64 `json:"timestamp,omitempty"`
}

ShowCursorRequest Request Object

func (ShowCursorRequest) String 

func (o ShowCursorRequest) String() string

type ShowCursorRequestCursorType 

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

func (ShowCursorRequestCursorType) MarshalJSON 

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

func (*ShowCursorRequestCursorType) UnmarshalJSON 

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

func (ShowCursorRequestCursorType) Value 

func (c ShowCursorRequestCursorType) Value() string

type ShowCursorRequestCursorTypeEnum 

type ShowCursorRequestCursorTypeEnum struct {
	AT_SEQUENCE_NUMBER    ShowCursorRequestCursorType
	AFTER_SEQUENCE_NUMBER ShowCursorRequestCursorType
	TRIM_HORIZON          ShowCursorRequestCursorType
	LATEST                ShowCursorRequestCursorType
	AT_TIMESTAMP          ShowCursorRequestCursorType
}

func GetShowCursorRequestCursorTypeEnum 

func GetShowCursorRequestCursorTypeEnum() ShowCursorRequestCursorTypeEnum

type ShowCursorResponse 

type ShowCursorResponse struct {

	// 数据游标。  取值范围：1~512个字符。  说明：  数据游标有效期为5分钟。
	PartitionCursor *string `json:"partition_cursor,omitempty"`
	HttpStatusCode  int     `json:"-"`
}

ShowCursorResponse Response Object

func (ShowCursorResponse) String 

func (o ShowCursorResponse) String() string

type ShowPartitionMetricsRequest 

type ShowPartitionMetricsRequest struct {

	// 通道名称。
	StreamName string `json:"stream_name"`

	// 分区编号。 可定义为如下两种样式： - shardId-0000000000 - 0 比如一个通道有三个分区，那么分区标识符分别为0, 1, 2，或者shardId-0000000000, shardId-0000000001, shardId-0000000002
	PartitionId string `json:"partition_id"`

	// 分区监控指标。（label与label_list必须二选一，label_list与label同时存在时，以label_list为准）  - total_put_bytes_per_partition：分区总输入流量（Byte） - total_get_bytes_per_partition：分区总输出流量（Byte） - total_put_records_per_partition：分区总输入记录数（个） - total_get_records_per_partition：分区总输出记录数（个）
	Label *ShowPartitionMetricsRequestLabel `json:"label,omitempty"`

	// 使用label用逗号拼接组成，用于批量查询多个label的指标。（label与label_list必须二选一，label_list与label同时存在时，以label_list为准）
	LabelList *string `json:"label_list,omitempty"`

	// 监控开始时间点，10位时间戳。
	StartTime int64 `json:"start_time"`

	// 监控结束时间点，10位时间戳。
	EndTime string `json:"end_time"`
}

ShowPartitionMetricsRequest Request Object

func (ShowPartitionMetricsRequest) String 

func (o ShowPartitionMetricsRequest) String() string

type ShowPartitionMetricsRequestLabel 

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

func (ShowPartitionMetricsRequestLabel) MarshalJSON 

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

func (*ShowPartitionMetricsRequestLabel) UnmarshalJSON 

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

func (ShowPartitionMetricsRequestLabel) Value 

func (c ShowPartitionMetricsRequestLabel) Value() string

type ShowPartitionMetricsRequestLabelEnum 

type ShowPartitionMetricsRequestLabelEnum struct {
	TOTAL_PUT_BYTES_PER_PARTITION   ShowPartitionMetricsRequestLabel
	TOTAL_GET_BYTES_PER_PARTITION   ShowPartitionMetricsRequestLabel
	TOTAL_PUT_RECORDS_PER_PARTITION ShowPartitionMetricsRequestLabel
	TOTAL_GET_RECORDS_PER_PARTITION ShowPartitionMetricsRequestLabel
}

func GetShowPartitionMetricsRequestLabelEnum 

func GetShowPartitionMetricsRequestLabelEnum() ShowPartitionMetricsRequestLabelEnum

type ShowPartitionMetricsResponse 

type ShowPartitionMetricsResponse struct {
	Metrics        *Metrics `json:"metrics,omitempty"`
	HttpStatusCode int      `json:"-"`
}

ShowPartitionMetricsResponse Response Object

func (ShowPartitionMetricsResponse) String 

func (o ShowPartitionMetricsResponse) String() string

type ShowStreamMetricsRequest 

type ShowStreamMetricsRequest struct {

	// 通道名称。
	StreamName string `json:"stream_name"`

	// 通道监控指标。（label与label_list必须二选一，label_list与label同时存在时，以label_list为准）  - total_put_bytes_per_stream：总输入流量（Byte） - total_get_bytes_per_stream：总输出流量（Byte） - total_put_records_per_stream：总输入记录数（个） - total_get_records_per_stream：总输出记录数（个） - total_put_req_latency：上传请求平均处理时间（毫秒） - total_get_req_latency：下载请求平均处理时间（毫秒） - total_put_req_suc_per_stream：上传请求成功次数（个） - total_get_req_suc_per_stream：下载请求成功次数（个） - traffic_control_put：因流控拒绝的上传请求次数 （个） - traffic_control_get：因流控拒绝的下载请求次数 （个）
	Label *ShowStreamMetricsRequestLabel `json:"label,omitempty"`

	// 使用label用逗号拼接组成，用于批量查询多个label的指标。（label与label_list必须二选一，label_list与label同时存在时，以label_list为准）
	LabelList *string `json:"label_list,omitempty"`

	// 监控开始时间点，10位时间戳。
	StartTime int64 `json:"start_time"`

	// 监控结束时间点，10位时间戳。
	EndTime int64 `json:"end_time"`
}

ShowStreamMetricsRequest Request Object

func (ShowStreamMetricsRequest) String 

func (o ShowStreamMetricsRequest) String() string

type ShowStreamMetricsRequestLabel 

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

func (ShowStreamMetricsRequestLabel) MarshalJSON 

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

func (*ShowStreamMetricsRequestLabel) UnmarshalJSON 

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

func (ShowStreamMetricsRequestLabel) Value 

func (c ShowStreamMetricsRequestLabel) Value() string

type ShowStreamMetricsRequestLabelEnum 

type ShowStreamMetricsRequestLabelEnum struct {
	TOTAL_PUT_BYTES_PER_STREAM   ShowStreamMetricsRequestLabel
	TOTAL_GET_BYTES_PER_STREAM   ShowStreamMetricsRequestLabel
	TOTAL_PUT_RECORDS_PER_STREAM ShowStreamMetricsRequestLabel
	TOTAL_GET_RECORDS_PER_STREAM ShowStreamMetricsRequestLabel
	TOTAL_PUT_REQ_LATENCY        ShowStreamMetricsRequestLabel
	TOTAL_GET_REQ_LATENCY        ShowStreamMetricsRequestLabel
	TOTAL_PUT_REQ_SUC_PER_STREAM ShowStreamMetricsRequestLabel
	TOTAL_GET_REQ_SUC_PER_STREAM ShowStreamMetricsRequestLabel
	TRAFFIC_CONTROL_PUT          ShowStreamMetricsRequestLabel
	TRAFFIC_CONTROL_GET          ShowStreamMetricsRequestLabel
}

func GetShowStreamMetricsRequestLabelEnum 

func GetShowStreamMetricsRequestLabelEnum() ShowStreamMetricsRequestLabelEnum

type ShowStreamMetricsResponse 

type ShowStreamMetricsResponse struct {
	Metrics *Metrics `json:"metrics,omitempty"`

	// 监控数据对象列表。
	MetricsList    *[]Metrics `json:"metrics_list,omitempty"`
	HttpStatusCode int        `json:"-"`
}

ShowStreamMetricsResponse Response Object

func (ShowStreamMetricsResponse) String 

func (o ShowStreamMetricsResponse) String() string

type ShowStreamRequest 

type ShowStreamRequest struct {

	// 需要查询的通道名称。
	StreamName string `json:"stream_name"`

	// 从该分区值开始返回分区列表，返回的分区列表不包括此分区。
	StartPartitionId *string `json:"start_partitionId,omitempty"`

	// 单次请求返回的最大分区数。
	LimitPartitions *int32 `json:"limit_partitions,omitempty"`
}

ShowStreamRequest Request Object

func (ShowStreamRequest) String 

func (o ShowStreamRequest) String() string

type ShowStreamResponse 

type ShowStreamResponse struct {

	// 通道名称。
	StreamName *string `json:"stream_name,omitempty"`

	// 通道创建的时间，13位时间戳。
	CreateTime *int64 `json:"create_time,omitempty"`

	// 通道最近一次修改的时间，13位时间戳。
	LastModifiedTime *int64 `json:"last_modified_time,omitempty"`

	// 通道的当前状态。  - CREATING：创建中 - RUNNING：运行中 - TERMINATING：删除中 - TERMINATED：已删除
	Status *ShowStreamResponseStatus `json:"status,omitempty"`

	// 通道类型。  - COMMON：普通通道，表示1MB带宽。 - ADVANCED：高级通道，表示5MB带宽。
	StreamType *ShowStreamResponseStreamType `json:"stream_type,omitempty"`

	// 通道的分区列表。
	Partitions *[]PartitionResult `json:"partitions,omitempty"`

	// 是否还有更多满足请求条件的分区。  - 是：true。 - 否：false。
	HasMorePartitions *bool `json:"has_more_partitions,omitempty"`

	// 数据保留时长，单位是小时。
	RetentionPeriod *int32 `json:"retention_period,omitempty"`

	// 通道唯一标示符。
	StreamId *string `json:"stream_id,omitempty"`

	// 源数据类型。  - BLOB：存储在数据库管理系统中的一组二进制数据。 - JSON：一种开放的文件格式，以易读的文字为基础，用来传输由属性值或者序列性的值组成的数据对象。 - CSV：纯文本形式存储的表格数据，分隔符默认采用逗号。  缺省值：BLOB。
	DataType *ShowStreamResponseDataType `json:"data_type,omitempty"`

	// 用于描述用户JSON、CSV格式的源数据结构，采用Avro Schema的语法描述。Avro介绍您也可以点击[这里](http://avro.apache.org/docs/current/#schemas)查看。
	DataSchema *string `json:"data_schema,omitempty"`

	// 数据的压缩类型，目前支持：  - snappy  - gzip  - zip  默认不压缩。
	CompressionFormat *ShowStreamResponseCompressionFormat `json:"compression_format,omitempty"`

	CsvProperties *CsvProperties `json:"csv_properties,omitempty"`

	// 可写分区总数量（只包含ACTIVE状态的分区）。
	WritablePartitionCount *int32 `json:"writable_partition_count,omitempty"`

	// 可读分区总数量（包含ACTIVE与DELETED状态的分区）。
	ReadablePartitionCount *int32 `json:"readable_partition_count,omitempty"`

	// 扩缩容操作记录列表。
	UpdatePartitionCounts *[]UpdatePartitionCount `json:"update_partition_counts,omitempty"`

	// 通道的标签列表。
	Tags *[]Tag `json:"tags,omitempty"`

	// 通道的企业项目。
	SysTags *[]SysTag `json:"sys_tags,omitempty"`

	// 是否开启自动扩缩容。  - true：开启自动扩缩容。 - false：关闭自动扩缩容。  默认不开启。
	AutoScaleEnabled *bool `json:"auto_scale_enabled,omitempty"`

	// 当自动扩缩容启用时，自动缩容的最小分片数。
	AutoScaleMinPartitionCount *int32 `json:"auto_scale_min_partition_count,omitempty"`

	// 当自动扩缩容启用时，自动扩容的最大分片数。
	AutoScaleMaxPartitionCount *int32 `json:"auto_scale_max_partition_count,omitempty"`
	HttpStatusCode             int    `json:"-"`
}

ShowStreamResponse Response Object

func (ShowStreamResponse) String 

func (o ShowStreamResponse) String() string

type ShowStreamResponseCompressionFormat 

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

func (ShowStreamResponseCompressionFormat) MarshalJSON 

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

func (*ShowStreamResponseCompressionFormat) UnmarshalJSON 

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

func (ShowStreamResponseCompressionFormat) Value 

func (c ShowStreamResponseCompressionFormat) Value() string

type ShowStreamResponseCompressionFormatEnum 

type ShowStreamResponseCompressionFormatEnum struct {
	SNAPPY ShowStreamResponseCompressionFormat
	GZIP   ShowStreamResponseCompressionFormat
	ZIP    ShowStreamResponseCompressionFormat
}

func GetShowStreamResponseCompressionFormatEnum 

func GetShowStreamResponseCompressionFormatEnum() ShowStreamResponseCompressionFormatEnum

type ShowStreamResponseDataType 

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

func (ShowStreamResponseDataType) MarshalJSON 

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

func (*ShowStreamResponseDataType) UnmarshalJSON 

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

func (ShowStreamResponseDataType) Value 

func (c ShowStreamResponseDataType) Value() string

type ShowStreamResponseDataTypeEnum 

type ShowStreamResponseDataTypeEnum struct {
	BLOB ShowStreamResponseDataType
	JSON ShowStreamResponseDataType
	CSV  ShowStreamResponseDataType
}

func GetShowStreamResponseDataTypeEnum 

func GetShowStreamResponseDataTypeEnum() ShowStreamResponseDataTypeEnum

type ShowStreamResponseStatus 

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

func (ShowStreamResponseStatus) MarshalJSON 

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

func (*ShowStreamResponseStatus) UnmarshalJSON 

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

func (ShowStreamResponseStatus) Value 

func (c ShowStreamResponseStatus) Value() string

type ShowStreamResponseStatusEnum 

type ShowStreamResponseStatusEnum struct {
	CREATING    ShowStreamResponseStatus
	RUNNING     ShowStreamResponseStatus
	TERMINATING ShowStreamResponseStatus
	FROZEN      ShowStreamResponseStatus
}

func GetShowStreamResponseStatusEnum 

func GetShowStreamResponseStatusEnum() ShowStreamResponseStatusEnum

type ShowStreamResponseStreamType 

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

func (ShowStreamResponseStreamType) MarshalJSON 

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

func (*ShowStreamResponseStreamType) UnmarshalJSON 

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

func (ShowStreamResponseStreamType) Value 

func (c ShowStreamResponseStreamType) Value() string

type ShowStreamResponseStreamTypeEnum 

type ShowStreamResponseStreamTypeEnum struct {
	COMMON   ShowStreamResponseStreamType
	ADVANCED ShowStreamResponseStreamType
}

func GetShowStreamResponseStreamTypeEnum 

func GetShowStreamResponseStreamTypeEnum() ShowStreamResponseStreamTypeEnum

type ShowStreamTagsRequest 

type ShowStreamTagsRequest struct {

	// 通道ID。
	StreamId string `json:"stream_id"`
}

ShowStreamTagsRequest Request Object

func (ShowStreamTagsRequest) String 

func (o ShowStreamTagsRequest) String() string

type ShowStreamTagsResponse 

type ShowStreamTagsResponse struct {

	// 标签列表。
	Tags           *[]Tag `json:"tags,omitempty"`
	HttpStatusCode int    `json:"-"`
}

ShowStreamTagsResponse Response Object

func (ShowStreamTagsResponse) String 

func (o ShowStreamTagsResponse) String() string

type ShowTransferTaskRequest 

type ShowTransferTaskRequest struct {

	// 已创建的通道的名称。
	StreamName string `json:"stream_name"`

	// 待删除的转储任务名称。
	TaskName string `json:"task_name"`
}

ShowTransferTaskRequest Request Object

func (ShowTransferTaskRequest) String 

func (o ShowTransferTaskRequest) String() string

type ShowTransferTaskResponse 

type ShowTransferTaskResponse struct {

	// 该转储任务所属通道名称。
	StreamName *string `json:"stream_name,omitempty"`

	// 转储任务名称。
	TaskName *string `json:"task_name,omitempty"`

	// 转储任务状态。  - ERROR：错误。 - STARTING：启动中。 - PAUSED：已停止。 - RUNNING：运行中。 - DELETE：已删除。 - ABNORMAL：异常。
	State *ShowTransferTaskResponseState `json:"state,omitempty"`

	// 转储任务类型。  - OBS：转储到OBS。 - MRS：转储到MRS。 - DLI：转储到DLI。 - CLOUDTABLE：转储到CloudTable。 - DWS：转储到DWS。
	DestinationType *ShowTransferTaskResponseDestinationType `json:"destination_type,omitempty"`

	// 转储任务创建时间。
	CreateTime *int64 `json:"create_time,omitempty"`

	// 转储任务最近一次转储时间。
	LastTransferTimestamp *int64 `json:"last_transfer_timestamp,omitempty"`

	// 分区转储详情列表。
	Partitions *[]PartitionResult `json:"partitions,omitempty"`

	ObsDestinationDescription *ObsDestinationDescriptorRequest `json:"obs_destination_description,omitempty"`

	DwsDestinationDescripton *DwsDestinationDescriptorRequest `json:"dws_destination_descripton,omitempty"`

	MrsDestinationDescription *MrsDestinationDescriptorRequest `json:"mrs_destination_description,omitempty"`

	DliDestinationDescription *DliDestinationDescriptorRequest `json:"dli_destination_description,omitempty"`

	CloudtableDestinationDescripton *CloudtableDestinationDescriptorRequest `json:"cloudtable_destination_descripton,omitempty"`
	HttpStatusCode                  int                                     `json:"-"`
}

ShowTransferTaskResponse Response Object

func (ShowTransferTaskResponse) String 

func (o ShowTransferTaskResponse) String() string

type ShowTransferTaskResponseDestinationType 

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

func (ShowTransferTaskResponseDestinationType) MarshalJSON 

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

func (*ShowTransferTaskResponseDestinationType) UnmarshalJSON 

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

func (ShowTransferTaskResponseDestinationType) Value 

func (c ShowTransferTaskResponseDestinationType) Value() string

type ShowTransferTaskResponseDestinationTypeEnum 

type ShowTransferTaskResponseDestinationTypeEnum struct {
	OBS        ShowTransferTaskResponseDestinationType
	MRS        ShowTransferTaskResponseDestinationType
	DLI        ShowTransferTaskResponseDestinationType
	CLOUDTABLE ShowTransferTaskResponseDestinationType
	DWS        ShowTransferTaskResponseDestinationType
}

func GetShowTransferTaskResponseDestinationTypeEnum 

func GetShowTransferTaskResponseDestinationTypeEnum() ShowTransferTaskResponseDestinationTypeEnum

type ShowTransferTaskResponseState 

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

func (ShowTransferTaskResponseState) MarshalJSON 

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

func (*ShowTransferTaskResponseState) UnmarshalJSON 

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

func (ShowTransferTaskResponseState) Value 

func (c ShowTransferTaskResponseState) Value() string

type ShowTransferTaskResponseStateEnum 

type ShowTransferTaskResponseStateEnum struct {
	ERROR    ShowTransferTaskResponseState
	STARTING ShowTransferTaskResponseState
	PAUSED   ShowTransferTaskResponseState
	RUNNING  ShowTransferTaskResponseState
	DELETE   ShowTransferTaskResponseState
	ABNORMAL ShowTransferTaskResponseState
}

func GetShowTransferTaskResponseStateEnum 

func GetShowTransferTaskResponseStateEnum() ShowTransferTaskResponseStateEnum

type StreamInfo 

type StreamInfo struct {

	// 通道名称。
	StreamName *string `json:"stream_name,omitempty"`

	// 通道创建的时间，13位时间戳。
	CreateTime *int64 `json:"create_time,omitempty"`

	// 数据保留时长，单位是小时。
	RetentionPeriod *int32 `json:"retention_period,omitempty"`

	// 通道的当前状态。  - CREATING：创建中 - RUNNING：运行中 - TERMINATING：删除中 - TERMINATED：已删除
	Status *StreamInfoStatus `json:"status,omitempty"`

	// 通道类型。  - COMMON：普通通道，表示1MB带宽。 - ADVANCED：高级通道，表示5MB带宽。
	StreamType *StreamInfoStreamType `json:"stream_type,omitempty"`

	// 源数据类型。  - BLOB：存储在数据库管理系统中的一组二进制数据。 - JSON：一种开放的文件格式，以易读的文字为基础，用来传输由属性值或者序列性的值组成的数据对象。 - CSV：纯文本形式存储的表格数据，分隔符默认采用逗号。  缺省值：BLOB。
	DataType *StreamInfoDataType `json:"data_type,omitempty"`

	// 分区数量。  分区是DIS数据通道的基本吞吐量单位。
	PartitionCount *int32 `json:"partition_count,omitempty"`

	// 是否开启自动扩缩容。  - true：开启自动扩缩容。 - false：关闭自动扩缩容。  默认不开启。
	AutoScaleEnabled *bool `json:"auto_scale_enabled,omitempty"`

	// 当自动扩缩容启用时，自动缩容的最小分片数。
	AutoScaleMinPartitionCount *int32 `json:"auto_scale_min_partition_count,omitempty"`

	// 当自动扩缩容启用时，自动扩容的最大分片数。
	AutoScaleMaxPartitionCount *int32 `json:"auto_scale_max_partition_count,omitempty"`

	// 通道标签列表。
	Tags *[]Tag `json:"tags,omitempty"`

	// 通道企业项目列表。
	SysTags *[]SysTag `json:"sys_tags,omitempty"`
}

func (StreamInfo) String 

func (o StreamInfo) String() string

type StreamInfoDataType 

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

func (StreamInfoDataType) MarshalJSON 

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

func (*StreamInfoDataType) UnmarshalJSON 

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

func (StreamInfoDataType) Value 

func (c StreamInfoDataType) Value() string

type StreamInfoDataTypeEnum 

type StreamInfoDataTypeEnum struct {
	BLOB StreamInfoDataType
	JSON StreamInfoDataType
	CSV  StreamInfoDataType
}

func GetStreamInfoDataTypeEnum 

func GetStreamInfoDataTypeEnum() StreamInfoDataTypeEnum

type StreamInfoStatus 

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

func (StreamInfoStatus) MarshalJSON 

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

func (*StreamInfoStatus) UnmarshalJSON 

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

func (StreamInfoStatus) Value 

func (c StreamInfoStatus) Value() string

type StreamInfoStatusEnum 

type StreamInfoStatusEnum struct {
	CREATING    StreamInfoStatus
	RUNNING     StreamInfoStatus
	TERMINATING StreamInfoStatus
	FROZEN      StreamInfoStatus
}

func GetStreamInfoStatusEnum 

func GetStreamInfoStatusEnum() StreamInfoStatusEnum

type StreamInfoStreamType 

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

func (StreamInfoStreamType) MarshalJSON 

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

func (*StreamInfoStreamType) UnmarshalJSON 

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

func (StreamInfoStreamType) Value 

func (c StreamInfoStreamType) Value() string

type StreamInfoStreamTypeEnum 

type StreamInfoStreamTypeEnum struct {
	COMMON   StreamInfoStreamType
	ADVANCED StreamInfoStreamType
}

func GetStreamInfoStreamTypeEnum 

func GetStreamInfoStreamTypeEnum() StreamInfoStreamTypeEnum

type SysTag 

type SysTag struct {

	// 键。  - 不能为空。  - 值必须为_sys_enterprise_project_id。
	Key *SysTagKey `json:"key,omitempty"`

	// 值。  - 对应的是企业项目ID，需要在企业管理页面获取。  - 36位UUID。
	Value *string `json:"value,omitempty"`
}

func (SysTag) String 

func (o SysTag) String() string

type SysTagKey 

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

func (SysTagKey) MarshalJSON 

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

func (*SysTagKey) UnmarshalJSON 

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

func (SysTagKey) Value 

func (c SysTagKey) Value() string

type SysTagKeyEnum 

type SysTagKeyEnum struct {
	SYS_ENTERPRISE_PROJECT_ID SysTagKey
}

func GetSysTagKeyEnum 

func GetSysTagKeyEnum() SysTagKeyEnum

type Tag 

type Tag struct {

	// 键。  - 不能为空。  - 对于同一资源键值唯一。  - 字符集：A-Z，a-z ， 0-9，‘-’，‘_’，UNICODE字符（\\u4E00-\\u9FFF）。
	Key *string `json:"key,omitempty"`

	// 值。  - 长度不超过43个字符。  - 字符集：A-Z，a-z ， 0-9，‘.’，‘-’，‘_’，UNICODE字符（\\u4E00-\\u9FFF）。  - 只能包含数字、字母、中划线“-”、下划线“_”。
	Value *string `json:"value,omitempty"`
}

Tag 标签对象。

func (Tag) String 

func (o Tag) String() string

type Tags 

type Tags struct {

	// 键。  - 不能为空。  - 对于同一资源键值唯一。  - 字符集：A-Z，a-z ， 0-9，‘-’，‘_’，UNICODE字符（\\u4E00-\\u9FFF）。
	Key *string `json:"key,omitempty"`

	// 标签值列表。  如果values为空列表，则表示any_value。value之间为或的关系。
	Values *[]string `json:"values,omitempty"`
}

func (Tags) String 

func (o Tags) String() string

type TransferTask 

type TransferTask struct {

	// 转储任务名称。
	TaskName *string `json:"task_name,omitempty"`

	// 转储任务状态。  - ERROR：错误。 - STARTING：启动中。 - PAUSED：已停止。 - RUNNING：运行中。 - DELETE：已删除。 - ABNORMAL：异常。
	State *TransferTaskState `json:"state,omitempty"`

	// 转储任务类型。  - OBS：转储到OBS。 - MRS：转储到MRS。 - DLI：转储到DLI。 - CLOUDTABLE：转储到CloudTable。 - DWS：转储到DWS。
	DestinationType *TransferTaskDestinationType `json:"destination_type,omitempty"`

	// 转储任务创建时间。
	CreateTime *int64 `json:"create_time,omitempty"`

	// 转储任务最近一次转储时间。
	LastTransferTimestamp *int64 `json:"last_transfer_timestamp,omitempty"`
}

func (TransferTask) String 

func (o TransferTask) String() string

type TransferTaskDestinationType 

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

func (TransferTaskDestinationType) MarshalJSON 

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

func (*TransferTaskDestinationType) UnmarshalJSON 

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

func (TransferTaskDestinationType) Value 

func (c TransferTaskDestinationType) Value() string

type TransferTaskDestinationTypeEnum 

type TransferTaskDestinationTypeEnum struct {
	OBS        TransferTaskDestinationType
	MRS        TransferTaskDestinationType
	DLI        TransferTaskDestinationType
	CLOUDTABLE TransferTaskDestinationType
	DWS        TransferTaskDestinationType
}

func GetTransferTaskDestinationTypeEnum 

func GetTransferTaskDestinationTypeEnum() TransferTaskDestinationTypeEnum

type TransferTaskState 

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

func (TransferTaskState) MarshalJSON 

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

func (*TransferTaskState) UnmarshalJSON 

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

func (TransferTaskState) Value 

func (c TransferTaskState) Value() string

type TransferTaskStateEnum 

type TransferTaskStateEnum struct {
	ERROR    TransferTaskState
	STARTING TransferTaskState
	PAUSED   TransferTaskState
	RUNNING  TransferTaskState
	DELETE   TransferTaskState
	ABNORMAL TransferTaskState
}

func GetTransferTaskStateEnum 

func GetTransferTaskStateEnum() TransferTaskStateEnum

type UpdatePartitionCount 

type UpdatePartitionCount struct {

	// 扩缩容操作执行时间戳，13位时间戳。
	CreateTimestamp *int64 `json:"create_timestamp,omitempty"`

	// 扩缩容操作前分区数量。
	SrcPartitionCount *int32 `json:"src_partition_count,omitempty"`

	// 扩缩容操作后分区数量。
	TargetPartitionCount *int32 `json:"target_partition_count,omitempty"`

	// 扩缩容操作响应码。
	ResultCode *int32 `json:"result_code,omitempty"`

	// 扩缩容操作响应信息。
	ResultMsg *int32 `json:"result_msg,omitempty"`

	// 本次扩缩容操作是否为自动扩缩容。  - true：自动扩缩容。 - false：手动扩缩容。
	AutoScale *bool `json:"auto_scale,omitempty"`
}

func (UpdatePartitionCount) String 

func (o UpdatePartitionCount) String() string

type UpdatePartitionCountReq 

type UpdatePartitionCountReq struct {

	// 需要变更分区数量的通道名称。
	StreamName string `json:"stream_name"`

	// 变更的目标分区数量。  取值为大于0的整数。  设置的值大于当前分区数量表示扩容，小于当前分区数量表示缩容。  注意：  每个通道在一小时内扩容和缩容总次数最多5次，且一小时内扩容或缩容操作有一次成功则最近一小时内不允许再次进行扩容或缩容操作。
	TargetPartitionCount int32 `json:"target_partition_count"`
}

func (UpdatePartitionCountReq) String 

func (o UpdatePartitionCountReq) String() string

type UpdatePartitionCountRequest 

type UpdatePartitionCountRequest struct {

	// 需要变更分区数量的通道名称。
	StreamName string `json:"stream_name"`

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

UpdatePartitionCountRequest Request Object

func (UpdatePartitionCountRequest) String 

func (o UpdatePartitionCountRequest) String() string

type UpdatePartitionCountResponse 

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

UpdatePartitionCountResponse Response Object

func (UpdatePartitionCountResponse) String 

func (o UpdatePartitionCountResponse) String() string

type UpdateStreamReq 

type UpdateStreamReq struct {

	// 待更新的通道名称。
	StreamName string `json:"stream_name"`

	// 数据保留时长。  取值范围：24~72。  单位：小时。  空表示使用缺省值。
	DataDuration *int32 `json:"data_duration,omitempty"`

	// 源数据类型。  - BLOB：存储在数据库管理系统中的一组二进制数据。 - JSON：一种开放的文件格式，以易读的文字为基础，用来传输由属性值或者序列性的值组成的数据对象。 - CSV：纯文本形式存储的表格数据，分隔符默认采用逗号。  缺省值：BLOB。
	DataType *UpdateStreamReqDataType `json:"data_type,omitempty"`

	// 用于描述用户JSON、CSV格式的源数据结构，采用Avro Schema的语法描述。
	DataSchema *string `json:"data_schema,omitempty"`

	// 是否开启自动扩缩容。  - true：开启自动扩缩容。 - false：关闭自动扩缩容。  默认不开启。
	AutoScaleEnabled *bool `json:"auto_scale_enabled,omitempty"`

	// 当自动扩缩容启用时，自动缩容的最小分片数。
	AutoScaleMinPartitionCount *int64 `json:"auto_scale_min_partition_count,omitempty"`

	// 当自动扩缩容启用时，自动扩容的最大分片数。
	AutoScaleMaxPartitionCount *int64 `json:"auto_scale_max_partition_count,omitempty"`
}

func (UpdateStreamReq) String 

func (o UpdateStreamReq) String() string

type UpdateStreamReqDataType 

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

func (UpdateStreamReqDataType) MarshalJSON 

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

func (*UpdateStreamReqDataType) UnmarshalJSON 

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

func (UpdateStreamReqDataType) Value 

func (c UpdateStreamReqDataType) Value() string

type UpdateStreamReqDataTypeEnum 

type UpdateStreamReqDataTypeEnum struct {
	BLOB UpdateStreamReqDataType
	JSON UpdateStreamReqDataType
	CSV  UpdateStreamReqDataType
}

func GetUpdateStreamReqDataTypeEnum 

func GetUpdateStreamReqDataTypeEnum() UpdateStreamReqDataTypeEnum

type UpdateStreamRequest 

type UpdateStreamRequest struct {

	// 需要变更分区数量的通道名称。
	StreamName string `json:"stream_name"`

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

UpdateStreamRequest Request Object

func (UpdateStreamRequest) String 

func (o UpdateStreamRequest) String() string

type UpdateStreamResponse 

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

UpdateStreamResponse Response Object

func (UpdateStreamResponse) String 

func (o UpdateStreamResponse) 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.