model

package
v0.0.30-rc Latest Latest
Warning

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

 Go to latest Published: Jan 16, 2021 License: Apache-2.0, BSD-2-Clause, BSD-3-Clause Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type CommitCheckpointRequest 

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

Request Object

func (CommitCheckpointRequest) String 

func (o CommitCheckpointRequest) String() string

type CommitCheckpointResponse 

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

Response Object

func (CommitCheckpointResponse) String 

func (o CommitCheckpointResponse) String() string

type CreateAppRequest 

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

Request Object

func (CreateAppRequest) String 

func (o CreateAppRequest) String() string

type CreateAppResponse 

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

Response Object

func (CreateAppResponse) String 

func (o CreateAppResponse) String() string

type CreateAppV3Request 

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

Request Object

func (CreateAppV3Request) String 

func (o CreateAppV3Request) String() string

type CreateAppV3Response 

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

Response Object

func (CreateAppV3Response) String 

func (o CreateAppV3Response) String() string

type CreatePoliciesV3Request 

type CreatePoliciesV3Request struct {
	StreamName string                   `json:"stream_name"`
	Body       *CreatePolicyRuleRequest `json:"body,omitempty"`
}

Request Object

func (CreatePoliciesV3Request) String 

func (o CreatePoliciesV3Request) String() string

type CreatePoliciesV3Response 

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

Response Object

func (CreatePoliciesV3Response) String 

func (o CreatePoliciesV3Response) String() string

type CreatePolicyRuleRequest 

type CreatePolicyRuleRequest struct {
	// 通道唯一标识符。
	StreamId string `json:"stream_id"`
	// 授权用户。  支持通配符\"*\"，表示授权所有账号，支持多账号添加，用\",\"隔开；
	PrincipalName string `json:"principal_name"`
	// 授权操作类型。  - putRecords：上传数据。 - getRecords：下载数据。
	ActionType CreatePolicyRuleRequestActionType `json:"action_type"`
	// 授权影响类型。  - accept：允许该授权操作。
	Effect CreatePolicyRuleRequestEffect `json:"effect"`
}

func (CreatePolicyRuleRequest) String 

func (o CreatePolicyRuleRequest) String() string

type CreatePolicyRuleRequestActionType 

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

func (CreatePolicyRuleRequestActionType) MarshalJSON 

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

func (*CreatePolicyRuleRequestActionType) UnmarshalJSON 

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

type CreatePolicyRuleRequestActionTypeEnum 

type CreatePolicyRuleRequestActionTypeEnum struct {
	PUT_RECORDS CreatePolicyRuleRequestActionType
	GET_RECORDS CreatePolicyRuleRequestActionType
}

func GetCreatePolicyRuleRequestActionTypeEnum 

func GetCreatePolicyRuleRequestActionTypeEnum() CreatePolicyRuleRequestActionTypeEnum

type CreatePolicyRuleRequestEffect 

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

func (CreatePolicyRuleRequestEffect) MarshalJSON 

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

func (*CreatePolicyRuleRequestEffect) UnmarshalJSON 

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

type CreatePolicyRuleRequestEffectEnum 

type CreatePolicyRuleRequestEffectEnum struct {
	ACCEPT CreatePolicyRuleRequestEffect
}

func GetCreatePolicyRuleRequestEffectEnum 

func GetCreatePolicyRuleRequestEffectEnum() CreatePolicyRuleRequestEffectEnum

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。  单位：小时。  缺省值：24。  空表示使用缺省值。
	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

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

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

type CreateStreamReqStreamTypeEnum 

type CreateStreamReqStreamTypeEnum struct {
	COMMON   CreateStreamReqStreamType
	ADVANCED CreateStreamReqStreamType
}

func GetCreateStreamReqStreamTypeEnum 

func GetCreateStreamReqStreamTypeEnum() CreateStreamReqStreamTypeEnum

type CreateStreamRequest 

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

Request Object

func (CreateStreamRequest) String 

func (o CreateStreamRequest) String() string

type CreateStreamResponse 

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

Response Object

func (CreateStreamResponse) String 

func (o CreateStreamResponse) String() string

type CreateTransferTaskRequest 

type CreateTransferTaskRequest struct {
	StreamName string                     `json:"stream_name"`
	Body       *CreateTransferTaskRequest `json:"body,omitempty"`
}

Request Object

func (CreateTransferTaskRequest) String 

func (o CreateTransferTaskRequest) String() string

type CreateTransferTaskResponse 

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

Response Object

func (CreateTransferTaskResponse) String 

func (o CreateTransferTaskResponse) String() string

type CreateTransferTaskV3Request 

type CreateTransferTaskV3Request struct {
	StreamName string                     `json:"stream_name"`
	Body       *CreateTransferTaskRequest `json:"body,omitempty"`
}

Request Object

func (CreateTransferTaskV3Request) String 

func (o CreateTransferTaskV3Request) String() string

type CreateTransferTaskV3Response 

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

Response Object

func (CreateTransferTaskV3Response) String 

func (o CreateTransferTaskV3Response) String() string

type CsvProperties 

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

func (CsvProperties) String 

func (o CsvProperties) String() string

type DeleteAppRequest 

type DeleteAppRequest struct {
	AppName string `json:"app_name"`
}

Request Object

func (DeleteAppRequest) String 

func (o DeleteAppRequest) String() string

type DeleteAppResponse 

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

Response Object

func (DeleteAppResponse) String 

func (o DeleteAppResponse) String() string

type DeleteCheckpointRequest 

type DeleteCheckpointRequest struct {
	StreamName     string                                `json:"stream_name"`
	AppName        string                                `json:"app_name"`
	CheckpointType DeleteCheckpointRequestCheckpointType `json:"checkpoint_type"`
	PartitionId    *string                               `json:"partition_id,omitempty"`
}

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

type DeleteCheckpointRequestCheckpointTypeEnum 

type DeleteCheckpointRequestCheckpointTypeEnum struct {
	LAST_READ DeleteCheckpointRequestCheckpointType
}

func GetDeleteCheckpointRequestCheckpointTypeEnum 

func GetDeleteCheckpointRequestCheckpointTypeEnum() DeleteCheckpointRequestCheckpointTypeEnum

type DeleteCheckpointResponse 

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

Response Object

func (DeleteCheckpointResponse) String 

func (o DeleteCheckpointResponse) String() string

type DeleteStreamRequest 

type DeleteStreamRequest struct {
	StreamName string `json:"stream_name"`
}

Request Object

func (DeleteStreamRequest) String 

func (o DeleteStreamRequest) String() string

type DeleteStreamResponse 

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

Response Object

func (DeleteStreamResponse) String 

func (o DeleteStreamResponse) String() string

type DeleteStreamV3Request 

type DeleteStreamV3Request struct {
	StreamName string `json:"stream_name"`
}

Request Object

func (DeleteStreamV3Request) String 

func (o DeleteStreamV3Request) String() string

type DeleteStreamV3Response 

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

Response Object

func (DeleteStreamV3Response) String 

func (o DeleteStreamV3Response) String() string

type DeleteTransferTaskRequest 

type DeleteTransferTaskRequest struct {
	StreamName string `json:"stream_name"`
	TaskName   string `json:"task_name"`
}

Request Object

func (DeleteTransferTaskRequest) String 

func (o DeleteTransferTaskRequest) String() string

type DeleteTransferTaskResponse 

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

Response Object

func (DeleteTransferTaskResponse) String 

func (o DeleteTransferTaskResponse) String() string

type DeleteTransferTaskV3Request 

type DeleteTransferTaskV3Request struct {
	StreamName string `json:"stream_name"`
	TaskName   string `json:"task_name"`
}

Request Object

func (DeleteTransferTaskV3Request) String 

func (o DeleteTransferTaskV3Request) String() string

type DeleteTransferTaskV3Response 

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

Response Object

func (DeleteTransferTaskV3Response) String 

func (o DeleteTransferTaskV3Response) String() string

type DescribeAppRequest 

type DescribeAppRequest struct {
	AppName string `json:"app_name"`
}

Request Object

func (DescribeAppRequest) String 

func (o DescribeAppRequest) String() string

type DescribeAppResponse 

type DescribeAppResponse struct {
	// App的名称。
	AppName *string `json:"app_name,omitempty"`
	// App的唯一标识符。
	AppId *string `json:"app_id,omitempty"`
	// App创建的时间，单位毫秒。
	CreateTime     *int64 `json:"create_time,omitempty"`
	HttpStatusCode int    `json:"-"`
}

Response Object

func (DescribeAppResponse) String 

func (o DescribeAppResponse) 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"`
}

func (DescribeAppResult) String 

func (o DescribeAppResult) String() string

type DescribeStreamRequest 

type DescribeStreamRequest struct {
	StreamName       string  `json:"stream_name"`
	StartPartitionId *string `json:"start_partitionId,omitempty"`
	LimitPartitions  *int32  `json:"limit_partitions,omitempty"`
}

Request Object

func (DescribeStreamRequest) String 

func (o DescribeStreamRequest) String() string

type DescribeStreamResponse 

type DescribeStreamResponse 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 *DescribeStreamResponseStatus `json:"status,omitempty"`
	// 通道类型。  - COMMON：普通通道，表示1MB带宽。 - ADVANCED：高级通道，表示5MB带宽。
	StreamType *DescribeStreamResponseStreamType `json:"stream_type,omitempty"`
	// A list of partitions that comprise the DIS stream.
	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 *DescribeStreamResponseDataType `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 *DescribeStreamResponseCompressionFormat `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"`
	// 是否开启自动扩缩容。  - 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:"-"`
}

Response Object

func (DescribeStreamResponse) String 

func (o DescribeStreamResponse) String() string

type DescribeStreamResponseCompressionFormat 

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

func (DescribeStreamResponseCompressionFormat) MarshalJSON 

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

func (*DescribeStreamResponseCompressionFormat) UnmarshalJSON 

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

type DescribeStreamResponseCompressionFormatEnum 

type DescribeStreamResponseCompressionFormatEnum struct {
	SNAPPY DescribeStreamResponseCompressionFormat
	GZIP   DescribeStreamResponseCompressionFormat
	ZIP    DescribeStreamResponseCompressionFormat
}

func GetDescribeStreamResponseCompressionFormatEnum 

func GetDescribeStreamResponseCompressionFormatEnum() DescribeStreamResponseCompressionFormatEnum

type DescribeStreamResponseDataType 

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

func (DescribeStreamResponseDataType) MarshalJSON 

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

func (*DescribeStreamResponseDataType) UnmarshalJSON 

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

type DescribeStreamResponseDataTypeEnum 

type DescribeStreamResponseDataTypeEnum struct {
	BLOB DescribeStreamResponseDataType
	JSON DescribeStreamResponseDataType
	CSV  DescribeStreamResponseDataType
}

func GetDescribeStreamResponseDataTypeEnum 

func GetDescribeStreamResponseDataTypeEnum() DescribeStreamResponseDataTypeEnum

type DescribeStreamResponseStatus 

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

func (DescribeStreamResponseStatus) MarshalJSON 

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

func (*DescribeStreamResponseStatus) UnmarshalJSON 

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

type DescribeStreamResponseStatusEnum 

type DescribeStreamResponseStatusEnum struct {
	CREATING    DescribeStreamResponseStatus
	RUNNING     DescribeStreamResponseStatus
	TERMINATING DescribeStreamResponseStatus
	FROZEN      DescribeStreamResponseStatus
}

func GetDescribeStreamResponseStatusEnum 

func GetDescribeStreamResponseStatusEnum() DescribeStreamResponseStatusEnum

type DescribeStreamResponseStreamType 

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

func (DescribeStreamResponseStreamType) MarshalJSON 

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

func (*DescribeStreamResponseStreamType) UnmarshalJSON 

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

type DescribeStreamResponseStreamTypeEnum 

type DescribeStreamResponseStreamTypeEnum struct {
	COMMON   DescribeStreamResponseStreamType
	ADVANCED DescribeStreamResponseStreamType
}

func GetDescribeStreamResponseStreamTypeEnum 

func GetDescribeStreamResponseStreamTypeEnum() DescribeStreamResponseStreamTypeEnum

type GetCheckpointRequest 

type GetCheckpointRequest struct {
	StreamName     string                             `json:"stream_name"`
	PartitionId    string                             `json:"partition_id"`
	AppName        string                             `json:"app_name"`
	CheckpointType GetCheckpointRequestCheckpointType `json:"checkpoint_type"`
}

Request Object

func (GetCheckpointRequest) String 

func (o GetCheckpointRequest) String() string

type GetCheckpointRequestCheckpointType 

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

func (GetCheckpointRequestCheckpointType) MarshalJSON 

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

func (*GetCheckpointRequestCheckpointType) UnmarshalJSON 

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

type GetCheckpointRequestCheckpointTypeEnum 

type GetCheckpointRequestCheckpointTypeEnum struct {
	LAST_READ GetCheckpointRequestCheckpointType
}

func GetGetCheckpointRequestCheckpointTypeEnum 

func GetGetCheckpointRequestCheckpointTypeEnum() GetCheckpointRequestCheckpointTypeEnum

type GetCheckpointResponse 

type GetCheckpointResponse struct {
	// 序列号，用来记录该通道的消费检查点。
	SequenceNumber *string `json:"sequence_number,omitempty"`
	// 用户消费程序端的元数据信息。
	Metadata       *string `json:"metadata,omitempty"`
	HttpStatusCode int     `json:"-"`
}

Response Object

func (GetCheckpointResponse) String 

func (o GetCheckpointResponse) String() string

type GetCursorRequest 

type GetCursorRequest struct {
	StreamName             string                      `json:"stream-name"`
	PartitionId            string                      `json:"partition-id"`
	CursorType             *GetCursorRequestCursorType `json:"cursor-type,omitempty"`
	StartingSequenceNumber *string                     `json:"starting-sequence-number,omitempty"`
	Timestamp              *int64                      `json:"timestamp,omitempty"`
}

Request Object

func (GetCursorRequest) String 

func (o GetCursorRequest) String() string

type GetCursorRequestCursorType 

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

func (GetCursorRequestCursorType) MarshalJSON 

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

func (*GetCursorRequestCursorType) UnmarshalJSON 

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

type GetCursorRequestCursorTypeEnum 

type GetCursorRequestCursorTypeEnum struct {
	AT_SEQUENCE_NUMBER    GetCursorRequestCursorType
	AFTER_SEQUENCE_NUMBER GetCursorRequestCursorType
	TRIM_HORIZON          GetCursorRequestCursorType
	LATEST                GetCursorRequestCursorType
	AT_TIMESTAMP          GetCursorRequestCursorType
}

func GetGetCursorRequestCursorTypeEnum 

func GetGetCursorRequestCursorTypeEnum() GetCursorRequestCursorTypeEnum

type GetCursorResponse 

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

Response Object

func (GetCursorResponse) String 

func (o GetCursorResponse) String() string

type GetRecordsRequest 

type GetRecordsRequest struct {
	PartitionCursor string `json:"partition-cursor"`
	MaxFetchBytes   *int32 `json:"max_fetch_bytes,omitempty"`
}

Request Object

func (GetRecordsRequest) String 

func (o GetRecordsRequest) String() string

type GetRecordsResponse 

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

Response Object

func (GetRecordsResponse) String 

func (o GetRecordsResponse) String() string

type ListAppRequest 

type ListAppRequest struct {
	Limit        *int32  `json:"limit,omitempty"`
	StartAppName *string `json:"start_app_name,omitempty"`
	StreamName   *string `json:"stream_name,omitempty"`
}

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"`
	HttpStatusCode int                  `json:"-"`
}

Response Object

func (ListAppResponse) String 

func (o ListAppResponse) String() string

type ListAppV3Request 

type ListAppV3Request struct {
	Limit        *int32  `json:"limit,omitempty"`
	StartAppName *string `json:"start_app_name,omitempty"`
	StreamName   *string `json:"stream_name,omitempty"`
}

Request Object

func (ListAppV3Request) String 

func (o ListAppV3Request) String() string

type ListAppV3Response 

type ListAppV3Response struct {
	// 是否还有更多满足条件的App。  - true：是。 - false：否。
	HasMoreApp *bool `json:"has_more_app,omitempty"`
	// AppEntry list that meets the current request.
	Apps           *[]DescribeAppResult `json:"apps,omitempty"`
	HttpStatusCode int                  `json:"-"`
}

Response Object

func (ListAppV3Response) String 

func (o ListAppV3Response) String() string

type ListPoliciesV3Request 

type ListPoliciesV3Request struct {
	StreamName string `json:"stream_name"`
}

Request Object

func (ListPoliciesV3Request) String 

func (o ListPoliciesV3Request) String() string

type ListPoliciesV3Response 

type ListPoliciesV3Response struct {
	// 通道唯一标识符。
	StreamId *string `json:"stream_id,omitempty"`
	// 通道授权信息列表。
	Rules          *[]PrincipalRule `json:"rules,omitempty"`
	HttpStatusCode int              `json:"-"`
}

Response Object

func (ListPoliciesV3Response) String 

func (o ListPoliciesV3Response) String() string

type ListStreamsRequest 

type ListStreamsRequest struct {
	Limit           *int32  `json:"limit,omitempty"`
	StartStreamName *string `json:"start_stream_name,omitempty"`
}

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:"-"`
}

Response Object

func (ListStreamsResponse) String 

func (o ListStreamsResponse) String() string

type ListTransferTasksV3Request 

type ListTransferTasksV3Request struct {
	StreamName string `json:"stream_name"`
}

Request Object

func (ListTransferTasksV3Request) String 

func (o ListTransferTasksV3Request) String() string

type ListTransferTasksV3Response 

type ListTransferTasksV3Response struct {
	// 转储任务总数。
	TotalNumber *int32 `json:"total_number,omitempty"`
	// 转储任务列表。
	Tasks          *[]TransferTask `json:"tasks,omitempty"`
	HttpStatusCode int             `json:"-"`
}

Response Object

func (ListTransferTasksV3Response) String 

func (o ListTransferTasksV3Response) String() string

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

type PartitionResultStatusEnum 

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

func GetPartitionResultStatusEnum 

func GetPartitionResultStatusEnum() PartitionResultStatusEnum

type PrincipalRule 

type PrincipalRule struct {
	// 通道唯一标识符。
	Principal *string `json:"principal,omitempty"`
	// 授权用户。
	PrincipalName *string `json:"principal_name,omitempty"`
	// 授权操作类型。  - putRecords：上传数据。
	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

type PrincipalRuleActionTypeEnum 

type PrincipalRuleActionTypeEnum struct {
	PUT_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

type PrincipalRuleEffectEnum 

type PrincipalRuleEffectEnum struct {
	ACCEPT PrincipalRuleEffect
}

func GetPrincipalRuleEffectEnum 

func GetPrincipalRuleEffectEnum() PrincipalRuleEffectEnum

type PutRecordsRequest 

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

Request Object

func (PutRecordsRequest) String 

func (o PutRecordsRequest) String() string

type PutRecordsResponse 

type PutRecordsResponse struct {
	// 上传失败的数据数量。
	FailedRecordCount *int32                   `json:"failed_record_count,omitempty"`
	Records           *[]PutRecordsResultEntry `json:"records,omitempty"`
	HttpStatusCode    int                      `json:"-"`
}

Response Object

func (PutRecordsResponse) String 

func (o PutRecordsResponse) 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 **os.File `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 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"`
	// List of tags for the newly created DIS stream.
	Tags *[]Tag `json:"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"`
}

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

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

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

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

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"`
}

func (Tag) String 

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

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

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 UpdatePartitionCountRequest 

type UpdatePartitionCountRequest struct {
	StreamName string                       `json:"stream_name"`
	Body       *UpdatePartitionCountRequest `json:"body,omitempty"`
}

Request Object

func (UpdatePartitionCountRequest) String 

func (o UpdatePartitionCountRequest) String() string

type UpdatePartitionCountResponse 

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

Response Object

func (UpdatePartitionCountResponse) String 

func (o UpdatePartitionCountResponse) String() string

type UpdateStreamRequest 

type UpdateStreamRequest struct {
	// 待更新的通道名称。
	StreamName *string `json:"stream_name,omitempty"`
	// 数据保留时长。  取值范围：24~72。  单位：小时。  缺省值：24。  空表示使用缺省值。
	DataDuration *int32 `json:"data_duration,omitempty"`
	// 源数据类型。  - BLOB：存储在数据库管理系统中的一组二进制数据。 - JSON：一种开放的文件格式，以易读的文字为基础，用来传输由属性值或者序列性的值组成的数据对象。 - CSV：纯文本形式存储的表格数据，分隔符默认采用逗号。  缺省值：BLOB。
	DataType *UpdateStreamRequestDataType `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"`
	// 扩缩容操作后分区数量。
	TargetPartitionCount *int64 `json:"target_partition_count,omitempty"`
}

func (UpdateStreamRequest) String 

func (o UpdateStreamRequest) String() string

type UpdateStreamRequestDataType 

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

func (UpdateStreamRequestDataType) MarshalJSON 

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

func (*UpdateStreamRequestDataType) UnmarshalJSON 

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

type UpdateStreamRequestDataTypeEnum 

type UpdateStreamRequestDataTypeEnum struct {
	BLOB UpdateStreamRequestDataType
	JSON UpdateStreamRequestDataType
	CSV  UpdateStreamRequestDataType
}

func GetUpdateStreamRequestDataTypeEnum 

func GetUpdateStreamRequestDataTypeEnum() UpdateStreamRequestDataTypeEnum

type UpdateStreamV3Request 

type UpdateStreamV3Request struct {
	StreamName string               `json:"stream_name"`
	Body       *UpdateStreamRequest `json:"body,omitempty"`
}

Request Object

func (UpdateStreamV3Request) String 

func (o UpdateStreamV3Request) String() string

type UpdateStreamV3Response 

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

Response Object

func (UpdateStreamV3Response) String 

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