model

package
v1.0.3 Latest Latest
Warning

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

 Go to latest Published: Dec 23, 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 *CommitCheckpointRequestBody `json:"body,omitempty"`
}

Request Object

func (CommitCheckpointRequest) String 

func (o CommitCheckpointRequest) String() string

type CommitCheckpointRequestBody 

type CommitCheckpointRequestBody struct {
	AppName string `json:"app_name"`

	CheckpointType CommitCheckpointRequestBodyCheckpointType `json:"checkpoint_type"`

	StreamName string `json:"stream_name"`

	PartitionId string `json:"partition_id"`

	SequenceNumber string `json:"sequence_number"`

	Metadata *string `json:"metadata,omitempty"`
}

func (CommitCheckpointRequestBody) String 

func (o CommitCheckpointRequestBody) String() string

type CommitCheckpointRequestBodyCheckpointType 

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

func (CommitCheckpointRequestBodyCheckpointType) MarshalJSON 

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

func (*CommitCheckpointRequestBodyCheckpointType) UnmarshalJSON 

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

type CommitCheckpointRequestBodyCheckpointTypeEnum 

type CommitCheckpointRequestBodyCheckpointTypeEnum struct {
	LAST_READ CommitCheckpointRequestBodyCheckpointType
}

func GetCommitCheckpointRequestBodyCheckpointTypeEnum 

func GetCommitCheckpointRequestBodyCheckpointTypeEnum() CommitCheckpointRequestBodyCheckpointTypeEnum

type CommitCheckpointResponse 

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

Response Object

func (CommitCheckpointResponse) String 

func (o CommitCheckpointResponse) String() string

type CreateAppRequest 

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

Request Object

func (CreateAppRequest) String 

func (o CreateAppRequest) String() string

type CreateAppRequestBody 

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

func (CreateAppRequestBody) String 

func (o CreateAppRequestBody) 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 *CreateAppRequestBody `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"`

	ActionType CreatePolicyRuleRequestActionType `json:"action_type"`

	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 {
	StreamName string `json:"stream_name"`

	PartitionCount int32 `json:"partition_count"`

	StreamType *CreateStreamReqStreamType `json:"stream_type,omitempty"`

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

	DataDuration *int32 `json:"data_duration,omitempty"`

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

	DataSchema *string `json:"data_schema,omitempty"`

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

	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 {
	AppName *string `json:"app_name,omitempty"`

	AppId *string `json:"app_id,omitempty"`

	CreateTime     *int64 `json:"create_time,omitempty"`
	HttpStatusCode int    `json:"-"`
}

Response Object

func (DescribeAppResponse) String 

func (o DescribeAppResponse) String() string

type DescribeAppResult 

type DescribeAppResult struct {
	AppName *string `json:"app_name,omitempty"`

	AppId *string `json:"app_id,omitempty"`

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

	CreateTime *int64 `json:"create_time,omitempty"`

	LastModifiedTime *int64 `json:"last_modified_time,omitempty"`

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

	StreamType *DescribeStreamResponseStreamType `json:"stream_type,omitempty"`

	Partitions *[]PartitionResult `json:"partitions,omitempty"`

	HasMorePartitions *bool `json:"has_more_partitions,omitempty"`

	RetentionPeriod *int32 `json:"retention_period,omitempty"`

	StreamId *string `json:"stream_id,omitempty"`

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

	DataSchema *string `json:"data_schema,omitempty"`

	CompressionFormat *DescribeStreamResponseCompressionFormat `json:"compression_format,omitempty"`

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

	WritablePartitionCount *int32 `json:"writable_partition_count,omitempty"`

	ReadablePartitionCount *int32 `json:"readable_partition_count,omitempty"`

	UpdatePartitionCounts *[]UpdatePartitionCount `json:"update_partition_counts,omitempty"`

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

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

	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 {
	HasMoreApp *bool `json:"has_more_app,omitempty"`

	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 {
	HasMoreApp *bool `json:"has_more_app,omitempty"`

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

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

	ActionType *PrincipalRuleActionType `json:"action_type,omitempty"`

	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 *PutRecordsRequestBody `json:"body,omitempty"`
}

Request Object

func (PutRecordsRequest) String 

func (o PutRecordsRequest) String() string

type PutRecordsRequestBody 

type PutRecordsRequestBody struct {
	StreamName string `json:"stream_name"`

	StreamId *string `json:"stream_id,omitempty"`

	Records []PutRecordsRequestEntry `json:"records"`
}

func (PutRecordsRequestBody) String 

func (o PutRecordsRequestBody) String() string

type PutRecordsRequestEntry 

type PutRecordsRequestEntry struct {
	Data **os.File `json:"data"`

	ExplicitHashKey *string `json:"explicit_hash_key,omitempty"`

	PartitionId *string `json:"partition_id,omitempty"`

	PartitionKey *string `json:"partition_key,omitempty"`

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

func (PutRecordsRequestEntry) String 

func (o PutRecordsRequestEntry) 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 {
	PartitionId *string `json:"partition_id,omitempty"`

	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 {
	PartitionKey *string `json:"partition_key,omitempty"`

	SequenceNumber *string `json:"sequence_number,omitempty"`

	Data **os.File `json:"data,omitempty"`

	Timestamp *int64 `json:"timestamp,omitempty"`

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

	CreateTime *int64 `json:"create_time,omitempty"`

	RetentionPeriod *int32 `json:"retention_period,omitempty"`

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

	StreamType *StreamInfoStreamType `json:"stream_type,omitempty"`

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

	PartitionCount *int32 `json:"partition_count,omitempty"`

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

	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 {
	Key *SysTagKey `json:"key,omitempty"`

	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 {
	Key *string `json:"key,omitempty"`

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

func (Tag) String 

func (o Tag) String() string

type TransferTask 

type TransferTask struct {
	TaskName *string `json:"task_name,omitempty"`

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

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

	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 *UpdatePartitionCountRequestBody `json:"body,omitempty"`
}

Request Object

func (UpdatePartitionCountRequest) String 

func (o UpdatePartitionCountRequest) String() string

type UpdatePartitionCountRequestBody 

type UpdatePartitionCountRequestBody struct {
	StreamName string `json:"stream_name"`

	TargetPartitionCount int32 `json:"target_partition_count"`
}

func (UpdatePartitionCountRequestBody) String 

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

	DataDuration *int32 `json:"data_duration,omitempty"`

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

	DataSchema *string `json:"data_schema,omitempty"`

	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.