model

package

Go to main page

Versions in this module

v0

v0.1.121

Nov 7, 2024

v0.1.120

Oct 31, 2024

v0.1.119

Oct 24, 2024

v0.1.118

Oct 17, 2024

v0.1.117

Oct 10, 2024

v0.1.116

Sep 26, 2024

v0.1.115

Sep 23, 2024

v0.1.114

Sep 12, 2024

v0.1.113

Sep 5, 2024

v0.1.112

Aug 29, 2024

v0.1.111

Aug 22, 2024

v0.1.110

Aug 15, 2024

v0.1.109

Aug 8, 2024

v0.1.108

Aug 1, 2024

v0.1.107

Jul 25, 2024

v0.1.106

Jul 18, 2024

v0.1.105

Jul 11, 2024

Changes in this version

type CreateInstanceByEngineReqProductIdEnum

+ C6_12U24G_CLUSTER_TAGHWSHWS_EUHWS_HKOCBHWS_OCBCTCG42HK_G42TMSBCHK_SBCHK_TM_C6_16U64G_CLUSTER_X86_TAGHCSFCS CreateInstanceByEngineReqProductId

+ C6_16U32G_CLUSTER_TAGHWSHWS_EUHWS_HKOCBHWS_OCBCTCG42HK_G42TMSBCHK_SBCHK_TM_C6_32U128G_CLUSTER_X86_TAGHCSFCS CreateInstanceByEngineReqProductId

+ C6_16U64G_CLUSTER_ARM_TAGHCSFCS CreateInstanceByEngineReqProductId

+ C6_32U128G_CLUSTER_ARM_TAGHCSFCS CreateInstanceByEngineReqProductId

+ C6_4U16G_CLUSTER_ARM_TAGHCSFCS CreateInstanceByEngineReqProductId

+ C6_4U8G_CLUSTER_TAGHWSHWS_EUHWS_HKOCBHWS_OCBCTCG42HK_G42TMSBCHK_SBCHK_TM_C6_4U16G_CLUSTER_X86_TAGHCSFCS CreateInstanceByEngineReqProductId

+ C6_8U16G_CLUSTER_TAGHWSHWS_EUHWS_HKOCBHWS_OCBCTCG42HK_G42TMSBCHK_SBCHK_TM_C6_8U32G_CLUSTER_X86_TAGHCSFCS CreateInstanceByEngineReqProductId

+ C6_8U32G_CLUSTER_ARM_TAGHCSFCS CreateInstanceByEngineReqProductId

type CreatePostPaidInstanceReqProductIdEnum

+ C6_12U24G_CLUSTER_TAGHWSHWS_EUHWS_HKOCBHWS_OCBCTCG42HK_G42TMSBCHK_SBCHK_TM_C6_16U64G_CLUSTER_X86_TAGHCSFCS CreatePostPaidInstanceReqProductId

+ C6_16U32G_CLUSTER_TAGHWSHWS_EUHWS_HKOCBHWS_OCBCTCG42HK_G42TMSBCHK_SBCHK_TM_C6_32U128G_CLUSTER_X86_TAGHCSFCS CreatePostPaidInstanceReqProductId

+ C6_16U64G_CLUSTER_ARM_TAGHCSFCS CreatePostPaidInstanceReqProductId

+ C6_32U128G_CLUSTER_ARM_TAGHCSFCS CreatePostPaidInstanceReqProductId

+ C6_4U16G_CLUSTER_ARM_TAGHCSFCS CreatePostPaidInstanceReqProductId

+ C6_4U8G_CLUSTER_TAGHWSHWS_EUHWS_HKOCBHWS_OCBCTCG42HK_G42TMSBCHK_SBCHK_TM_C6_4U16G_CLUSTER_X86_TAGHCSFCS CreatePostPaidInstanceReqProductId

+ C6_8U16G_CLUSTER_TAGHWSHWS_EUHWS_HKOCBHWS_OCBCTCG42HK_G42TMSBCHK_SBCHK_TM_C6_8U32G_CLUSTER_X86_TAGHCSFCS CreatePostPaidInstanceReqProductId

+ C6_8U32G_CLUSTER_ARM_TAGHCSFCS CreatePostPaidInstanceReqProductId

v0.1.104

Jul 4, 2024

v0.1.103

Jun 27, 2024

v0.1.102

Jun 20, 2024

v0.1.101

Jun 14, 2024

v0.1.100

Jun 13, 2024

v0.1.99

Jun 6, 2024

v0.1.98

May 30, 2024

v0.1.97

May 23, 2024

v0.1.96

May 16, 2024

v0.1.95

May 9, 2024

v0.1.94

Apr 30, 2024

Changes in this version

type CreateInstanceByEngineReqEngineVersionEnum

+ E_4_8_0_TAGHWSHWS_EUHWS_HKOCBHWS_OCBCTCG42HK_G42TMSBCHK_SBCHK_TM_5_X_TAGHCS CreateInstanceByEngineReqEngineVersion

type CreateInstanceByEngineReqProductIdEnum

+ C6_12U24G_CLUSTER_TAGHWSHWS_EUHWS_HKOCBHWS_OCBCTCG42HK_G42TMSBCHK_SBCHK_TM_C6_16U64G_CLUSTER_X86_TAGHCS CreateInstanceByEngineReqProductId

+ C6_16U32G_CLUSTER_TAGHWSHWS_EUHWS_HKOCBHWS_OCBCTCG42HK_G42TMSBCHK_SBCHK_TM_C6_32U128G_CLUSTER_X86_TAGHCS CreateInstanceByEngineReqProductId

+ C6_4U8G_CLUSTER_SMALL_TAGHWSHWS_EUHWS_HKOCBHWS_OCBCTCG42HK_G42TMSBCHK_SBCHK_TM_C6_2U8G_SINGLE_X86_TAGHCS CreateInstanceByEngineReqProductId

+ C6_4U8G_CLUSTER_TAGHWSHWS_EUHWS_HKOCBHWS_OCBCTCG42HK_G42TMSBCHK_SBCHK_TM_C6_4U16G_CLUSTER_X86_TAGHCS CreateInstanceByEngineReqProductId

+ C6_8U16G_CLUSTER_TAGHWSHWS_EUHWS_HKOCBHWS_OCBCTCG42HK_G42TMSBCHK_SBCHK_TM_C6_8U32G_CLUSTER_X86_TAGHCS CreateInstanceByEngineReqProductId

type CreatePostPaidInstanceReqEngineVersionEnum

+ E_4_8_0_TAGHWSHWS_EUHWS_HKOCBHWS_OCBCTCG42HK_G42TMSBCHK_SBCHK_TM_5_X_TAGHCS CreatePostPaidInstanceReqEngineVersion

type CreatePostPaidInstanceReqProductIdEnum

+ C6_12U24G_CLUSTER_TAGHWSHWS_EUHWS_HKOCBHWS_OCBCTCG42HK_G42TMSBCHK_SBCHK_TM_C6_16U64G_CLUSTER_X86_TAGHCS CreatePostPaidInstanceReqProductId

+ C6_16U32G_CLUSTER_TAGHWSHWS_EUHWS_HKOCBHWS_OCBCTCG42HK_G42TMSBCHK_SBCHK_TM_C6_32U128G_CLUSTER_X86_TAGHCS CreatePostPaidInstanceReqProductId

+ C6_4U8G_CLUSTER_TAGHWSHWS_EUHWS_HKOCBHWS_OCBCTCG42HK_G42TMSBCHK_SBCHK_TM_C6_4U16G_CLUSTER_X86_TAGHCS CreatePostPaidInstanceReqProductId

+ C6_8U16G_CLUSTER_TAGHWSHWS_EUHWS_HKOCBHWS_OCBCTCG42HK_G42TMSBCHK_SBCHK_TM_C6_8U32G_CLUSTER_X86_TAGHCS CreatePostPaidInstanceReqProductId

type CreateTopicOrBatchDeleteTopicReq

+ Queues *[]CreateTopicReqQueues

type CreateTopicReq

+ Queues *[]CreateTopicReqQueues

+ type CreateTopicReqQueues struct

+ Broker *string

+ QueueNum float32

+ func (o CreateTopicReqQueues) String() string

type ShowInstanceResp

+ AvailableZoneNames *[]string

+ EnterpriseProjectId *string

type ShowInstanceResponse

+ AvailableZoneNames *[]string

+ EnterpriseProjectId *string

v0.1.93

Apr 25, 2024

v0.1.92

Apr 18, 2024

v0.1.92-patch

Apr 23, 2024

v0.1.91

Apr 11, 2024

Changes in this version

type ListInstancesRequestEngineEnum

+ ROCKETMQ ListInstancesRequestEngine

v0.1.90

Apr 3, 2024

Changes in this version

type ListMessageTraceRespTraceTraceTypeEnum

+ SUB_AFTER ListMessageTraceRespTraceTraceType

+ SUB_BEFORE ListMessageTraceRespTraceTraceType

v0.1.89

Apr 1, 2024

v0.1.88

Mar 28, 2024

Changes in this version

type CreateInstanceByEngineReqEngineVersionEnum

+ E_4_8_0_TAGHWSHWS_EUHWS_HKOCBHWS_OCBCTCG42HK_G42TMHK_TM_5_X_TAGHCS CreateInstanceByEngineReqEngineVersion

type CreateInstanceByEngineReqProductIdEnum

+ C6_12U24G_CLUSTER_TAGHWSHWS_EUHWS_HKOCBHWS_OCBCTCG42HK_G42TMHK_TM_C6_16U64G_CLUSTER_X86_TAGHCS CreateInstanceByEngineReqProductId

+ C6_16U32G_CLUSTER_TAGHWSHWS_EUHWS_HKOCBHWS_OCBCTCG42HK_G42TMHK_TM_C6_32U128G_CLUSTER_X86_TAGHCS CreateInstanceByEngineReqProductId

+ C6_16U64G_CLUSTER_ARM_TAGHCS CreateInstanceByEngineReqProductId

+ C6_2U8G_SINGLE_ARM_TAGHCS CreateInstanceByEngineReqProductId

+ C6_32U128G_CLUSTER_ARM_TAGHCS CreateInstanceByEngineReqProductId

+ C6_4U16G_CLUSTER_ARM_TAGHCS CreateInstanceByEngineReqProductId

+ C6_4U8G_CLUSTER_SMALL_TAGHWSHWS_EUHWS_HKOCBHWS_OCBCTCG42HK_G42TMHK_TM_C6_2U8G_SINGLE_X86_TAGHCS CreateInstanceByEngineReqProductId

+ C6_4U8G_CLUSTER_TAGHWSHWS_EUHWS_HKOCBHWS_OCBCTCG42HK_G42TMHK_TM_C6_4U16G_CLUSTER_X86_TAGHCS CreateInstanceByEngineReqProductId

+ C6_8U16G_CLUSTER_TAGHWSHWS_EUHWS_HKOCBHWS_OCBCTCG42HK_G42TMHK_TM_C6_8U32G_CLUSTER_X86_TAGHCS CreateInstanceByEngineReqProductId

+ C6_8U32G_CLUSTER_ARM_TAGHCS CreateInstanceByEngineReqProductId

+ type CreateOrUpdateConsumerGroup struct

+ Broadcast *bool

+ Brokers *[]string

+ ConsumeOrderly *bool

+ Enabled *bool

+ GroupDesc *string

+ Name *string

+ RetryMaxTime *int32

+ func (o CreateOrUpdateConsumerGroup) String() string

type CreatePostPaidInstanceReqEngineVersionEnum

+ E_4_8_0_TAGHWSHWS_EUHWS_HKOCBHWS_OCBCTCG42HK_G42TMHK_TM_5_X_TAGHCS CreatePostPaidInstanceReqEngineVersion

type CreatePostPaidInstanceReqProductIdEnum

+ C6_12U24G_CLUSTER_TAGHWSHWS_EUHWS_HKOCBHWS_OCBCTCG42HK_G42TMHK_TM_C6_16U64G_CLUSTER_X86_TAGHCS CreatePostPaidInstanceReqProductId

+ C6_16U32G_CLUSTER_TAGHWSHWS_EUHWS_HKOCBHWS_OCBCTCG42HK_G42TMHK_TM_C6_32U128G_CLUSTER_X86_TAGHCS CreatePostPaidInstanceReqProductId

+ C6_16U64G_CLUSTER_ARM_TAGHCS CreatePostPaidInstanceReqProductId

+ C6_32U128G_CLUSTER_ARM_TAGHCS CreatePostPaidInstanceReqProductId

+ C6_4U16G_CLUSTER_ARM_TAGHCS CreatePostPaidInstanceReqProductId

+ C6_4U8G_CLUSTER_TAGHWSHWS_EUHWS_HKOCBHWS_OCBCTCG42HK_G42TMHK_TM_C6_4U16G_CLUSTER_X86_TAGHCS CreatePostPaidInstanceReqProductId

+ C6_8U16G_CLUSTER_TAGHWSHWS_EUHWS_HKOCBHWS_OCBCTCG42HK_G42TMHK_TM_C6_8U32G_CLUSTER_X86_TAGHCS CreatePostPaidInstanceReqProductId

+ C6_8U32G_CLUSTER_ARM_TAGHCS CreatePostPaidInstanceReqProductId

v0.1.87

Mar 21, 2024

v0.1.86

Mar 14, 2024

v0.1.85

Mar 7, 2024

v0.1.84

Feb 29, 2024

v0.1.83

Feb 22, 2024

v0.1.82

Feb 20, 2024

v0.1.81

Feb 7, 2024

v0.1.80

Feb 1, 2024

Changes in this version

type ConsumerGroup

+ ConsumeOrderly *bool

+ CreatedAt *string

+ Permissions *[]string

type CreateConsumerGroupOrBatchDeleteConsumerGroupReq

+ ConsumeOrderly *bool

+ CreatedAt *string

+ Permissions *[]string

v0.1.79

Jan 25, 2024

v0.1.78

Jan 18, 2024

Changes in this version

type ResendReq

+ Topic *string

v0.1.77

Jan 11, 2024

v0.1.76

Jan 4, 2024

Changes in this version

type ResizeEngineInstanceReq

+ PublicipId *string

v0.1.75

Dec 27, 2023

v0.1.74

Dec 22, 2023

v0.1.73

Dec 21, 2023

v0.1.72

Dec 14, 2023

Changes in this version

+ type CreateRocketMqMigrationTaskReq struct

+ Bindings *[]MigrationRabbitBindingMetadata

+ Exchanges *[]MigrationRabbitExchangeMetadata

+ Queues *[]MigrationRabbitQueueMetadata

+ SubscriptionGroupTable map[string]MigrationRocketMqSubscriptionGroup

+ TopicConfigTable map[string]MigrationRocketMqTopicConfig

+ Vhosts *[]MigrationRabbitVhostMetadata

+ func (o CreateRocketMqMigrationTaskReq) String() string

+ type MigrationRabbitBindingMetadata struct

+ Destination *string

+ DestinationType *string

+ RoutingKey *string

+ Source *string

+ Vhost *string

+ func (o MigrationRabbitBindingMetadata) String() string

+ type MigrationRabbitExchangeMetadata struct

+ Durable *bool

+ Name *string

+ Type *string

+ Vhost *string

+ func (o MigrationRabbitExchangeMetadata) String() string

+ type MigrationRabbitQueueMetadata struct

+ Durable *bool

+ Name *string

+ Vhost *string

+ func (o MigrationRabbitQueueMetadata) String() string

+ type MigrationRabbitVhostMetadata struct

+ Name *string

+ func (o MigrationRabbitVhostMetadata) String() string

+ type MigrationRocketMqSubscriptionGroup struct

+ ConsumeBroadcastEnable *bool

+ ConsumeEnable *bool

+ ConsumeFromMinEnable *bool

+ GroupName *string

+ NotifyConsumerIdsChangedEnable *bool

+ RetryMaxTimes *int32

+ RetryQueueNums *int32

+ WhichBrokerWhenConsumeSlow *int64

+ func (o MigrationRocketMqSubscriptionGroup) String() string

+ type MigrationRocketMqTopicConfig struct

+ Order *bool

+ Perm *int32

+ ReadQueueNums *int32

+ TopicFilterType *string

+ TopicName *string

+ TopicSysFlag *int32

+ WriteQueueNums *int32

+ func (o MigrationRocketMqTopicConfig) String() string

v0.1.71

Dec 7, 2023

Changes in this version

+ type ModifyConfigReq struct

+ RocketmqConfigs *[]RocketMqConfigReq

+ func (o ModifyConfigReq) String() string

+ type RocketMqConfigReq struct

+ Name *RocketMqConfigReqName

+ Value *string

+ func (o RocketMqConfigReq) String() string

+ type RocketMqConfigReqName struct

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

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

+ func (c RocketMqConfigReqName) Value() string

+ type RocketMqConfigReqNameEnum struct

+ FILE_RESERVED_TIME RocketMqConfigReqName

+ func GetRocketMqConfigReqNameEnum() RocketMqConfigReqNameEnum

+ type RocketMqConfigResp struct

+ ConfigType *string

+ DefaultValue *string

+ Name *string

+ ValidValues *string

+ Value *string

+ ValueType *string

+ func (o RocketMqConfigResp) String() string

+ type ShowRocketMqConfigsRequest struct

+ InstanceId string

+ func (o ShowRocketMqConfigsRequest) String() string

+ type ShowRocketMqConfigsResponse struct

+ HttpStatusCode int

+ RocketmqConfigs *[]RocketMqConfigResp

+ func (o ShowRocketMqConfigsResponse) String() string

+ type UpdateRocketMqConfigsRequest struct

+ Body *ModifyConfigReq

+ InstanceId string

+ func (o UpdateRocketMqConfigsRequest) String() string

+ type UpdateRocketMqConfigsResponse struct

+ HttpStatusCode int

+ func (o UpdateRocketMqConfigsResponse) String() string

v0.1.70

Nov 30, 2023

Changes in this version

+ type ResizeEngineInstanceReq struct

+ NewBrokerNum *int32

+ NewProductId *string

+ NewStorageSpace *int32

+ OperType string

+ func (o ResizeEngineInstanceReq) String() string

+ type ResizeInstanceRequest struct

+ Body *ResizeEngineInstanceReq

+ Engine string

+ InstanceId string

+ func (o ResizeInstanceRequest) String() string

+ type ResizeInstanceResponse struct

+ HttpStatusCode int

+ JobId *string

+ func (o ResizeInstanceResponse) String() string

+ type RocketMqExtendProductInfoEntity struct

+ ArchTypes *[]string

+ AvailableZones *[]string

+ BillingCode *string

+ ChargingMode *[]string

+ EcsFlavorId *string

+ Ios *[]RocketMqExtendProductIosEntity

+ ProductId *string

+ Properties *RocketMqExtendProductPropertiesEntity

+ QingtianIncompatible *bool

+ SupportFeatures *[]RocketMqProductSupportFeaturesEntity

+ Type *string

+ UnavailableZones *[]string

+ func (o RocketMqExtendProductInfoEntity) String() string

+ type RocketMqExtendProductIosEntity struct

+ AvailableZones *[]string

+ IoSpec *string

+ Type *string

+ UnavailableZones *[]string

+ func (o RocketMqExtendProductIosEntity) String() string

+ type RocketMqExtendProductPropertiesEntity struct

+ EngineVersions *string

+ MaxBroker *string

+ MaxConsumerPerBroker *string

+ MaxStoragePerNode *string

+ MaxTopicPerBroker *string

+ MinBroker *string

+ MinStoragePerNode *string

+ ProductAlias *string

+ func (o RocketMqExtendProductPropertiesEntity) String() string

+ type RocketMqProductSupportFeaturesEntity struct

+ Name *string

+ Properties map[string]string

+ func (o RocketMqProductSupportFeaturesEntity) String() string

+ type ShowEngineInstanceExtendProductInfoRequest struct

+ Engine string

+ InstanceId string

+ Type *ShowEngineInstanceExtendProductInfoRequestType

+ func (o ShowEngineInstanceExtendProductInfoRequest) String() string

+ type ShowEngineInstanceExtendProductInfoRequestType struct

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

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

+ func (c ShowEngineInstanceExtendProductInfoRequestType) Value() string

+ type ShowEngineInstanceExtendProductInfoRequestTypeEnum struct

+ ADVANCED ShowEngineInstanceExtendProductInfoRequestType

+ func GetShowEngineInstanceExtendProductInfoRequestTypeEnum() ShowEngineInstanceExtendProductInfoRequestTypeEnum

+ type ShowEngineInstanceExtendProductInfoResponse struct

+ Engine *string

+ HttpStatusCode int

+ Products *[]RocketMqExtendProductInfoEntity

+ Versions *[]string

+ func (o ShowEngineInstanceExtendProductInfoResponse) String() string

v0.1.69

Nov 23, 2023

v0.1.68

Nov 23, 2023

Changes in this version

type ListInstancesRequestStatusEnum

+ CONFIGURING ListInstancesRequestStatus

+ CREATEFAILED ListInstancesRequestStatus

+ DELETING ListInstancesRequestStatus

+ ERROR ListInstancesRequestStatus

+ EXTENDEDFAILED ListInstancesRequestStatus

+ EXTENDING ListInstancesRequestStatus

+ FREEZING ListInstancesRequestStatus

+ ROLLBACK ListInstancesRequestStatus

+ ROLLBACKFAILED ListInstancesRequestStatus

+ SHRINKING ListInstancesRequestStatus

+ UPGRADING ListInstancesRequestStatus

+ UPGRADINGFAILED ListInstancesRequestStatus

+ VOLUMETYPECHANGING ListInstancesRequestStatus

v0.1.67

Nov 16, 2023

v0.1.66

Nov 13, 2023

v0.1.65

Nov 9, 2023

v0.1.64

Nov 2, 2023

v0.1.63

Oct 26, 2023

Changes in this version

type ConsumerGroup

+ GroupDesc *string

type CreateConsumerGroupOrBatchDeleteConsumerGroupReq

+ GroupDesc *string

type ShowGroupResponse

+ GroupDesc *string

v0.1.62

Oct 19, 2023

v0.1.61

Oct 12, 2023

v0.1.60

Sep 19, 2023

Changes in this version

type CreateRocketMqMigrationTaskResponse

+ TaskId *string

+ type UpdateConsumerGroup struct

+ Broadcast bool

+ Brokers *[]string

+ Enabled bool

+ FromBeginning *bool

+ Name *string

+ RetryMaxTime float32

+ func (o UpdateConsumerGroup) String() string

v0.1.59

Sep 14, 2023

v0.1.58

Sep 7, 2023

v0.1.57

Aug 31, 2023

v0.1.56

Aug 24, 2023

v0.1.55

Aug 21, 2023

v0.1.54

Aug 17, 2023

v0.1.53

Aug 10, 2023

Changes in this version

type ConsumerDetailResp

+ ConsumerOffset *int64

+ Lag *int64

+ MaxOffset *int64

type CreatePostPaidInstanceReqEngineVersionEnum

+ E_5_X CreatePostPaidInstanceReqEngineVersion

type CreateTopicOrBatchDeleteTopicReq

+ MessageType *CreateTopicOrBatchDeleteTopicReqMessageType

+ type CreateTopicOrBatchDeleteTopicReqMessageType struct

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

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

+ func (c CreateTopicOrBatchDeleteTopicReqMessageType) Value() string

+ type CreateTopicOrBatchDeleteTopicReqMessageTypeEnum struct

+ DELAY CreateTopicOrBatchDeleteTopicReqMessageType

+ FIFO CreateTopicOrBatchDeleteTopicReqMessageType

+ NORMAL CreateTopicOrBatchDeleteTopicReqMessageType

+ TRANSACTION CreateTopicOrBatchDeleteTopicReqMessageType

+ func GetCreateTopicOrBatchDeleteTopicReqMessageTypeEnum() CreateTopicOrBatchDeleteTopicReqMessageTypeEnum

type CreateTopicReq

+ MessageType *CreateTopicReqMessageType

+ type CreateTopicReqMessageType struct

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

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

+ func (c CreateTopicReqMessageType) Value() string

+ type CreateTopicReqMessageTypeEnum struct

+ DELAY CreateTopicReqMessageType

+ FIFO CreateTopicReqMessageType

+ NORMAL CreateTopicReqMessageType

+ TRANSACTION CreateTopicReqMessageType

+ func GetCreateTopicReqMessageTypeEnum() CreateTopicReqMessageTypeEnum

type ShowConsumerListOrDetailsResponse

+ ConsumerOffset *int64

+ Lag *int64

+ MaxOffset *int64

type ShowInstanceResp

+ GrpcAddress *string

+ PublicGrpcAddress *string

type ShowInstanceResponse

+ GrpcAddress *string

+ PublicGrpcAddress *string

type ShowOneTopicResponse

+ MessageType *ShowOneTopicResponseMessageType

+ type ShowOneTopicResponseMessageType struct

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

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

+ func (c ShowOneTopicResponseMessageType) Value() string

+ type ShowOneTopicResponseMessageTypeEnum struct

+ DELAY ShowOneTopicResponseMessageType

+ FIFO ShowOneTopicResponseMessageType

+ NORMAL ShowOneTopicResponseMessageType

+ TRANSACTION ShowOneTopicResponseMessageType

+ func GetShowOneTopicResponseMessageTypeEnum() ShowOneTopicResponseMessageTypeEnum

type ShowTopicStatusResponse

+ MaxOffset *int32

+ MinOffset *int32

type Topic

+ MessageType *TopicMessageType

+ type TopicMessageType struct

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

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

+ func (c TopicMessageType) Value() string

+ type TopicMessageTypeEnum struct

+ DELAY TopicMessageType

+ FIFO TopicMessageType

+ NORMAL TopicMessageType

+ TRANSACTION TopicMessageType

+ func GetTopicMessageTypeEnum() TopicMessageTypeEnum

v0.1.52

Aug 3, 2023

Changes in this version

type ListMessagesRequest

+ Key *string

v0.1.51

Jul 31, 2023

v0.1.50

Jul 27, 2023

Changes in this version

+ type ListInstancesRequestEngine struct

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

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

+ func (c ListInstancesRequestEngine) Value() string

+ type ListInstancesRequestEngineEnum struct

+ RELIABILITY ListInstancesRequestEngine

+ func GetListInstancesRequestEngineEnum() ListInstancesRequestEngineEnum

+ type ValidateConsumedMessageRequestEngine struct

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

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

+ func (c ValidateConsumedMessageRequestEngine) Value() string

+ type ValidateConsumedMessageRequestEngineEnum struct

+ RELIABILITY ValidateConsumedMessageRequestEngine

+ func GetValidateConsumedMessageRequestEngineEnum() ValidateConsumedMessageRequestEngineEnum

v0.1.49

Jul 20, 2023

v0.1.48

Jul 13, 2023

v0.1.47

Jul 6, 2023

v0.1.46

Jun 29, 2023

v0.1.45

Jun 21, 2023

v0.1.44

Jun 15, 2023

Changes in this version

+ type SendDlqMessageRequestEngine struct

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

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

+ func (c SendDlqMessageRequestEngine) Value() string

+ type SendDlqMessageRequestEngineEnum struct

+ RELIABILITY SendDlqMessageRequestEngine

+ func GetSendDlqMessageRequestEngineEnum() SendDlqMessageRequestEngineEnum

v0.1.43

Jun 8, 2023

Changes in this version

type CreateInstanceByEngineReqProductIdEnum

+ C6_4U8G_CLUSTER_SMALL CreateInstanceByEngineReqProductId

+ type SendDlqMessageRequest struct

+ Body *DeadletterResendReq

+ Engine string

+ InstanceId string

+ func (o SendDlqMessageRequest) String() string

+ type SendDlqMessageResponse struct

+ HttpStatusCode int

+ ResendResults *[]DeadletterResendRespResendResults

+ func (o SendDlqMessageResponse) String() string

+ type ValidateConsumedMessageRequest struct

+ Body *ResendReq

+ Engine string

+ InstanceId string

+ func (o ValidateConsumedMessageRequest) String() string

+ type ValidateConsumedMessageResponse struct

+ HttpStatusCode int

+ ResendResults *[]DeadletterResendRespResendResults

+ func (o ValidateConsumedMessageResponse) String() string

v0.1.42

Jun 1, 2023

Changes in this version

+ type CreateRocketMqMigrationTaskRequest struct

+ Body *string

+ InstanceId string

+ Name string

+ Overwrite CreateRocketMqMigrationTaskRequestOverwrite

+ Type CreateRocketMqMigrationTaskRequestType

+ func (o CreateRocketMqMigrationTaskRequest) String() string

+ type CreateRocketMqMigrationTaskRequestOverwrite struct

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

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

+ func (c CreateRocketMqMigrationTaskRequestOverwrite) Value() string

+ type CreateRocketMqMigrationTaskRequestOverwriteEnum struct

+ FALSE CreateRocketMqMigrationTaskRequestOverwrite

+ TRUE CreateRocketMqMigrationTaskRequestOverwrite

+ func GetCreateRocketMqMigrationTaskRequestOverwriteEnum() CreateRocketMqMigrationTaskRequestOverwriteEnum

+ type CreateRocketMqMigrationTaskRequestType struct

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

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

+ func (c CreateRocketMqMigrationTaskRequestType) Value() string

+ type CreateRocketMqMigrationTaskRequestTypeEnum struct

+ KAFKA CreateRocketMqMigrationTaskRequestType

+ RABBIT_TO_ROCKET CreateRocketMqMigrationTaskRequestType

+ ROCKETMQ CreateRocketMqMigrationTaskRequestType

+ func GetCreateRocketMqMigrationTaskRequestTypeEnum() CreateRocketMqMigrationTaskRequestTypeEnum

+ type CreateRocketMqMigrationTaskResponse struct

+ Body *string

+ HttpStatusCode int

+ func (o CreateRocketMqMigrationTaskResponse) String() string

+ type DeadletterResendReq struct

+ MsgIdList *[]string

+ Topic *string

+ func (o DeadletterResendReq) String() string

+ type DeadletterResendRespResendResults struct

+ ErrorCode *string

+ ErrorMessage *string

+ MsgId *string

+ func (o DeadletterResendRespResendResults) String() string

+ type DeleteRocketMqMigrationTaskRequest struct

+ Body *MetadataDeleteReq

+ InstanceId string

+ func (o DeleteRocketMqMigrationTaskRequest) String() string

+ type DeleteRocketMqMigrationTaskResponse struct

+ Body *string

+ HttpStatusCode int

+ func (o DeleteRocketMqMigrationTaskResponse) String() string

+ type ListRocketMqMigrationTaskRequest struct

+ Id *string

+ InstanceId string

+ Limit *string

+ Name *string

+ Offset *string

+ Type *ListRocketMqMigrationTaskRequestType

+ func (o ListRocketMqMigrationTaskRequest) String() string

+ type ListRocketMqMigrationTaskRequestType struct

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

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

+ func (c ListRocketMqMigrationTaskRequestType) Value() string

+ type ListRocketMqMigrationTaskRequestTypeEnum struct

+ ALL ListRocketMqMigrationTaskRequestType

+ EXCHANGE ListRocketMqMigrationTaskRequestType

+ QUEUE ListRocketMqMigrationTaskRequestType

+ VHOST ListRocketMqMigrationTaskRequestType

+ func GetListRocketMqMigrationTaskRequestTypeEnum() ListRocketMqMigrationTaskRequestTypeEnum

+ type ListRocketMqMigrationTaskResponse struct

+ HttpStatusCode int

+ Task *[]MetadataTask

+ Total *int32

+ func (o ListRocketMqMigrationTaskResponse) String() string

+ type MetadataDeleteReq struct

+ TaskIds *[]string

+ func (o MetadataDeleteReq) String() string

+ type MetadataTask struct

+ Id *string

+ Name *string

+ StartDate *string

+ Status *string

+ Type *string

+ func (o MetadataTask) String() string

+ type ResendReq struct

+ ClientId *string

+ Group *string

+ MsgIdList *[]string

+ func (o ResendReq) String() string

+ type SendRocketMqDlqMessageRequest struct

+ Body *DeadletterResendReq

+ InstanceId string

+ func (o SendRocketMqDlqMessageRequest) String() string

+ type SendRocketMqDlqMessageResponse struct

+ HttpStatusCode int

+ ResendResults *[]DeadletterResendRespResendResults

+ func (o SendRocketMqDlqMessageResponse) String() string

+ type ValidateRocketMqConsumedMessageRequest struct

+ Body *ResendReq

+ InstanceId string

+ func (o ValidateRocketMqConsumedMessageRequest) String() string

+ type ValidateRocketMqConsumedMessageResponse struct

+ HttpStatusCode int

+ ResendResults *[]DeadletterResendRespResendResults

+ func (o ValidateRocketMqConsumedMessageResponse) String() string

v0.1.41

May 25, 2023

v0.1.40

May 18, 2023

v0.1.39

May 11, 2023

v0.1.38

Apr 27, 2023

v0.1.37

Apr 20, 2023

Changes in this version

+ type Brokers struct

+ BrokerName *string

+ Queues *[]Queue

+ func (o Brokers) String() string

+ type ClientData struct

+ ClientAddr *string

+ ClientId *string

+ Language *string

+ Subscriptions *[]Subscription

+ Version *string

+ func (o ClientData) String() string

+ type ConsumerDetailResp struct

+ Brokers *[]Brokers

+ func (o ConsumerDetailResp) String() string

+ type ConsumerList struct

+ Topics *[]string

+ Total float32

+ func (o ConsumerList) String() string

+ type Queue struct

+ BrokerOffset *int64

+ ConsumerOffset *int64

+ Id *int32

+ Lag *int64

+ LastMessageTime *int64

+ func (o Queue) String() string

+ type ShowConsumerConnectionsRequest struct

+ Group string

+ InstanceId string

+ IsDetail *bool

+ Limit *int32

+ Offset *int32

+ func (o ShowConsumerConnectionsRequest) String() string

+ type ShowConsumerConnectionsResponse struct

+ Clients *[]ClientData

+ GroupName *string

+ HttpStatusCode int

+ NextOffset *int32

+ Online *bool

+ PreviousOffset *int32

+ SubscriptionConsistency *bool

+ Total *int32

+ func (o ShowConsumerConnectionsResponse) String() string

type ShowConsumerListOrDetailsResponse

+ Brokers *[]Brokers

+ Total float32

+ type Subscription struct

+ Expression *string

+ Topic *string

+ Type *string

+ func (o Subscription) String() string

type UpdateInstanceReq

+ EnablePublicip *bool

+ PublicipId *string

v0.1.36

Apr 13, 2023

v0.1.35

Apr 6, 2023

v0.1.34

Mar 30, 2023

v0.1.33

Mar 23, 2023

v0.1.32

Mar 16, 2023

v0.1.31

Mar 14, 2023

v0.1.30

Mar 9, 2023

v0.1.29

Mar 7, 2023

v0.1.28

Mar 2, 2023

v0.1.27

Feb 23, 2023

v0.1.26

Feb 16, 2023

Changes in this version

+ type BatchCreateOrDeleteRocketmqTagRequest struct

+ Body *BatchCreateOrDeleteTagReq

+ InstanceId string

+ func (o BatchCreateOrDeleteRocketmqTagRequest) String() string

+ type BatchCreateOrDeleteRocketmqTagResponse struct

+ HttpStatusCode int

+ func (o BatchCreateOrDeleteRocketmqTagResponse) String() string

+ type BatchCreateOrDeleteTagReq struct

+ Action *BatchCreateOrDeleteTagReqAction

+ Tags *[]TagEntity

+ func (o BatchCreateOrDeleteTagReq) String() string

+ type BatchCreateOrDeleteTagReqAction struct

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

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

+ func (c BatchCreateOrDeleteTagReqAction) Value() string

+ type BatchCreateOrDeleteTagReqActionEnum struct

+ CREATE BatchCreateOrDeleteTagReqAction

+ DELETE BatchCreateOrDeleteTagReqAction

+ func GetBatchCreateOrDeleteTagReqActionEnum() BatchCreateOrDeleteTagReqActionEnum

+ type BssParam struct

+ ChargingMode *BssParamChargingMode

+ IsAutoPay *bool

+ IsAutoRenew *bool

+ PeriodNum *int32

+ PeriodType *BssParamPeriodType

+ func (o BssParam) String() string

+ type BssParamChargingMode struct

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

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

+ func (c BssParamChargingMode) Value() string

+ type BssParamChargingModeEnum struct

+ POST_PAID BssParamChargingMode

+ PRE_PAID BssParamChargingMode

+ func GetBssParamChargingModeEnum() BssParamChargingModeEnum

+ type BssParamPeriodType struct

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

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

+ func (c BssParamPeriodType) Value() string

+ type BssParamPeriodTypeEnum struct

+ MONTH BssParamPeriodType

+ YEAR BssParamPeriodType

+ func GetBssParamPeriodTypeEnum() BssParamPeriodTypeEnum

+ type CreateInstanceByEngineReq struct

+ AvailableZones []string

+ BrokerNum int32

+ BssParam *BssParam

+ Description *string

+ EnableAcl *bool

+ EnablePublicip *bool

+ Engine CreateInstanceByEngineReqEngine

+ EngineVersion CreateInstanceByEngineReqEngineVersion

+ EnterpriseProjectId *string

+ Ipv6Enable *bool

+ Name string

+ ProductId CreateInstanceByEngineReqProductId

+ PublicipId *string

+ SecurityGroupId string

+ SslEnable *bool

+ StorageSpace int32

+ StorageSpecCode CreateInstanceByEngineReqStorageSpecCode

+ SubnetId string

+ VpcId string

+ func (o CreateInstanceByEngineReq) String() string

+ type CreateInstanceByEngineReqEngine struct

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

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

+ func (c CreateInstanceByEngineReqEngine) Value() string

+ type CreateInstanceByEngineReqEngineEnum struct

+ RELIABILITY CreateInstanceByEngineReqEngine

+ func GetCreateInstanceByEngineReqEngineEnum() CreateInstanceByEngineReqEngineEnum

+ type CreateInstanceByEngineReqEngineVersion struct

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

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

+ func (c CreateInstanceByEngineReqEngineVersion) Value() string

+ type CreateInstanceByEngineReqEngineVersionEnum struct

+ E_4_8_0 CreateInstanceByEngineReqEngineVersion

+ func GetCreateInstanceByEngineReqEngineVersionEnum() CreateInstanceByEngineReqEngineVersionEnum

+ type CreateInstanceByEngineReqProductId struct

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

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

+ func (c CreateInstanceByEngineReqProductId) Value() string

+ type CreateInstanceByEngineReqProductIdEnum struct

+ C6_12U24G_CLUSTER CreateInstanceByEngineReqProductId

+ C6_16U32G_CLUSTER CreateInstanceByEngineReqProductId

+ C6_4U8G_CLUSTER CreateInstanceByEngineReqProductId

+ C6_8U16G_CLUSTER CreateInstanceByEngineReqProductId

+ func GetCreateInstanceByEngineReqProductIdEnum() CreateInstanceByEngineReqProductIdEnum

+ type CreateInstanceByEngineReqStorageSpecCode struct

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

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

+ func (c CreateInstanceByEngineReqStorageSpecCode) Value() string

+ type CreateInstanceByEngineReqStorageSpecCodeEnum struct

+ DMS_PHYSICAL_STORAGE_HIGH_V2 CreateInstanceByEngineReqStorageSpecCode

+ DMS_PHYSICAL_STORAGE_ULTRA_V2 CreateInstanceByEngineReqStorageSpecCode

+ func GetCreateInstanceByEngineReqStorageSpecCodeEnum() CreateInstanceByEngineReqStorageSpecCodeEnum

+ type CreateInstanceByEngineRequest struct

+ Body *CreateInstanceByEngineReq

+ Engine CreateInstanceByEngineRequestEngine

+ func (o CreateInstanceByEngineRequest) String() string

+ type CreateInstanceByEngineRequestEngine struct

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

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

+ func (c CreateInstanceByEngineRequestEngine) Value() string

+ type CreateInstanceByEngineRequestEngineEnum struct

+ RELIABILITY CreateInstanceByEngineRequestEngine

+ func GetCreateInstanceByEngineRequestEngineEnum() CreateInstanceByEngineRequestEngineEnum

+ type CreateInstanceByEngineResponse struct

+ HttpStatusCode int

+ InstanceId *string

+ func (o CreateInstanceByEngineResponse) String() string

type ListConsumerGroupOfTopicRequest

+ Limit *int32

+ Offset *int32

type ListInstancesRequest

+ Limit *int32

+ Offset *int32

type ShowConsumerListOrDetailsRequest

+ Limit *int32

+ Offset *int32

+ type ShowRocketmqProjectTagsRequest struct

+ func (o ShowRocketmqProjectTagsRequest) String() string

+ type ShowRocketmqProjectTagsResponse struct

+ HttpStatusCode int

+ Tags *[]TagMultyValueEntity

+ func (o ShowRocketmqProjectTagsResponse) String() string

+ type ShowRocketmqTagsRequest struct

+ InstanceId string

+ func (o ShowRocketmqTagsRequest) String() string

+ type ShowRocketmqTagsResponse struct

+ HttpStatusCode int

+ Tags *[]TagEntity

+ func (o ShowRocketmqTagsResponse) String() string

+ type TagMultyValueEntity struct

+ Key *string

+ Values *[]string

+ func (o TagMultyValueEntity) String() string

v0.1.25

Feb 9, 2023

v0.1.24

Feb 2, 2023

v0.1.23

Jan 19, 2023

v0.1.22

Jan 12, 2023

Changes in this version

+ type ListRocketInstanceTopicsRequest struct

+ InstanceId string

+ Limit *int32

+ Offset *int32

+ func (o ListRocketInstanceTopicsRequest) String() string

+ type ListRocketInstanceTopicsResponse struct

+ HttpStatusCode int

+ Max *int32

+ NextOffset *int32

+ PreviousOffset *int32

+ Remaining *int32

+ Topics *[]Topic

+ Total *int32

+ func (o ListRocketInstanceTopicsResponse) String() string

type ShowOneTopicResponse

+ Name *string

+ type Topic struct

+ Brokers *[]TopicBrokers

+ Name *string

+ Permission *TopicPermission

+ TotalReadQueueNum float32

+ TotalWriteQueueNum float32

+ func (o Topic) String() string

+ type TopicPermission struct

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

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

+ func (c TopicPermission) Value() string

+ type TopicPermissionEnum struct

+ ALL TopicPermission

+ PUB TopicPermission

+ SUB TopicPermission

+ func GetTopicPermissionEnum() TopicPermissionEnum

v0.1.21

Jan 5, 2023

v0.1.20

Dec 29, 2022

v0.1.19

Dec 26, 2022

v0.1.18

Dec 22, 2022

Changes in this version

type CreatePostPaidInstanceReq

+ EnableAcl *bool

+ EnterpriseProjectId *string

v0.1.17

Dec 19, 2022

v0.1.16

Dec 15, 2022

v0.1.15

Dec 8, 2022

Changes in this version

type ShowGroupResponse

+ AppId *string

+ AppName *string

+ Permissions *[]string

type UpdateInstanceReq

+ EnableAcl *bool

v0.1.14

Dec 1, 2022

v0.1.13

Nov 30, 2022

v0.1.12

Nov 24, 2022

v0.1.11

Nov 17, 2022

v0.1.10

Nov 14, 2022

v0.1.9

Nov 8, 2022

v0.1.8

Nov 3, 2022

v0.1.7

Nov 2, 2022

v0.1.6

Oct 27, 2022

v0.1.5

Sep 28, 2022

v0.1.4

Sep 26, 2022

v0.1.3

Sep 22, 2022

v0.1.2

Sep 15, 2022

Changes in this version

type BatchDeleteInstanceReqAllFailureEnum

+ RELIABILITY BatchDeleteInstanceReqAllFailure

type ListAccessPolicyRespPolicies

+ SecretKey *string

v0.1.1

Sep 8, 2022

v0.0.108

Sep 1, 2022

v0.0.107

Aug 29, 2022

v0.0.106

Aug 25, 2022

v0.0.105

Aug 22, 2022

v0.0.104

Aug 18, 2022

v0.0.103

Aug 15, 2022

v0.0.102

Aug 8, 2022

v0.0.101

Aug 2, 2022

v0.0.100

Jul 28, 2022

v0.0.99

Jul 21, 2022

v0.0.98

Jul 14, 2022

v0.0.97

Jul 7, 2022

v0.0.96

Jun 30, 2022

v0.0.95

Jun 25, 2022

v0.0.94

Jun 23, 2022

v0.0.93

Jun 19, 2022

v0.0.92

Jun 9, 2022

v0.0.91

Jun 2, 2022

v0.0.90

May 26, 2022

Changes in this version

type BatchDeleteInstanceReqAction

+ func (c BatchDeleteInstanceReqAction) Value() string

type BatchDeleteInstanceReqAllFailure

+ func (c BatchDeleteInstanceReqAllFailure) Value() string

type BatchDeleteInstanceRespResultsResult

+ func (c BatchDeleteInstanceRespResultsResult) Value() string

type CreatePostPaidInstanceReqEngine

+ func (c CreatePostPaidInstanceReqEngine) Value() string

type CreatePostPaidInstanceReqEngineVersion

+ func (c CreatePostPaidInstanceReqEngineVersion) Value() string

type CreatePostPaidInstanceReqProductId

+ func (c CreatePostPaidInstanceReqProductId) Value() string

type CreatePostPaidInstanceReqStorageSpecCode

+ func (c CreatePostPaidInstanceReqStorageSpecCode) Value() string

type CreateTopicOrBatchDeleteTopicReqPermission

+ func (c CreateTopicOrBatchDeleteTopicReqPermission) Value() string

type CreateTopicReqPermission

+ func (c CreateTopicReqPermission) Value() string

type CreateUserResponseDefaultGroupPerm

+ func (c CreateUserResponseDefaultGroupPerm) Value() string

type CreateUserResponseDefaultTopicPerm

+ func (c CreateUserResponseDefaultTopicPerm) Value() string

type ListConsumeGroupAccessPolicyRequestEngine

+ func (c ListConsumeGroupAccessPolicyRequestEngine) Value() string

type ListInstancesRequestExactMatchName

+ func (c ListInstancesRequestExactMatchName) Value() string

type ListInstancesRequestIncludeFailure

+ func (c ListInstancesRequestIncludeFailure) Value() string

type ListInstancesRequestStatus

+ func (c ListInstancesRequestStatus) Value() string

type ListMessageTraceRequestEngine

+ func (c ListMessageTraceRequestEngine) Value() string

type ListMessageTraceRespTraceMsgType

+ func (c ListMessageTraceRespTraceMsgType) Value() string

type ListMessageTraceRespTraceTraceType

+ func (c ListMessageTraceRespTraceTraceType) Value() string

type ListMessageTraceRespTraceTransactionState

+ func (c ListMessageTraceRespTraceTransactionState) Value() string

type ListMessagesRequestEngine

+ func (c ListMessagesRequestEngine) Value() string

type ResetConsumeOffsetRequestEngine

+ func (c ResetConsumeOffsetRequestEngine) Value() string

type ShowInstanceRespType

+ func (c ShowInstanceRespType) Value() string

type ShowInstanceResponseType

+ func (c ShowInstanceResponseType) Value() string

type ShowOneTopicResponsePermission

+ func (c ShowOneTopicResponsePermission) Value() string

type ShowUserResponseDefaultGroupPerm

+ func (c ShowUserResponseDefaultGroupPerm) Value() string

type ShowUserResponseDefaultTopicPerm

+ func (c ShowUserResponseDefaultTopicPerm) Value() string

type UpdateTopicReqPermission

+ func (c UpdateTopicReqPermission) Value() string

type UpdateUserResponseDefaultGroupPerm

+ func (c UpdateUserResponseDefaultGroupPerm) Value() string

type UpdateUserResponseDefaultTopicPerm

+ func (c UpdateUserResponseDefaultTopicPerm) Value() string

type UserDefaultGroupPerm

+ func (c UserDefaultGroupPerm) Value() string

type UserDefaultTopicPerm

+ func (c UserDefaultTopicPerm) Value() string

type UserGroupPermsPerm

+ func (c UserGroupPermsPerm) Value() string

type UserTopicPermsPerm

+ func (c UserTopicPermsPerm) Value() string

v0.0.89

May 19, 2022

v0.0.88

May 13, 2022

Changes in this version

+ type BatchDeleteConsumerGroupReq struct

+ Groups *[]string

+ func (o BatchDeleteConsumerGroupReq) String() string

+ type BatchDeleteConsumerGroupResp struct

+ JobId *string

+ func (o BatchDeleteConsumerGroupResp) String() string

+ type BatchDeleteInstanceReq struct

+ Action BatchDeleteInstanceReqAction

+ AllFailure *BatchDeleteInstanceReqAllFailure

+ Instances *[]string

+ func (o BatchDeleteInstanceReq) String() string

+ type BatchDeleteInstanceReqAction struct

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

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

+ type BatchDeleteInstanceReqActionEnum struct

+ DELETE BatchDeleteInstanceReqAction

+ func GetBatchDeleteInstanceReqActionEnum() BatchDeleteInstanceReqActionEnum

+ type BatchDeleteInstanceReqAllFailure struct

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

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

+ type BatchDeleteInstanceReqAllFailureEnum struct

+ FALSE BatchDeleteInstanceReqAllFailure

+ TRUE BatchDeleteInstanceReqAllFailure

+ func GetBatchDeleteInstanceReqAllFailureEnum() BatchDeleteInstanceReqAllFailureEnum

+ type BatchDeleteInstanceRespResults struct

+ Instance *string

+ Result *BatchDeleteInstanceRespResultsResult

+ func (o BatchDeleteInstanceRespResults) String() string

+ type BatchDeleteInstanceRespResultsResult struct

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

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

+ type BatchDeleteInstanceRespResultsResultEnum struct

+ FAILED BatchDeleteInstanceRespResultsResult

+ SUCCESS BatchDeleteInstanceRespResultsResult

+ func GetBatchDeleteInstanceRespResultsResultEnum() BatchDeleteInstanceRespResultsResultEnum

+ type BatchDeleteInstancesRequest struct

+ Body *BatchDeleteInstanceReq

+ func (o BatchDeleteInstancesRequest) String() string

+ type BatchDeleteInstancesResponse struct

+ HttpStatusCode int

+ Results *[]BatchDeleteInstanceRespResults

+ func (o BatchDeleteInstancesResponse) String() string

+ type BatchDeleteTopicReq struct

+ Topics *[]string

+ func (o BatchDeleteTopicReq) String() string

+ type BatchDeleteTopicResp struct

+ JobId *string

+ func (o BatchDeleteTopicResp) String() string

+ type BatchUpdateConsumerGroupReq struct

+ Groups *[]ConsumerGroup

+ func (o BatchUpdateConsumerGroupReq) String() string

+ type BatchUpdateConsumerGroupRequest struct

+ Body *BatchUpdateConsumerGroupReq

+ InstanceId string

+ func (o BatchUpdateConsumerGroupRequest) String() string

+ type BatchUpdateConsumerGroupResponse struct

+ HttpStatusCode int

+ JobId *string

+ func (o BatchUpdateConsumerGroupResponse) String() string

+ type ConsumerGroup struct

+ Broadcast *bool

+ Brokers *[]string

+ Enabled *bool

+ FromBeginning *bool

+ Name *string

+ RetryMaxTime float32

+ func (o ConsumerGroup) String() string

+ type CreateConsumerGroupOrBatchDeleteConsumerGroupReq struct

+ Broadcast *bool

+ Brokers *[]string

+ Enabled *bool

+ FromBeginning *bool

+ Groups *[]string

+ Name *string

+ RetryMaxTime float32

+ func (o CreateConsumerGroupOrBatchDeleteConsumerGroupReq) String() string

+ type CreateConsumerGroupOrBatchDeleteConsumerGroupRequest struct

+ Action *string

+ Body *CreateConsumerGroupOrBatchDeleteConsumerGroupReq

+ InstanceId string

+ func (o CreateConsumerGroupOrBatchDeleteConsumerGroupRequest) String() string

+ type CreateConsumerGroupOrBatchDeleteConsumerGroupResponse struct

+ HttpStatusCode int

+ JobId *string

+ Name *string

+ func (o CreateConsumerGroupOrBatchDeleteConsumerGroupResponse) String() string

+ type CreateGroupResp struct

+ Name *string

+ func (o CreateGroupResp) String() string

+ type CreatePostPaidInstanceReq struct

+ AvailableZones []string

+ BrokerNum *int32

+ Description *string

+ EnablePublicip *bool

+ Engine CreatePostPaidInstanceReqEngine

+ EngineVersion CreatePostPaidInstanceReqEngineVersion

+ Ipv6Enable *bool

+ Name string

+ ProductId CreatePostPaidInstanceReqProductId

+ PublicipId *string

+ SecurityGroupId string

+ SslEnable *bool

+ StorageSpace int32

+ StorageSpecCode CreatePostPaidInstanceReqStorageSpecCode

+ SubnetId string

+ VpcId string

+ func (o CreatePostPaidInstanceReq) String() string

+ type CreatePostPaidInstanceReqEngine struct

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

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

+ type CreatePostPaidInstanceReqEngineEnum struct

+ RELIABILITY CreatePostPaidInstanceReqEngine

+ func GetCreatePostPaidInstanceReqEngineEnum() CreatePostPaidInstanceReqEngineEnum

+ type CreatePostPaidInstanceReqEngineVersion struct

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

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

+ type CreatePostPaidInstanceReqEngineVersionEnum struct

+ E_4_8_0 CreatePostPaidInstanceReqEngineVersion

+ func GetCreatePostPaidInstanceReqEngineVersionEnum() CreatePostPaidInstanceReqEngineVersionEnum

+ type CreatePostPaidInstanceReqProductId struct

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

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

+ type CreatePostPaidInstanceReqProductIdEnum struct

+ C6_12U24G_CLUSTER CreatePostPaidInstanceReqProductId

+ C6_16U32G_CLUSTER CreatePostPaidInstanceReqProductId

+ C6_4U8G_CLUSTER CreatePostPaidInstanceReqProductId

+ C6_8U16G_CLUSTER CreatePostPaidInstanceReqProductId

+ func GetCreatePostPaidInstanceReqProductIdEnum() CreatePostPaidInstanceReqProductIdEnum

+ type CreatePostPaidInstanceReqStorageSpecCode struct

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

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

+ type CreatePostPaidInstanceReqStorageSpecCodeEnum struct

+ DMS_PHYSICAL_STORAGE_HIGH_V2 CreatePostPaidInstanceReqStorageSpecCode

+ DMS_PHYSICAL_STORAGE_ULTRA_V2 CreatePostPaidInstanceReqStorageSpecCode

+ func GetCreatePostPaidInstanceReqStorageSpecCodeEnum() CreatePostPaidInstanceReqStorageSpecCodeEnum

+ type CreatePostPaidInstanceRequest struct

+ Body *CreatePostPaidInstanceReq

+ func (o CreatePostPaidInstanceRequest) String() string

+ type CreatePostPaidInstanceResponse struct

+ HttpStatusCode int

+ InstanceId *string

+ func (o CreatePostPaidInstanceResponse) String() string

+ type CreateTopicOrBatchDeleteTopicReq struct

+ Brokers *[]string

+ Name *string

+ Permission *CreateTopicOrBatchDeleteTopicReqPermission

+ QueueNum float32

+ Topics *[]string

+ func (o CreateTopicOrBatchDeleteTopicReq) String() string

+ type CreateTopicOrBatchDeleteTopicReqPermission struct

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

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

+ type CreateTopicOrBatchDeleteTopicReqPermissionEnum struct

+ ALL CreateTopicOrBatchDeleteTopicReqPermission

+ PUB CreateTopicOrBatchDeleteTopicReqPermission

+ SUB CreateTopicOrBatchDeleteTopicReqPermission

+ func GetCreateTopicOrBatchDeleteTopicReqPermissionEnum() CreateTopicOrBatchDeleteTopicReqPermissionEnum

+ type CreateTopicOrBatchDeleteTopicRequest struct

+ Action *string

+ Body *CreateTopicOrBatchDeleteTopicReq

+ InstanceId string

+ func (o CreateTopicOrBatchDeleteTopicRequest) String() string

+ type CreateTopicOrBatchDeleteTopicResponse struct

+ HttpStatusCode int

+ Id *string

+ JobId *string

+ func (o CreateTopicOrBatchDeleteTopicResponse) String() string

+ type CreateTopicReq struct

+ Brokers *[]string

+ Name *string

+ Permission *CreateTopicReqPermission

+ QueueNum float32

+ func (o CreateTopicReq) String() string

+ type CreateTopicReqPermission struct

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

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

+ type CreateTopicReqPermissionEnum struct

+ ALL CreateTopicReqPermission

+ PUB CreateTopicReqPermission

+ SUB CreateTopicReqPermission

+ func GetCreateTopicReqPermissionEnum() CreateTopicReqPermissionEnum

+ type CreateTopicResp struct

+ Id *string

+ func (o CreateTopicResp) String() string

+ type CreateUserRequest struct

+ Body *User

+ InstanceId string

+ func (o CreateUserRequest) String() string

+ type CreateUserResponse struct

+ AccessKey *string

+ Admin *bool

+ DefaultGroupPerm *CreateUserResponseDefaultGroupPerm

+ DefaultTopicPerm *CreateUserResponseDefaultTopicPerm

+ GroupPerms *[]UserGroupPerms

+ HttpStatusCode int

+ SecretKey *string

+ TopicPerms *[]UserTopicPerms

+ WhiteRemoteAddress *string

+ func (o CreateUserResponse) String() string

+ type CreateUserResponseDefaultGroupPerm struct

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

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

+ type CreateUserResponseDefaultGroupPermEnum struct

+ DENY CreateUserResponseDefaultGroupPerm

+ PUB CreateUserResponseDefaultGroupPerm

+ PUB_SUB CreateUserResponseDefaultGroupPerm

+ SUB CreateUserResponseDefaultGroupPerm

+ func GetCreateUserResponseDefaultGroupPermEnum() CreateUserResponseDefaultGroupPermEnum

+ type CreateUserResponseDefaultTopicPerm struct

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

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

+ type CreateUserResponseDefaultTopicPermEnum struct

+ DENY CreateUserResponseDefaultTopicPerm

+ PUB CreateUserResponseDefaultTopicPerm

+ PUB_SUB CreateUserResponseDefaultTopicPerm

+ SUB CreateUserResponseDefaultTopicPerm

+ func GetCreateUserResponseDefaultTopicPermEnum() CreateUserResponseDefaultTopicPermEnum

+ type DeleteConsumerGroupRequest struct

+ Group string

+ InstanceId string

+ func (o DeleteConsumerGroupRequest) String() string

+ type DeleteConsumerGroupResponse struct

+ HttpStatusCode int

+ func (o DeleteConsumerGroupResponse) String() string

+ type DeleteInstanceRequest struct

+ InstanceId string

+ func (o DeleteInstanceRequest) String() string

+ type DeleteInstanceResponse struct

+ HttpStatusCode int

+ func (o DeleteInstanceResponse) String() string

+ type DeleteTopicRequest struct

+ InstanceId string

+ Topic string

+ func (o DeleteTopicRequest) String() string

+ type DeleteTopicResponse struct

+ HttpStatusCode int

+ func (o DeleteTopicResponse) String() string

+ type DeleteUserRequest struct

+ InstanceId string

+ UserName string

+ func (o DeleteUserRequest) String() string

+ type DeleteUserResponse struct

+ HttpStatusCode int

+ Message *string

+ func (o DeleteUserResponse) String() string

+ type ExportDlqMessageReq struct

+ MsgIdList *[]string

+ Topic *string

+ UniqKeyList *[]string

+ func (o ExportDlqMessageReq) String() string

+ type ExportDlqMessageRequest struct

+ Body *ExportDlqMessageReq

+ InstanceId string

+ func (o ExportDlqMessageRequest) String() string

+ type ExportDlqMessageResponse struct

+ Body *[]Message

+ HttpStatusCode int

+ func (o ExportDlqMessageResponse) String() string

+ type ListAccessPolicyRespPolicies struct

+ AccessKey *string

+ Admin *bool

+ Perm *string

+ WhiteRemoteAddress *string

+ func (o ListAccessPolicyRespPolicies) String() string

+ type ListAvailableZonesRequest struct

+ func (o ListAvailableZonesRequest) String() string

+ type ListAvailableZonesRespAvailableZones struct

+ Code *string

+ DefaultAz *bool

+ Id *string

+ Ipv6Enable *bool

+ Name *string

+ Port *string

+ RemainTime *int64

+ ResourceAvailability *string

+ SoldOut *bool

+ func (o ListAvailableZonesRespAvailableZones) String() string

+ type ListAvailableZonesResponse struct

+ AvailableZones *[]ListAvailableZonesRespAvailableZones

+ HttpStatusCode int

+ RegionId *string

+ func (o ListAvailableZonesResponse) String() string

+ type ListBrokersRequest struct

+ InstanceId string

+ func (o ListBrokersRequest) String() string

+ type ListBrokersRespBrokers struct

+ BrokerName *string

+ Ids *[]float32

+ func (o ListBrokersRespBrokers) String() string

+ type ListBrokersResponse struct

+ Brokers *[]ListBrokersRespBrokers

+ HttpStatusCode int

+ func (o ListBrokersResponse) String() string

+ type ListConsumeGroupAccessPolicyRequest struct

+ Engine ListConsumeGroupAccessPolicyRequestEngine

+ GroupId string

+ InstanceId string

+ Limit *string

+ Offset *string

+ func (o ListConsumeGroupAccessPolicyRequest) String() string

+ type ListConsumeGroupAccessPolicyRequestEngine struct

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

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

+ type ListConsumeGroupAccessPolicyRequestEngineEnum struct

+ RELIABILITY ListConsumeGroupAccessPolicyRequestEngine

+ func GetListConsumeGroupAccessPolicyRequestEngineEnum() ListConsumeGroupAccessPolicyRequestEngineEnum

+ type ListConsumeGroupAccessPolicyResponse struct

+ HttpStatusCode int

+ Name *string

+ Policies *[]ListAccessPolicyRespPolicies

+ Total float32

+ func (o ListConsumeGroupAccessPolicyResponse) String() string

+ type ListConsumerGroupOfTopicRequest struct

+ InstanceId string

+ Topic string

+ func (o ListConsumerGroupOfTopicRequest) String() string

+ type ListConsumerGroupOfTopicResponse struct

+ Groups *[]string

+ HttpStatusCode int

+ func (o ListConsumerGroupOfTopicResponse) String() string

+ type ListInstanceConsumerGroupsRequest struct

+ Group *string

+ InstanceId string

+ Limit *int32

+ Offset *int32

+ func (o ListInstanceConsumerGroupsRequest) String() string

+ type ListInstanceConsumerGroupsResponse struct

+ Groups *[]ConsumerGroup

+ HttpStatusCode int

+ Max float32

+ NextOffset float32

+ PreviousOffset float32

+ Remaining float32

+ Total float32

+ func (o ListInstanceConsumerGroupsResponse) String() string

+ type ListInstancesRequest struct

+ Engine *string

+ EnterpriseProjectId *string

+ ExactMatchName *ListInstancesRequestExactMatchName

+ IncludeFailure *ListInstancesRequestIncludeFailure

+ InstanceId *string

+ Name *string

+ Status *ListInstancesRequestStatus

+ func (o ListInstancesRequest) String() string

+ type ListInstancesRequestExactMatchName struct

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

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

+ type ListInstancesRequestExactMatchNameEnum struct

+ FALSE ListInstancesRequestExactMatchName

+ TRUE ListInstancesRequestExactMatchName

+ func GetListInstancesRequestExactMatchNameEnum() ListInstancesRequestExactMatchNameEnum

+ type ListInstancesRequestIncludeFailure struct

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

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

+ type ListInstancesRequestIncludeFailureEnum struct

+ FALSE ListInstancesRequestIncludeFailure

+ TRUE ListInstancesRequestIncludeFailure

+ func GetListInstancesRequestIncludeFailureEnum() ListInstancesRequestIncludeFailureEnum

+ type ListInstancesRequestStatus struct

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

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

+ type ListInstancesRequestStatusEnum struct

+ CREATING ListInstancesRequestStatus

+ FAULTY ListInstancesRequestStatus

+ FROZEN ListInstancesRequestStatus

+ RESIZING ListInstancesRequestStatus

+ RESIZING_FAILED ListInstancesRequestStatus

+ RESTARTING ListInstancesRequestStatus

+ RUNNING ListInstancesRequestStatus

+ func GetListInstancesRequestStatusEnum() ListInstancesRequestStatusEnum

+ type ListInstancesResponse struct

+ HttpStatusCode int

+ InstanceNum *int32

+ Instances *[]ShowInstanceResp

+ func (o ListInstancesResponse) String() string

+ type ListMessageTraceRequest struct

+ Engine ListMessageTraceRequestEngine

+ InstanceId string

+ MsgId *string

+ func (o ListMessageTraceRequest) String() string

+ type ListMessageTraceRequestEngine struct

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

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

+ type ListMessageTraceRequestEngineEnum struct

+ RELIABILITY ListMessageTraceRequestEngine

+ func GetListMessageTraceRequestEngineEnum() ListMessageTraceRequestEngineEnum

+ type ListMessageTraceRespTrace struct

+ BodyLength float32

+ ClientHost *string

+ ConsumeStatus float32

+ CostTime float32

+ FromTransactionCheck *bool

+ GroupName *string

+ Keys *string

+ MsgId *string

+ MsgType *ListMessageTraceRespTraceMsgType

+ OffsetMsgId *string

+ RequestId *string

+ RetryTimes *string

+ StoreHost *string

+ Success *bool

+ Tags *string

+ Timestamp float32

+ Topic *string

+ TraceType *ListMessageTraceRespTraceTraceType

+ TransactionId *string

+ TransactionState *ListMessageTraceRespTraceTransactionState

+ func (o ListMessageTraceRespTrace) String() string

+ type ListMessageTraceRespTraceMsgType struct

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

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

+ type ListMessageTraceRespTraceMsgTypeEnum struct

+ DELAY_MSG ListMessageTraceRespTraceMsgType

+ NORMAL_MSG ListMessageTraceRespTraceMsgType

+ TRANS_MSG_COMMIT ListMessageTraceRespTraceMsgType

+ TRANS_MSG_HALF ListMessageTraceRespTraceMsgType

+ func GetListMessageTraceRespTraceMsgTypeEnum() ListMessageTraceRespTraceMsgTypeEnum

+ type ListMessageTraceRespTraceTraceType struct

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

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

+ type ListMessageTraceRespTraceTraceTypeEnum struct

+ END_TRANSACTION ListMessageTraceRespTraceTraceType

+ PUB ListMessageTraceRespTraceTraceType

+ SUB ListMessageTraceRespTraceTraceType

+ func GetListMessageTraceRespTraceTraceTypeEnum() ListMessageTraceRespTraceTraceTypeEnum

+ type ListMessageTraceRespTraceTransactionState struct

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

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

+ type ListMessageTraceRespTraceTransactionStateEnum struct

+ COMMIT_MESSAGE ListMessageTraceRespTraceTransactionState

+ ROLLBACK_MESSAGE ListMessageTraceRespTraceTransactionState

+ UNKNOW ListMessageTraceRespTraceTransactionState

+ func GetListMessageTraceRespTraceTransactionStateEnum() ListMessageTraceRespTraceTransactionStateEnum

+ type ListMessageTraceResponse struct

+ HttpStatusCode int

+ Trace *[]ListMessageTraceRespTrace

+ func (o ListMessageTraceResponse) String() string

+ type ListMessagesRequest struct

+ EndTime *string

+ Engine ListMessagesRequestEngine

+ InstanceId string

+ Limit *string

+ MsgId *string

+ Offset *string

+ StartTime *string

+ Topic string

+ func (o ListMessagesRequest) String() string

+ type ListMessagesRequestEngine struct

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

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

+ type ListMessagesRequestEngineEnum struct

+ RELIABILITY ListMessagesRequestEngine

+ func GetListMessagesRequestEngineEnum() ListMessagesRequestEngineEnum

+ type ListMessagesResponse struct

+ HttpStatusCode int

+ Messages *[]Message

+ Total float32

+ func (o ListMessagesResponse) String() string

+ type ListTopicAccessPolicyRequest struct

+ InstanceId string

+ Limit *string

+ Offset *string

+ Topic string

+ func (o ListTopicAccessPolicyRequest) String() string

+ type ListTopicAccessPolicyResponse struct

+ HttpStatusCode int

+ Name *string

+ Policies *[]ListAccessPolicyRespPolicies

+ Total float32

+ func (o ListTopicAccessPolicyResponse) String() string

+ type ListUserRequest struct

+ InstanceId string

+ Limit *string

+ Offset *string

+ func (o ListUserRequest) String() string

+ type ListUserResponse struct

+ HttpStatusCode int

+ Total float32

+ Users *[]User

+ func (o ListUserResponse) String() string

+ type Message struct

+ Body *string

+ BodyCrc float32

+ BornHost *string

+ BornTimestamp float32

+ InstanceId *string

+ MsgId *string

+ PropertyList *[]MessagePropertyList

+ QueueId *string

+ QueueOffset *string

+ ReconsumeTimes *string

+ StoreHost *string

+ StoreSize float32

+ StoreTimestamp float32

+ Topic *string

+ func (o Message) String() string

+ type MessagePropertyList struct

+ Name *string

+ Value *string

+ func (o MessagePropertyList) String() string

+ type ResetConsumeOffsetReq struct

+ Timestamp float32

+ Topic *string

+ func (o ResetConsumeOffsetReq) String() string

+ type ResetConsumeOffsetRequest struct

+ Body *ResetConsumeOffsetReq

+ Engine ResetConsumeOffsetRequestEngine

+ GroupId string

+ InstanceId string

+ func (o ResetConsumeOffsetRequest) String() string

+ type ResetConsumeOffsetRequestEngine struct

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

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

+ type ResetConsumeOffsetRequestEngineEnum struct

+ RELIABILITY ResetConsumeOffsetRequestEngine

+ func GetResetConsumeOffsetRequestEngineEnum() ResetConsumeOffsetRequestEngineEnum

+ type ResetConsumeOffsetRespQueues struct

+ BrokerName *string

+ QueueId *int32

+ TimestampOffset *int64

+ func (o ResetConsumeOffsetRespQueues) String() string

+ type ResetConsumeOffsetResponse struct

+ HttpStatusCode int

+ Queues *[]ResetConsumeOffsetRespQueues

+ func (o ResetConsumeOffsetResponse) String() string

+ type ShowConsumerListOrDetailsRequest struct

+ Group string

+ InstanceId string

+ Topic *string

+ func (o ShowConsumerListOrDetailsRequest) String() string

+ type ShowConsumerListOrDetailsResponse struct

+ HttpStatusCode int

+ Topics *[]string

+ func (o ShowConsumerListOrDetailsResponse) String() string

+ type ShowGroupRequest struct

+ Group string

+ InstanceId string

+ func (o ShowGroupRequest) String() string

+ type ShowGroupResponse struct

+ Broadcast *bool

+ Brokers *[]string

+ Enabled *bool

+ FromBeginning *bool

+ HttpStatusCode int

+ Name *string

+ RetryMaxTime float32

+ func (o ShowGroupResponse) String() string

+ type ShowInstanceRequest struct

+ InstanceId string

+ func (o ShowInstanceRequest) String() string

+ type ShowInstanceResp struct

+ AvailableZones *[]string

+ BrokerAddress *string

+ BrokerNum *int32

+ CesVersion *string

+ ChargingMode *int32

+ CreatedAt *string

+ CrossVpcInfo *string

+ Description *string

+ DiskEncrypted *bool

+ EnableAcl *bool

+ EnableLogCollection *bool

+ EnablePublicip *bool

+ Engine *string

+ EngineVersion *string

+ ExtendTimes *int64

+ InstanceId *string

+ Ipv6Enable *bool

+ MaintainBegin *string

+ MaintainEnd *string

+ Name *string

+ NamesrvAddress *string

+ NewSpecBillingEnable *bool

+ NodeNum *int32

+ ProductId *string

+ PublicBrokerAddress *string

+ PublicNamesrvAddress *string

+ PublicipAddress *string

+ PublicipId *string

+ ResourceSpecCode *string

+ SecurityGroupId *string

+ SecurityGroupName *string

+ ServiceType *string

+ Specification *string

+ SslEnable *bool

+ Status *string

+ StorageResourceId *string

+ StorageSpace *int32

+ StorageSpecCode *string

+ StorageType *string

+ SubnetCidr *string

+ SubnetId *string

+ SubnetName *string

+ SupportFeatures *string

+ Tags *[]TagEntity

+ TotalStorageSpace *int32

+ Type *ShowInstanceRespType

+ UsedStorageSpace *int32

+ UserId *string

+ UserName *string

+ VpcId *string

+ VpcName *string

+ func (o ShowInstanceResp) String() string

+ type ShowInstanceRespType struct

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

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

+ type ShowInstanceRespTypeEnum struct

+ CLUSTER ShowInstanceRespType

+ SINGLE ShowInstanceRespType

+ func GetShowInstanceRespTypeEnum() ShowInstanceRespTypeEnum

+ type ShowInstanceResponse struct

+ AvailableZones *[]string

+ BrokerAddress *string

+ BrokerNum *int32

+ CesVersion *string

+ ChargingMode *int32

+ CreatedAt *string

+ CrossVpcInfo *string

+ Description *string

+ DiskEncrypted *bool

+ EnableAcl *bool

+ EnableLogCollection *bool

+ EnablePublicip *bool

+ Engine *string

+ EngineVersion *string

+ ExtendTimes *int64

+ HttpStatusCode int

+ InstanceId *string

+ Ipv6Enable *bool

+ MaintainBegin *string

+ MaintainEnd *string

+ Name *string

+ NamesrvAddress *string

+ NewSpecBillingEnable *bool

+ NodeNum *int32

+ ProductId *string

+ PublicBrokerAddress *string

+ PublicNamesrvAddress *string

+ PublicipAddress *string

+ PublicipId *string

+ ResourceSpecCode *string

+ SecurityGroupId *string

+ SecurityGroupName *string

+ ServiceType *string

+ Specification *string

+ SslEnable *bool

+ Status *string

+ StorageResourceId *string

+ StorageSpace *int32

+ StorageSpecCode *string

+ StorageType *string

+ SubnetCidr *string

+ SubnetId *string

+ SubnetName *string

+ SupportFeatures *string

+ Tags *[]TagEntity

+ TotalStorageSpace *int32

+ Type *ShowInstanceResponseType

+ UsedStorageSpace *int32

+ UserId *string

+ UserName *string

+ VpcId *string

+ VpcName *string

+ func (o ShowInstanceResponse) String() string

+ type ShowInstanceResponseType struct

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

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

+ type ShowInstanceResponseTypeEnum struct

+ CLUSTER ShowInstanceResponseType

+ SINGLE ShowInstanceResponseType

+ func GetShowInstanceResponseTypeEnum() ShowInstanceResponseTypeEnum

+ type ShowOneTopicRequest struct

+ InstanceId string

+ Topic string

+ func (o ShowOneTopicRequest) String() string

+ type ShowOneTopicResponse struct

+ Brokers *[]TopicBrokers

+ HttpStatusCode int

+ Permission *ShowOneTopicResponsePermission

+ TotalReadQueueNum float32

+ TotalWriteQueueNum float32

+ func (o ShowOneTopicResponse) String() string

+ type ShowOneTopicResponsePermission struct

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

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

+ type ShowOneTopicResponsePermissionEnum struct

+ ALL ShowOneTopicResponsePermission

+ PUB ShowOneTopicResponsePermission

+ SUB ShowOneTopicResponsePermission

+ func GetShowOneTopicResponsePermissionEnum() ShowOneTopicResponsePermissionEnum

+ type ShowTopicStatusRequest struct

+ InstanceId string

+ Topic string

+ func (o ShowTopicStatusRequest) String() string

+ type ShowTopicStatusRespBrokers struct

+ BrokerName *string

+ Queues *[]ShowTopicStatusRespQueues

+ func (o ShowTopicStatusRespBrokers) String() string

+ type ShowTopicStatusRespQueues struct

+ Id *int32

+ LastMessageTime *int64

+ MaxOffset *int32

+ MinOffset *int32

+ func (o ShowTopicStatusRespQueues) String() string

+ type ShowTopicStatusResponse struct

+ Brokers *[]ShowTopicStatusRespBrokers

+ HttpStatusCode int

+ func (o ShowTopicStatusResponse) String() string

+ type ShowUserRequest struct

+ InstanceId string

+ UserName string

+ func (o ShowUserRequest) String() string

+ type ShowUserResponse struct

+ AccessKey *string

+ Admin *bool

+ DefaultGroupPerm *ShowUserResponseDefaultGroupPerm

+ DefaultTopicPerm *ShowUserResponseDefaultTopicPerm

+ GroupPerms *[]UserGroupPerms

+ HttpStatusCode int

+ SecretKey *string

+ TopicPerms *[]UserTopicPerms

+ WhiteRemoteAddress *string

+ func (o ShowUserResponse) String() string

+ type ShowUserResponseDefaultGroupPerm struct

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

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

+ type ShowUserResponseDefaultGroupPermEnum struct

+ DENY ShowUserResponseDefaultGroupPerm

+ PUB ShowUserResponseDefaultGroupPerm

+ PUB_SUB ShowUserResponseDefaultGroupPerm

+ SUB ShowUserResponseDefaultGroupPerm

+ func GetShowUserResponseDefaultGroupPermEnum() ShowUserResponseDefaultGroupPermEnum

+ type ShowUserResponseDefaultTopicPerm struct

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

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

+ type ShowUserResponseDefaultTopicPermEnum struct

+ DENY ShowUserResponseDefaultTopicPerm

+ PUB ShowUserResponseDefaultTopicPerm

+ PUB_SUB ShowUserResponseDefaultTopicPerm

+ SUB ShowUserResponseDefaultTopicPerm

+ func GetShowUserResponseDefaultTopicPermEnum() ShowUserResponseDefaultTopicPermEnum

+ type TagEntity struct

+ Key *string

+ Value *string

+ func (o TagEntity) String() string

+ type TopicBrokers struct

+ BrokerName *string

+ ReadQueueNum float32

+ WriteQueueNum float32

+ func (o TopicBrokers) String() string

+ type UpdateConsumerGroupRequest struct

+ Body *ConsumerGroup

+ Group string

+ InstanceId string

+ func (o UpdateConsumerGroupRequest) String() string

+ type UpdateConsumerGroupResponse struct

+ HttpStatusCode int

+ func (o UpdateConsumerGroupResponse) String() string

+ type UpdateInstanceReq struct

+ Description *string

+ Name *string

+ RetentionPolicy *bool

+ SecurityGroupId *string

+ func (o UpdateInstanceReq) String() string

+ type UpdateInstanceRequest struct

+ Body *UpdateInstanceReq

+ InstanceId string

+ func (o UpdateInstanceRequest) String() string

+ type UpdateInstanceResponse struct

+ HttpStatusCode int

+ func (o UpdateInstanceResponse) String() string

+ type UpdateTopicReq struct

+ Permission *UpdateTopicReqPermission

+ ReadQueueNum float32

+ WriteQueueNum float32

+ func (o UpdateTopicReq) String() string

+ type UpdateTopicReqPermission struct

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

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

+ type UpdateTopicReqPermissionEnum struct

+ ALL UpdateTopicReqPermission

+ PUB UpdateTopicReqPermission

+ SUB UpdateTopicReqPermission

+ func GetUpdateTopicReqPermissionEnum() UpdateTopicReqPermissionEnum

+ type UpdateTopicRequest struct

+ Body *UpdateTopicReq

+ InstanceId string

+ Topic string

+ func (o UpdateTopicRequest) String() string

+ type UpdateTopicResponse struct

+ HttpStatusCode int

+ func (o UpdateTopicResponse) String() string

+ type UpdateUserRequest struct

+ Body *User

+ InstanceId string

+ UserName string

+ func (o UpdateUserRequest) String() string

+ type UpdateUserResponse struct

+ AccessKey *string

+ Admin *bool

+ DefaultGroupPerm *UpdateUserResponseDefaultGroupPerm

+ DefaultTopicPerm *UpdateUserResponseDefaultTopicPerm

+ GroupPerms *[]UserGroupPerms

+ HttpStatusCode int

+ SecretKey *string

+ TopicPerms *[]UserTopicPerms

+ WhiteRemoteAddress *string

+ func (o UpdateUserResponse) String() string

+ type UpdateUserResponseDefaultGroupPerm struct

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

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

+ type UpdateUserResponseDefaultGroupPermEnum struct

+ DENY UpdateUserResponseDefaultGroupPerm

+ PUB UpdateUserResponseDefaultGroupPerm

+ PUB_SUB UpdateUserResponseDefaultGroupPerm

+ SUB UpdateUserResponseDefaultGroupPerm

+ func GetUpdateUserResponseDefaultGroupPermEnum() UpdateUserResponseDefaultGroupPermEnum

+ type UpdateUserResponseDefaultTopicPerm struct

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

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

+ type UpdateUserResponseDefaultTopicPermEnum struct

+ DENY UpdateUserResponseDefaultTopicPerm

+ PUB UpdateUserResponseDefaultTopicPerm

+ PUB_SUB UpdateUserResponseDefaultTopicPerm

+ SUB UpdateUserResponseDefaultTopicPerm

+ func GetUpdateUserResponseDefaultTopicPermEnum() UpdateUserResponseDefaultTopicPermEnum

+ type User struct

+ AccessKey *string

+ Admin *bool

+ DefaultGroupPerm *UserDefaultGroupPerm

+ DefaultTopicPerm *UserDefaultTopicPerm

+ GroupPerms *[]UserGroupPerms

+ SecretKey *string

+ TopicPerms *[]UserTopicPerms

+ WhiteRemoteAddress *string

+ func (o User) String() string

+ type UserDefaultGroupPerm struct

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

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

+ type UserDefaultGroupPermEnum struct

+ DENY UserDefaultGroupPerm

+ PUB UserDefaultGroupPerm

+ PUB_SUB UserDefaultGroupPerm

+ SUB UserDefaultGroupPerm

+ func GetUserDefaultGroupPermEnum() UserDefaultGroupPermEnum

+ type UserDefaultTopicPerm struct

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

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

+ type UserDefaultTopicPermEnum struct

+ DENY UserDefaultTopicPerm

+ PUB UserDefaultTopicPerm

+ PUB_SUB UserDefaultTopicPerm

+ SUB UserDefaultTopicPerm

+ func GetUserDefaultTopicPermEnum() UserDefaultTopicPermEnum

+ type UserGroupPerms struct

+ Name *string

+ Perm *UserGroupPermsPerm

+ func (o UserGroupPerms) String() string

+ type UserGroupPermsPerm struct

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

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

+ type UserGroupPermsPermEnum struct

+ DENY UserGroupPermsPerm

+ PUB UserGroupPermsPerm

+ PUB_SUB UserGroupPermsPerm

+ SUB UserGroupPermsPerm

+ func GetUserGroupPermsPermEnum() UserGroupPermsPermEnum

+ type UserTopicPerms struct

+ Name *string

+ Perm *UserTopicPermsPerm

+ func (o UserTopicPerms) String() string

+ type UserTopicPermsPerm struct

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

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

+ type UserTopicPermsPermEnum struct

+ DENY UserTopicPermsPerm

+ PUB UserTopicPermsPerm

+ PUB_SUB UserTopicPermsPerm

+ SUB UserTopicPermsPerm

+ func GetUserTopicPermsPermEnum() UserTopicPermsPermEnum

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL