Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

model

package

Go to main page

Versions in this module

v0

v0.0.73

Dec 25, 2021

v0.0.72

Dec 17, 2021

v0.0.71

Dec 10, 2021

v0.0.70

Nov 29, 2021

v0.0.69

Nov 25, 2021

v0.0.68

Nov 12, 2021

v0.0.67

Oct 25, 2021

v0.0.66

Oct 19, 2021

v0.0.65

Oct 11, 2021

v0.0.64

Sep 29, 2021

v0.0.63

Sep 26, 2021

v0.0.62

Sep 24, 2021

v0.0.61

Sep 24, 2021

v0.0.60

Sep 16, 2021

v0.0.59

Sep 10, 2021

v0.0.58

Aug 31, 2021

v0.0.57

Aug 25, 2021

v0.0.56

Aug 17, 2021

v0.0.55

Aug 10, 2021

v0.0.54

Jul 27, 2021

v0.0.53

Jul 26, 2021

v0.0.52

Jul 16, 2021

v0.0.51

Jul 9, 2021

v0.0.50

Jun 29, 2021

v0.0.49

Jun 25, 2021

v0.0.48

Jun 21, 2021

v0.0.47

Jun 10, 2021

v0.0.46

Jun 4, 2021

v0.0.45

May 25, 2021

Changes in this version

+ type CommitCheckpointRequest struct

+ Body *CommitCheckpointRequestBody

+ func (o CommitCheckpointRequest) String() string

+ type CommitCheckpointRequestBody struct

+ AppName string

+ CheckpointType CommitCheckpointRequestBodyCheckpointType

+ Metadata *string

+ PartitionId string

+ SequenceNumber string

+ StreamName string

+ func (o CommitCheckpointRequestBody) String() string

+ type CommitCheckpointRequestBodyCheckpointType struct

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

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

+ type CommitCheckpointRequestBodyCheckpointTypeEnum struct

+ LAST_READ CommitCheckpointRequestBodyCheckpointType

+ func GetCommitCheckpointRequestBodyCheckpointTypeEnum() CommitCheckpointRequestBodyCheckpointTypeEnum

+ type CommitCheckpointResponse struct

+ HttpStatusCode int

+ func (o CommitCheckpointResponse) String() string

+ type CreateAppRequest struct

+ Body *CreateAppRequestBody

+ func (o CreateAppRequest) String() string

+ type CreateAppRequestBody struct

+ AppName string

+ func (o CreateAppRequestBody) String() string

+ type CreateAppResponse struct

+ HttpStatusCode int

+ func (o CreateAppResponse) String() string

+ type CreateAppV3Request struct

+ Body *CreateAppRequestBody

+ func (o CreateAppV3Request) String() string

+ type CreateAppV3Response struct

+ HttpStatusCode int

+ func (o CreateAppV3Response) String() string

+ type CreatePoliciesV3Request struct

+ Body *CreatePolicyRuleRequest

+ StreamName string

+ func (o CreatePoliciesV3Request) String() string

+ type CreatePoliciesV3Response struct

+ HttpStatusCode int

+ func (o CreatePoliciesV3Response) String() string

+ type CreatePolicyRuleRequest struct

+ ActionType CreatePolicyRuleRequestActionType

+ Effect CreatePolicyRuleRequestEffect

+ PrincipalName string

+ StreamId string

+ func (o CreatePolicyRuleRequest) String() string

+ type CreatePolicyRuleRequestActionType struct

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

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

+ type CreatePolicyRuleRequestActionTypeEnum struct

+ GET_RECORDS CreatePolicyRuleRequestActionType

+ PUT_RECORDS CreatePolicyRuleRequestActionType

+ func GetCreatePolicyRuleRequestActionTypeEnum() CreatePolicyRuleRequestActionTypeEnum

+ type CreatePolicyRuleRequestEffect struct

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

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

+ type CreatePolicyRuleRequestEffectEnum struct

+ ACCEPT CreatePolicyRuleRequestEffect

+ func GetCreatePolicyRuleRequestEffectEnum() CreatePolicyRuleRequestEffectEnum

+ type CreateStreamReq struct

+ AutoScaleEnabled *bool

+ AutoScaleMaxPartitionCount *int32

+ AutoScaleMinPartitionCount *int64

+ CompressionFormat *CreateStreamReqCompressionFormat

+ CsvProperties *CsvProperties

+ DataDuration *int32

+ DataSchema *string

+ DataType *CreateStreamReqDataType

+ PartitionCount int32

+ StreamName string

+ StreamType *CreateStreamReqStreamType

+ SysTags *[]SysTag

+ Tags *[]Tag

+ func (o CreateStreamReq) String() string

+ type CreateStreamReqCompressionFormat struct

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

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

+ type CreateStreamReqCompressionFormatEnum struct

+ GZIP CreateStreamReqCompressionFormat

+ SNAPPY CreateStreamReqCompressionFormat

+ ZIP CreateStreamReqCompressionFormat

+ func GetCreateStreamReqCompressionFormatEnum() CreateStreamReqCompressionFormatEnum

+ type CreateStreamReqDataType struct

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

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

+ type CreateStreamReqDataTypeEnum struct

+ BLOB CreateStreamReqDataType

+ CSV CreateStreamReqDataType

+ JSON CreateStreamReqDataType

+ func GetCreateStreamReqDataTypeEnum() CreateStreamReqDataTypeEnum

+ type CreateStreamReqStreamType struct

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

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

+ type CreateStreamReqStreamTypeEnum struct

+ ADVANCED CreateStreamReqStreamType

+ COMMON CreateStreamReqStreamType

+ func GetCreateStreamReqStreamTypeEnum() CreateStreamReqStreamTypeEnum

+ type CreateStreamRequest struct

+ Body *CreateStreamReq

+ func (o CreateStreamRequest) String() string

+ type CreateStreamResponse struct

+ HttpStatusCode int

+ func (o CreateStreamResponse) String() string

+ type CreateTransferTaskRequest struct

+ Body *CreateTransferTaskRequest

+ StreamName string

+ func (o CreateTransferTaskRequest) String() string

+ type CreateTransferTaskResponse struct

+ HttpStatusCode int

+ func (o CreateTransferTaskResponse) String() string

+ type CreateTransferTaskV3Request struct

+ Body *CreateTransferTaskRequest

+ StreamName string

+ func (o CreateTransferTaskV3Request) String() string

+ type CreateTransferTaskV3Response struct

+ HttpStatusCode int

+ func (o CreateTransferTaskV3Response) String() string

+ type CsvProperties struct

+ Delimiter *string

+ func (o CsvProperties) String() string

+ type DeleteAppRequest struct

+ AppName string

+ func (o DeleteAppRequest) String() string

+ type DeleteAppResponse struct

+ HttpStatusCode int

+ func (o DeleteAppResponse) String() string

+ type DeleteCheckpointRequest struct

+ AppName string

+ CheckpointType DeleteCheckpointRequestCheckpointType

+ PartitionId *string

+ StreamName string

+ func (o DeleteCheckpointRequest) String() string

+ type DeleteCheckpointRequestCheckpointType struct

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

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

+ type DeleteCheckpointRequestCheckpointTypeEnum struct

+ LAST_READ DeleteCheckpointRequestCheckpointType

+ func GetDeleteCheckpointRequestCheckpointTypeEnum() DeleteCheckpointRequestCheckpointTypeEnum

+ type DeleteCheckpointResponse struct

+ HttpStatusCode int

+ func (o DeleteCheckpointResponse) String() string

+ type DeleteStreamRequest struct

+ StreamName string

+ func (o DeleteStreamRequest) String() string

+ type DeleteStreamResponse struct

+ HttpStatusCode int

+ func (o DeleteStreamResponse) String() string

+ type DeleteStreamV3Request struct

+ StreamName string

+ func (o DeleteStreamV3Request) String() string

+ type DeleteStreamV3Response struct

+ HttpStatusCode int

+ func (o DeleteStreamV3Response) String() string

+ type DeleteTransferTaskRequest struct

+ StreamName string

+ TaskName string

+ func (o DeleteTransferTaskRequest) String() string

+ type DeleteTransferTaskResponse struct

+ HttpStatusCode int

+ func (o DeleteTransferTaskResponse) String() string

+ type DeleteTransferTaskV3Request struct

+ StreamName string

+ TaskName string

+ func (o DeleteTransferTaskV3Request) String() string

+ type DeleteTransferTaskV3Response struct

+ HttpStatusCode int

+ func (o DeleteTransferTaskV3Response) String() string

+ type DescribeAppRequest struct

+ AppName string

+ func (o DescribeAppRequest) String() string

+ type DescribeAppResponse struct

+ AppId *string

+ AppName *string

+ CreateTime *int64

+ HttpStatusCode int

+ func (o DescribeAppResponse) String() string

+ type DescribeAppResult struct

+ AppId *string

+ AppName *string

+ CreateTime *int64

+ func (o DescribeAppResult) String() string

+ type DescribeStreamRequest struct

+ LimitPartitions *int32

+ StartPartitionId *string

+ StreamName string

+ func (o DescribeStreamRequest) String() string

+ type DescribeStreamResponse struct

+ AutoScaleEnabled *bool

+ AutoScaleMaxPartitionCount *int32

+ AutoScaleMinPartitionCount *int32

+ CompressionFormat *DescribeStreamResponseCompressionFormat

+ CreateTime *int64

+ CsvProperties *CsvProperties

+ DataSchema *string

+ DataType *DescribeStreamResponseDataType

+ HasMorePartitions *bool

+ HttpStatusCode int

+ LastModifiedTime *int64

+ Partitions *[]PartitionResult

+ ReadablePartitionCount *int32

+ RetentionPeriod *int32

+ Status *DescribeStreamResponseStatus

+ StreamId *string

+ StreamName *string

+ StreamType *DescribeStreamResponseStreamType

+ Tags *[]Tag

+ UpdatePartitionCounts *[]UpdatePartitionCount

+ WritablePartitionCount *int32

+ func (o DescribeStreamResponse) String() string

+ type DescribeStreamResponseCompressionFormat struct

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

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

+ type DescribeStreamResponseCompressionFormatEnum struct

+ GZIP DescribeStreamResponseCompressionFormat

+ SNAPPY DescribeStreamResponseCompressionFormat

+ ZIP DescribeStreamResponseCompressionFormat

+ func GetDescribeStreamResponseCompressionFormatEnum() DescribeStreamResponseCompressionFormatEnum

+ type DescribeStreamResponseDataType struct

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

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

+ type DescribeStreamResponseDataTypeEnum struct

+ BLOB DescribeStreamResponseDataType

+ CSV DescribeStreamResponseDataType

+ JSON DescribeStreamResponseDataType

+ func GetDescribeStreamResponseDataTypeEnum() DescribeStreamResponseDataTypeEnum

+ type DescribeStreamResponseStatus struct

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

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

+ type DescribeStreamResponseStatusEnum struct

+ CREATING DescribeStreamResponseStatus

+ FROZEN DescribeStreamResponseStatus

+ RUNNING DescribeStreamResponseStatus

+ TERMINATING DescribeStreamResponseStatus

+ func GetDescribeStreamResponseStatusEnum() DescribeStreamResponseStatusEnum

+ type DescribeStreamResponseStreamType struct

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

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

+ type DescribeStreamResponseStreamTypeEnum struct

+ ADVANCED DescribeStreamResponseStreamType

+ COMMON DescribeStreamResponseStreamType

+ func GetDescribeStreamResponseStreamTypeEnum() DescribeStreamResponseStreamTypeEnum

+ type GetCheckpointRequest struct

+ AppName string

+ CheckpointType GetCheckpointRequestCheckpointType

+ PartitionId string

+ StreamName string

+ func (o GetCheckpointRequest) String() string

+ type GetCheckpointRequestCheckpointType struct

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

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

+ type GetCheckpointRequestCheckpointTypeEnum struct

+ LAST_READ GetCheckpointRequestCheckpointType

+ func GetGetCheckpointRequestCheckpointTypeEnum() GetCheckpointRequestCheckpointTypeEnum

+ type GetCheckpointResponse struct

+ HttpStatusCode int

+ Metadata *string

+ SequenceNumber *string

+ func (o GetCheckpointResponse) String() string

+ type GetCursorRequest struct

+ CursorType *GetCursorRequestCursorType

+ PartitionId string

+ StartingSequenceNumber *string

+ StreamName string

+ Timestamp *int64

+ func (o GetCursorRequest) String() string

+ type GetCursorRequestCursorType struct

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

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

+ type GetCursorRequestCursorTypeEnum struct

+ AFTER_SEQUENCE_NUMBER GetCursorRequestCursorType

+ AT_SEQUENCE_NUMBER GetCursorRequestCursorType

+ AT_TIMESTAMP GetCursorRequestCursorType

+ LATEST GetCursorRequestCursorType

+ TRIM_HORIZON GetCursorRequestCursorType

+ func GetGetCursorRequestCursorTypeEnum() GetCursorRequestCursorTypeEnum

+ type GetCursorResponse struct

+ HttpStatusCode int

+ PartitionCursor *string

+ func (o GetCursorResponse) String() string

+ type GetRecordsRequest struct

+ MaxFetchBytes *int32

+ PartitionCursor string

+ func (o GetRecordsRequest) String() string

+ type GetRecordsResponse struct

+ HttpStatusCode int

+ NextPartitionCursor *string

+ Records *[]Record

+ func (o GetRecordsResponse) String() string

+ type ListAppRequest struct

+ Limit *int32

+ StartAppName *string

+ StreamName *string

+ func (o ListAppRequest) String() string

+ type ListAppResponse struct

+ Apps *[]DescribeAppResult

+ HasMoreApp *bool

+ HttpStatusCode int

+ func (o ListAppResponse) String() string

+ type ListAppV3Request struct

+ Limit *int32

+ StartAppName *string

+ StreamName *string

+ func (o ListAppV3Request) String() string

+ type ListAppV3Response struct

+ Apps *[]DescribeAppResult

+ HasMoreApp *bool

+ HttpStatusCode int

+ func (o ListAppV3Response) String() string

+ type ListPoliciesV3Request struct

+ StreamName string

+ func (o ListPoliciesV3Request) String() string

+ type ListPoliciesV3Response struct

+ HttpStatusCode int

+ Rules *[]PrincipalRule

+ StreamId *string

+ func (o ListPoliciesV3Response) String() string

+ type ListStreamsRequest struct

+ Limit *int32

+ StartStreamName *string

+ func (o ListStreamsRequest) String() string

+ type ListStreamsResponse struct

+ HasMoreStreams *bool

+ HttpStatusCode int

+ StreamInfoList *[]StreamInfo

+ StreamNames *[]string

+ TotalNumber *int64

+ func (o ListStreamsResponse) String() string

+ type ListTransferTasksV3Request struct

+ StreamName string

+ func (o ListTransferTasksV3Request) String() string

+ type ListTransferTasksV3Response struct

+ HttpStatusCode int

+ Tasks *[]TransferTask

+ TotalNumber *int32

+ func (o ListTransferTasksV3Response) String() string

+ type PartitionResult struct

+ HashRange *string

+ ParentPartitions *string

+ PartitionId *string

+ SequenceNumberRange *string

+ Status *PartitionResultStatus

+ func (o PartitionResult) String() string

+ type PartitionResultStatus struct

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

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

+ type PartitionResultStatusEnum struct

+ ACTIVE PartitionResultStatus

+ CREATING PartitionResultStatus

+ DELETED PartitionResultStatus

+ EXPIRED PartitionResultStatus

+ func GetPartitionResultStatusEnum() PartitionResultStatusEnum

+ type PrincipalRule struct

+ ActionType *PrincipalRuleActionType

+ Effect *PrincipalRuleEffect

+ Principal *string

+ PrincipalName *string

+ func (o PrincipalRule) String() string

+ type PrincipalRuleActionType struct

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

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

+ type PrincipalRuleActionTypeEnum struct

+ PUT_RECORDS PrincipalRuleActionType

+ func GetPrincipalRuleActionTypeEnum() PrincipalRuleActionTypeEnum

+ type PrincipalRuleEffect struct

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

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

+ type PrincipalRuleEffectEnum struct

+ ACCEPT PrincipalRuleEffect

+ func GetPrincipalRuleEffectEnum() PrincipalRuleEffectEnum

+ type PutRecordsRequest struct

+ Body *PutRecordsRequestBody

+ func (o PutRecordsRequest) String() string

+ type PutRecordsRequestBody struct

+ Records []PutRecordsRequestEntry

+ StreamId *string

+ StreamName string

+ func (o PutRecordsRequestBody) String() string

+ type PutRecordsRequestEntry struct

+ Data **os.File

+ ExplicitHashKey *string

+ PartitionId *string

+ PartitionKey *string

+ Timestamp *int64

+ func (o PutRecordsRequestEntry) String() string

+ type PutRecordsResponse struct

+ FailedRecordCount *int32

+ HttpStatusCode int

+ Records *[]PutRecordsResultEntry

+ func (o PutRecordsResponse) String() string

+ type PutRecordsResultEntry struct

+ ErrorCode *string

+ ErrorMessage *string

+ PartitionId *string

+ SequenceNumber *string

+ func (o PutRecordsResultEntry) String() string

+ type Record struct

+ Data **os.File

+ PartitionKey *string

+ SequenceNumber *string

+ Timestamp *int64

+ TimestampType *string

+ func (o Record) String() string

+ type StreamInfo struct

+ AutoScaleEnabled *bool

+ AutoScaleMaxPartitionCount *int32

+ AutoScaleMinPartitionCount *int32

+ CreateTime *int64

+ DataType *StreamInfoDataType

+ PartitionCount *int32

+ RetentionPeriod *int32

+ Status *StreamInfoStatus

+ StreamName *string

+ StreamType *StreamInfoStreamType

+ Tags *[]Tag

+ func (o StreamInfo) String() string

+ type StreamInfoDataType struct

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

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

+ type StreamInfoDataTypeEnum struct

+ BLOB StreamInfoDataType

+ CSV StreamInfoDataType

+ JSON StreamInfoDataType

+ func GetStreamInfoDataTypeEnum() StreamInfoDataTypeEnum

+ type StreamInfoStatus struct

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

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

+ type StreamInfoStatusEnum struct

+ CREATING StreamInfoStatus

+ FROZEN StreamInfoStatus

+ RUNNING StreamInfoStatus

+ TERMINATING StreamInfoStatus

+ func GetStreamInfoStatusEnum() StreamInfoStatusEnum

+ type StreamInfoStreamType struct

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

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

+ type StreamInfoStreamTypeEnum struct

+ ADVANCED StreamInfoStreamType

+ COMMON StreamInfoStreamType

+ func GetStreamInfoStreamTypeEnum() StreamInfoStreamTypeEnum

+ type SysTag struct

+ Key *SysTagKey

+ Value *string

+ func (o SysTag) String() string

+ type SysTagKey struct

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

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

+ type SysTagKeyEnum struct

+ SYS_ENTERPRISE_PROJECT_ID SysTagKey

+ func GetSysTagKeyEnum() SysTagKeyEnum

+ type Tag struct

+ Key *string

+ Value *string

+ func (o Tag) String() string

+ type TransferTask struct

+ CreateTime *int64

+ DestinationType *TransferTaskDestinationType

+ LastTransferTimestamp *int64

+ State *TransferTaskState

+ TaskName *string

+ func (o TransferTask) String() string

+ type TransferTaskDestinationType struct

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

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

+ type TransferTaskDestinationTypeEnum struct

+ CLOUDTABLE TransferTaskDestinationType

+ DLI TransferTaskDestinationType

+ DWS TransferTaskDestinationType

+ MRS TransferTaskDestinationType

+ OBS TransferTaskDestinationType

+ func GetTransferTaskDestinationTypeEnum() TransferTaskDestinationTypeEnum

+ type TransferTaskState struct

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

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

+ type TransferTaskStateEnum struct

+ ABNORMAL TransferTaskState

+ DELETE TransferTaskState

+ ERROR TransferTaskState

+ PAUSED TransferTaskState

+ RUNNING TransferTaskState

+ STARTING TransferTaskState

+ func GetTransferTaskStateEnum() TransferTaskStateEnum

+ type UpdatePartitionCount struct

+ AutoScale *bool

+ CreateTimestamp *int64

+ ResultCode *int32

+ ResultMsg *int32

+ SrcPartitionCount *int32

+ TargetPartitionCount *int32

+ func (o UpdatePartitionCount) String() string

+ type UpdatePartitionCountRequest struct

+ Body *UpdatePartitionCountRequestBody

+ StreamName string

+ func (o UpdatePartitionCountRequest) String() string

+ type UpdatePartitionCountRequestBody struct

+ StreamName string

+ TargetPartitionCount int32

+ func (o UpdatePartitionCountRequestBody) String() string

+ type UpdatePartitionCountResponse struct

+ HttpStatusCode int

+ func (o UpdatePartitionCountResponse) String() string

+ type UpdateStreamRequest struct

+ AutoScaleEnabled *bool

+ AutoScaleMaxPartitionCount *int64

+ AutoScaleMinPartitionCount *int64

+ DataDuration *int32

+ DataSchema *string

+ DataType *UpdateStreamRequestDataType

+ StreamName *string

+ TargetPartitionCount *int64

+ func (o UpdateStreamRequest) String() string

+ type UpdateStreamRequestDataType struct

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

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

+ type UpdateStreamRequestDataTypeEnum struct

+ BLOB UpdateStreamRequestDataType

+ CSV UpdateStreamRequestDataType

+ JSON UpdateStreamRequestDataType

+ func GetUpdateStreamRequestDataTypeEnum() UpdateStreamRequestDataTypeEnum

+ type UpdateStreamV3Request struct

+ Body *UpdateStreamRequest

+ StreamName string

+ func (o UpdateStreamV3Request) String() string

+ type UpdateStreamV3Response struct

+ HttpStatusCode int

+ func (o UpdateStreamV3Response) String() string

v0.0.43-rc

May 14, 2021

v0.0.42-rc

May 10, 2021

v0.0.41-rc

Apr 30, 2021

v0.0.40-rc

Apr 15, 2021

v0.0.39-rc

Mar 30, 2021

v0.0.38-rc

Mar 26, 2021

v0.0.37-rc.1

Mar 23, 2021

v0.0.37-rc

Mar 20, 2021

v0.0.36-rc

Mar 16, 2021

v0.0.35-rc

Mar 15, 2021

v0.0.34-rc.1

Mar 2, 2021

v0.0.34-rc

Feb 27, 2021

v0.0.33-rc

Feb 7, 2021

v0.0.32-rc.1

Feb 4, 2021

v0.0.32-rc

Jan 30, 2021

v0.0.31-rc

Jan 25, 2021

v0.0.30-rc.1

Jan 21, 2021

v0.0.30-rc

Jan 16, 2021

v0.0.29-beta

Dec 31, 2020