Documentation ¶
Index ¶
- type BatchCreateOrDeleteRocketmqTagRequest
- type BatchCreateOrDeleteRocketmqTagResponse
- type BatchCreateOrDeleteTagReq
- type BatchCreateOrDeleteTagReqAction
- type BatchCreateOrDeleteTagReqActionEnum
- type BatchDeleteConsumerGroupReq
- type BatchDeleteConsumerGroupResp
- type BatchDeleteInstanceReq
- type BatchDeleteInstanceReqAction
- type BatchDeleteInstanceReqActionEnum
- type BatchDeleteInstanceReqAllFailure
- type BatchDeleteInstanceReqAllFailureEnum
- type BatchDeleteInstanceRespResults
- type BatchDeleteInstanceRespResultsResult
- type BatchDeleteInstanceRespResultsResultEnum
- type BatchDeleteInstancesRequest
- type BatchDeleteInstancesResponse
- type BatchDeleteTopicReq
- type BatchDeleteTopicResp
- type BatchUpdateConsumerGroupReq
- type BatchUpdateConsumerGroupRequest
- type BatchUpdateConsumerGroupResponse
- type Brokers
- type BssParam
- type BssParamChargingMode
- type BssParamChargingModeEnum
- type BssParamPeriodType
- type BssParamPeriodTypeEnum
- type ClientData
- type ConsumerDetailResp
- type ConsumerGroup
- type ConsumerList
- type CreateConsumerGroupOrBatchDeleteConsumerGroupReq
- type CreateConsumerGroupOrBatchDeleteConsumerGroupRequest
- type CreateConsumerGroupOrBatchDeleteConsumerGroupResponse
- type CreateGroupResp
- type CreateInstanceByEngineReq
- type CreateInstanceByEngineReqEngine
- type CreateInstanceByEngineReqEngineEnum
- type CreateInstanceByEngineReqEngineVersion
- type CreateInstanceByEngineReqEngineVersionEnum
- type CreateInstanceByEngineReqProductId
- type CreateInstanceByEngineReqProductIdEnum
- type CreateInstanceByEngineReqStorageSpecCode
- type CreateInstanceByEngineReqStorageSpecCodeEnum
- type CreateInstanceByEngineRequest
- type CreateInstanceByEngineRequestEngine
- type CreateInstanceByEngineRequestEngineEnum
- type CreateInstanceByEngineResponse
- type CreatePostPaidInstanceReq
- type CreatePostPaidInstanceReqEngine
- type CreatePostPaidInstanceReqEngineEnum
- type CreatePostPaidInstanceReqEngineVersion
- type CreatePostPaidInstanceReqEngineVersionEnum
- type CreatePostPaidInstanceReqProductId
- type CreatePostPaidInstanceReqProductIdEnum
- type CreatePostPaidInstanceReqStorageSpecCode
- type CreatePostPaidInstanceReqStorageSpecCodeEnum
- type CreatePostPaidInstanceRequest
- type CreatePostPaidInstanceResponse
- type CreateRocketMqMigrationTaskRequest
- type CreateRocketMqMigrationTaskRequestOverwrite
- type CreateRocketMqMigrationTaskRequestOverwriteEnum
- type CreateRocketMqMigrationTaskRequestType
- type CreateRocketMqMigrationTaskRequestTypeEnum
- type CreateRocketMqMigrationTaskResponse
- type CreateTopicOrBatchDeleteTopicReq
- type CreateTopicOrBatchDeleteTopicReqMessageType
- type CreateTopicOrBatchDeleteTopicReqMessageTypeEnum
- type CreateTopicOrBatchDeleteTopicReqPermission
- type CreateTopicOrBatchDeleteTopicReqPermissionEnum
- type CreateTopicOrBatchDeleteTopicRequest
- type CreateTopicOrBatchDeleteTopicResponse
- type CreateTopicReq
- type CreateTopicReqMessageType
- type CreateTopicReqMessageTypeEnum
- type CreateTopicReqPermission
- type CreateTopicReqPermissionEnum
- type CreateTopicResp
- type CreateUserRequest
- type CreateUserResponse
- type CreateUserResponseDefaultGroupPerm
- type CreateUserResponseDefaultGroupPermEnum
- type CreateUserResponseDefaultTopicPerm
- type CreateUserResponseDefaultTopicPermEnum
- type DeadletterResendReq
- type DeadletterResendRespResendResults
- type DeleteConsumerGroupRequest
- type DeleteConsumerGroupResponse
- type DeleteInstanceRequest
- type DeleteInstanceResponse
- type DeleteRocketMqMigrationTaskRequest
- type DeleteRocketMqMigrationTaskResponse
- type DeleteTopicRequest
- type DeleteTopicResponse
- type DeleteUserRequest
- type DeleteUserResponse
- type ExportDlqMessageReq
- type ExportDlqMessageRequest
- type ExportDlqMessageResponse
- type ListAccessPolicyRespPolicies
- type ListAvailableZonesRequest
- type ListAvailableZonesRespAvailableZones
- type ListAvailableZonesResponse
- type ListBrokersRequest
- type ListBrokersRespBrokers
- type ListBrokersResponse
- type ListConsumeGroupAccessPolicyRequest
- type ListConsumeGroupAccessPolicyRequestEngine
- type ListConsumeGroupAccessPolicyRequestEngineEnum
- type ListConsumeGroupAccessPolicyResponse
- type ListConsumerGroupOfTopicRequest
- type ListConsumerGroupOfTopicResponse
- type ListInstanceConsumerGroupsRequest
- type ListInstanceConsumerGroupsResponse
- type ListInstancesRequest
- type ListInstancesRequestEngine
- type ListInstancesRequestEngineEnum
- type ListInstancesRequestExactMatchName
- type ListInstancesRequestExactMatchNameEnum
- type ListInstancesRequestIncludeFailure
- type ListInstancesRequestIncludeFailureEnum
- type ListInstancesRequestStatus
- type ListInstancesRequestStatusEnum
- type ListInstancesResponse
- type ListMessageTraceRequest
- type ListMessageTraceRequestEngine
- type ListMessageTraceRequestEngineEnum
- type ListMessageTraceRespTrace
- type ListMessageTraceRespTraceMsgType
- type ListMessageTraceRespTraceMsgTypeEnum
- type ListMessageTraceRespTraceTraceType
- type ListMessageTraceRespTraceTraceTypeEnum
- type ListMessageTraceRespTraceTransactionState
- type ListMessageTraceRespTraceTransactionStateEnum
- type ListMessageTraceResponse
- type ListMessagesRequest
- type ListMessagesRequestEngine
- type ListMessagesRequestEngineEnum
- type ListMessagesResponse
- type ListRocketInstanceTopicsRequest
- type ListRocketInstanceTopicsResponse
- type ListRocketMqMigrationTaskRequest
- type ListRocketMqMigrationTaskRequestType
- type ListRocketMqMigrationTaskRequestTypeEnum
- type ListRocketMqMigrationTaskResponse
- type ListTopicAccessPolicyRequest
- type ListTopicAccessPolicyResponse
- type ListUserRequest
- type ListUserResponse
- type Message
- type MessagePropertyList
- type MetadataDeleteReq
- type MetadataTask
- type Queue
- type ResendReq
- type ResetConsumeOffsetReq
- type ResetConsumeOffsetRequest
- type ResetConsumeOffsetRequestEngine
- type ResetConsumeOffsetRequestEngineEnum
- type ResetConsumeOffsetRespQueues
- type ResetConsumeOffsetResponse
- type SendDlqMessageRequest
- type SendDlqMessageRequestEngine
- type SendDlqMessageRequestEngineEnum
- type SendDlqMessageResponse
- type ShowConsumerConnectionsRequest
- type ShowConsumerConnectionsResponse
- type ShowConsumerListOrDetailsRequest
- type ShowConsumerListOrDetailsResponse
- type ShowGroupRequest
- type ShowGroupResponse
- type ShowInstanceRequest
- type ShowInstanceResp
- type ShowInstanceRespType
- type ShowInstanceRespTypeEnum
- type ShowInstanceResponse
- type ShowInstanceResponseType
- type ShowInstanceResponseTypeEnum
- type ShowOneTopicRequest
- type ShowOneTopicResponse
- type ShowOneTopicResponseMessageType
- type ShowOneTopicResponseMessageTypeEnum
- type ShowOneTopicResponsePermission
- type ShowOneTopicResponsePermissionEnum
- type ShowRocketmqProjectTagsRequest
- type ShowRocketmqProjectTagsResponse
- type ShowRocketmqTagsRequest
- type ShowRocketmqTagsResponse
- type ShowTopicStatusRequest
- type ShowTopicStatusRespBrokers
- type ShowTopicStatusRespQueues
- type ShowTopicStatusResponse
- type ShowUserRequest
- type ShowUserResponse
- type ShowUserResponseDefaultGroupPerm
- type ShowUserResponseDefaultGroupPermEnum
- type ShowUserResponseDefaultTopicPerm
- type ShowUserResponseDefaultTopicPermEnum
- type Subscription
- type TagEntity
- type TagMultyValueEntity
- type Topic
- type TopicBrokers
- type TopicMessageType
- type TopicMessageTypeEnum
- type TopicPermission
- type TopicPermissionEnum
- type UpdateConsumerGroup
- type UpdateConsumerGroupRequest
- type UpdateConsumerGroupResponse
- type UpdateInstanceReq
- type UpdateInstanceRequest
- type UpdateInstanceResponse
- type UpdateTopicReq
- type UpdateTopicReqPermission
- type UpdateTopicReqPermissionEnum
- type UpdateTopicRequest
- type UpdateTopicResponse
- type UpdateUserRequest
- type UpdateUserResponse
- type UpdateUserResponseDefaultGroupPerm
- type UpdateUserResponseDefaultGroupPermEnum
- type UpdateUserResponseDefaultTopicPerm
- type UpdateUserResponseDefaultTopicPermEnum
- type User
- type UserDefaultGroupPerm
- type UserDefaultGroupPermEnum
- type UserDefaultTopicPerm
- type UserDefaultTopicPermEnum
- type UserGroupPerms
- type UserGroupPermsPerm
- type UserGroupPermsPermEnum
- type UserTopicPerms
- type UserTopicPermsPerm
- type UserTopicPermsPermEnum
- type ValidateConsumedMessageRequest
- type ValidateConsumedMessageRequestEngine
- type ValidateConsumedMessageRequestEngineEnum
- type ValidateConsumedMessageResponse
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BatchCreateOrDeleteRocketmqTagRequest ¶
type BatchCreateOrDeleteRocketmqTagRequest struct { InstanceId string `json:"instance_id"` Body *BatchCreateOrDeleteTagReq `json:"body,omitempty"` }
func (BatchCreateOrDeleteRocketmqTagRequest) String ¶
func (o BatchCreateOrDeleteRocketmqTagRequest) String() string
type BatchCreateOrDeleteRocketmqTagResponse ¶
type BatchCreateOrDeleteRocketmqTagResponse struct {
HttpStatusCode int `json:"-"`
}
func (BatchCreateOrDeleteRocketmqTagResponse) String ¶
func (o BatchCreateOrDeleteRocketmqTagResponse) String() string
type BatchCreateOrDeleteTagReq ¶
type BatchCreateOrDeleteTagReq struct { Action *BatchCreateOrDeleteTagReqAction `json:"action,omitempty"` Tags *[]TagEntity `json:"tags,omitempty"` }
func (BatchCreateOrDeleteTagReq) String ¶
func (o BatchCreateOrDeleteTagReq) String() string
type BatchCreateOrDeleteTagReqAction ¶
type BatchCreateOrDeleteTagReqAction struct {
// contains filtered or unexported fields
}
func (BatchCreateOrDeleteTagReqAction) MarshalJSON ¶
func (c BatchCreateOrDeleteTagReqAction) MarshalJSON() ([]byte, error)
func (*BatchCreateOrDeleteTagReqAction) UnmarshalJSON ¶
func (c *BatchCreateOrDeleteTagReqAction) UnmarshalJSON(b []byte) error
func (BatchCreateOrDeleteTagReqAction) Value ¶
func (c BatchCreateOrDeleteTagReqAction) Value() string
type BatchCreateOrDeleteTagReqActionEnum ¶
type BatchCreateOrDeleteTagReqActionEnum struct { CREATE BatchCreateOrDeleteTagReqAction DELETE BatchCreateOrDeleteTagReqAction }
func GetBatchCreateOrDeleteTagReqActionEnum ¶
func GetBatchCreateOrDeleteTagReqActionEnum() BatchCreateOrDeleteTagReqActionEnum
type BatchDeleteConsumerGroupReq ¶
type BatchDeleteConsumerGroupReq struct {
Groups *[]string `json:"groups,omitempty"`
}
func (BatchDeleteConsumerGroupReq) String ¶
func (o BatchDeleteConsumerGroupReq) String() string
type BatchDeleteConsumerGroupResp ¶
type BatchDeleteConsumerGroupResp struct {
JobId *string `json:"job_id,omitempty"`
}
func (BatchDeleteConsumerGroupResp) String ¶
func (o BatchDeleteConsumerGroupResp) String() string
type BatchDeleteInstanceReq ¶
type BatchDeleteInstanceReq struct { Instances *[]string `json:"instances,omitempty"` Action BatchDeleteInstanceReqAction `json:"action"` AllFailure *BatchDeleteInstanceReqAllFailure `json:"allFailure,omitempty"` }
func (BatchDeleteInstanceReq) String ¶
func (o BatchDeleteInstanceReq) String() string
type BatchDeleteInstanceReqAction ¶
type BatchDeleteInstanceReqAction struct {
// contains filtered or unexported fields
}
func (BatchDeleteInstanceReqAction) MarshalJSON ¶
func (c BatchDeleteInstanceReqAction) MarshalJSON() ([]byte, error)
func (*BatchDeleteInstanceReqAction) UnmarshalJSON ¶
func (c *BatchDeleteInstanceReqAction) UnmarshalJSON(b []byte) error
func (BatchDeleteInstanceReqAction) Value ¶
func (c BatchDeleteInstanceReqAction) Value() string
type BatchDeleteInstanceReqActionEnum ¶
type BatchDeleteInstanceReqActionEnum struct {
DELETE BatchDeleteInstanceReqAction
}
func GetBatchDeleteInstanceReqActionEnum ¶
func GetBatchDeleteInstanceReqActionEnum() BatchDeleteInstanceReqActionEnum
type BatchDeleteInstanceReqAllFailure ¶
type BatchDeleteInstanceReqAllFailure struct {
// contains filtered or unexported fields
}
func (BatchDeleteInstanceReqAllFailure) MarshalJSON ¶
func (c BatchDeleteInstanceReqAllFailure) MarshalJSON() ([]byte, error)
func (*BatchDeleteInstanceReqAllFailure) UnmarshalJSON ¶
func (c *BatchDeleteInstanceReqAllFailure) UnmarshalJSON(b []byte) error
func (BatchDeleteInstanceReqAllFailure) Value ¶
func (c BatchDeleteInstanceReqAllFailure) Value() string
type BatchDeleteInstanceReqAllFailureEnum ¶
type BatchDeleteInstanceReqAllFailureEnum struct {
RELIABILITY BatchDeleteInstanceReqAllFailure
}
func GetBatchDeleteInstanceReqAllFailureEnum ¶
func GetBatchDeleteInstanceReqAllFailureEnum() BatchDeleteInstanceReqAllFailureEnum
type BatchDeleteInstanceRespResults ¶
type BatchDeleteInstanceRespResults struct { Result *BatchDeleteInstanceRespResultsResult `json:"result,omitempty"` Instance *string `json:"instance,omitempty"` }
func (BatchDeleteInstanceRespResults) String ¶
func (o BatchDeleteInstanceRespResults) String() string
type BatchDeleteInstanceRespResultsResult ¶
type BatchDeleteInstanceRespResultsResult struct {
// contains filtered or unexported fields
}
func (BatchDeleteInstanceRespResultsResult) MarshalJSON ¶
func (c BatchDeleteInstanceRespResultsResult) MarshalJSON() ([]byte, error)
func (*BatchDeleteInstanceRespResultsResult) UnmarshalJSON ¶
func (c *BatchDeleteInstanceRespResultsResult) UnmarshalJSON(b []byte) error
func (BatchDeleteInstanceRespResultsResult) Value ¶
func (c BatchDeleteInstanceRespResultsResult) Value() string
type BatchDeleteInstanceRespResultsResultEnum ¶
type BatchDeleteInstanceRespResultsResultEnum struct { SUCCESS BatchDeleteInstanceRespResultsResult FAILED BatchDeleteInstanceRespResultsResult }
func GetBatchDeleteInstanceRespResultsResultEnum ¶
func GetBatchDeleteInstanceRespResultsResultEnum() BatchDeleteInstanceRespResultsResultEnum
type BatchDeleteInstancesRequest ¶
type BatchDeleteInstancesRequest struct {
Body *BatchDeleteInstanceReq `json:"body,omitempty"`
}
func (BatchDeleteInstancesRequest) String ¶
func (o BatchDeleteInstancesRequest) String() string
type BatchDeleteInstancesResponse ¶
type BatchDeleteInstancesResponse struct { Results *[]BatchDeleteInstanceRespResults `json:"results,omitempty"` HttpStatusCode int `json:"-"` }
func (BatchDeleteInstancesResponse) String ¶
func (o BatchDeleteInstancesResponse) String() string
type BatchDeleteTopicReq ¶
type BatchDeleteTopicReq struct {
Topics *[]string `json:"topics,omitempty"`
}
func (BatchDeleteTopicReq) String ¶
func (o BatchDeleteTopicReq) String() string
type BatchDeleteTopicResp ¶
type BatchDeleteTopicResp struct {
JobId *string `json:"job_id,omitempty"`
}
func (BatchDeleteTopicResp) String ¶
func (o BatchDeleteTopicResp) String() string
type BatchUpdateConsumerGroupReq ¶
type BatchUpdateConsumerGroupReq struct {
Groups *[]ConsumerGroup `json:"groups,omitempty"`
}
func (BatchUpdateConsumerGroupReq) String ¶
func (o BatchUpdateConsumerGroupReq) String() string
type BatchUpdateConsumerGroupRequest ¶
type BatchUpdateConsumerGroupRequest struct { InstanceId string `json:"instance_id"` Body *BatchUpdateConsumerGroupReq `json:"body,omitempty"` }
func (BatchUpdateConsumerGroupRequest) String ¶
func (o BatchUpdateConsumerGroupRequest) String() string
type BatchUpdateConsumerGroupResponse ¶
type BatchUpdateConsumerGroupResponse struct { JobId *string `json:"job_id,omitempty"` HttpStatusCode int `json:"-"` }
func (BatchUpdateConsumerGroupResponse) String ¶
func (o BatchUpdateConsumerGroupResponse) String() string
type Brokers ¶
type BssParam ¶
type BssParam struct { IsAutoRenew *bool `json:"is_auto_renew,omitempty"` ChargingMode *BssParamChargingMode `json:"charging_mode,omitempty"` IsAutoPay *bool `json:"is_auto_pay,omitempty"` PeriodType *BssParamPeriodType `json:"period_type,omitempty"` PeriodNum *int32 `json:"period_num,omitempty"` OrderId *string `json:"order_id,omitempty"` }
type BssParamChargingMode ¶
type BssParamChargingMode struct {
// contains filtered or unexported fields
}
func (BssParamChargingMode) MarshalJSON ¶
func (c BssParamChargingMode) MarshalJSON() ([]byte, error)
func (*BssParamChargingMode) UnmarshalJSON ¶
func (c *BssParamChargingMode) UnmarshalJSON(b []byte) error
func (BssParamChargingMode) Value ¶
func (c BssParamChargingMode) Value() string
type BssParamChargingModeEnum ¶
type BssParamChargingModeEnum struct { PRE_PAID BssParamChargingMode POST_PAID BssParamChargingMode }
func GetBssParamChargingModeEnum ¶
func GetBssParamChargingModeEnum() BssParamChargingModeEnum
type BssParamPeriodType ¶
type BssParamPeriodType struct {
// contains filtered or unexported fields
}
func (BssParamPeriodType) MarshalJSON ¶
func (c BssParamPeriodType) MarshalJSON() ([]byte, error)
func (*BssParamPeriodType) UnmarshalJSON ¶
func (c *BssParamPeriodType) UnmarshalJSON(b []byte) error
func (BssParamPeriodType) Value ¶
func (c BssParamPeriodType) Value() string
type BssParamPeriodTypeEnum ¶
type BssParamPeriodTypeEnum struct { MONTH BssParamPeriodType YEAR BssParamPeriodType }
func GetBssParamPeriodTypeEnum ¶
func GetBssParamPeriodTypeEnum() BssParamPeriodTypeEnum
type ClientData ¶
type ClientData struct { Language *string `json:"language,omitempty"` Version *string `json:"version,omitempty"` ClientId *string `json:"client_id,omitempty"` ClientAddr *string `json:"client_addr,omitempty"` Subscriptions *[]Subscription `json:"subscriptions,omitempty"` }
func (ClientData) String ¶
func (o ClientData) String() string
type ConsumerDetailResp ¶
type ConsumerDetailResp struct { Lag *int64 `json:"lag,omitempty"` MaxOffset *int64 `json:"max_offset,omitempty"` ConsumerOffset *int64 `json:"consumer_offset,omitempty"` Brokers *[]Brokers `json:"brokers,omitempty"` }
func (ConsumerDetailResp) String ¶
func (o ConsumerDetailResp) String() string
type ConsumerGroup ¶
type ConsumerGroup struct { Enabled *bool `json:"enabled,omitempty"` Broadcast *bool `json:"broadcast,omitempty"` Brokers *[]string `json:"brokers,omitempty"` Name *string `json:"name,omitempty"` GroupDesc *string `json:"group_desc,omitempty"` RetryMaxTime float32 `json:"retry_max_time,omitempty"` FromBeginning *bool `json:"from_beginning,omitempty"` }
func (ConsumerGroup) String ¶
func (o ConsumerGroup) String() string
type ConsumerList ¶
type ConsumerList struct { Topics *[]string `json:"topics,omitempty"` Total *int32 `json:"total,omitempty"` }
func (ConsumerList) String ¶
func (o ConsumerList) String() string
type CreateConsumerGroupOrBatchDeleteConsumerGroupReq ¶
type CreateConsumerGroupOrBatchDeleteConsumerGroupReq struct { Groups *[]string `json:"groups,omitempty"` Enabled *bool `json:"enabled,omitempty"` Broadcast *bool `json:"broadcast,omitempty"` Brokers *[]string `json:"brokers,omitempty"` Name *string `json:"name,omitempty"` GroupDesc *string `json:"group_desc,omitempty"` RetryMaxTime float32 `json:"retry_max_time,omitempty"` FromBeginning *bool `json:"from_beginning,omitempty"` }
func (CreateConsumerGroupOrBatchDeleteConsumerGroupReq) String ¶
func (o CreateConsumerGroupOrBatchDeleteConsumerGroupReq) String() string
type CreateConsumerGroupOrBatchDeleteConsumerGroupRequest ¶
type CreateConsumerGroupOrBatchDeleteConsumerGroupRequest struct { InstanceId string `json:"instance_id"` Action *string `json:"action,omitempty"` Body *CreateConsumerGroupOrBatchDeleteConsumerGroupReq `json:"body,omitempty"` }
func (CreateConsumerGroupOrBatchDeleteConsumerGroupRequest) String ¶
func (o CreateConsumerGroupOrBatchDeleteConsumerGroupRequest) String() string
type CreateConsumerGroupOrBatchDeleteConsumerGroupResponse ¶
type CreateConsumerGroupOrBatchDeleteConsumerGroupResponse struct { JobId *string `json:"job_id,omitempty"` Name *string `json:"name,omitempty"` HttpStatusCode int `json:"-"` }
func (CreateConsumerGroupOrBatchDeleteConsumerGroupResponse) String ¶
func (o CreateConsumerGroupOrBatchDeleteConsumerGroupResponse) String() string
type CreateGroupResp ¶
type CreateGroupResp struct {
Name *string `json:"name,omitempty"`
}
func (CreateGroupResp) String ¶
func (o CreateGroupResp) String() string
type CreateInstanceByEngineReq ¶
type CreateInstanceByEngineReq struct { Name string `json:"name"` Description *string `json:"description,omitempty"` Engine CreateInstanceByEngineReqEngine `json:"engine"` EngineVersion CreateInstanceByEngineReqEngineVersion `json:"engine_version"` StorageSpace int32 `json:"storage_space"` VpcId string `json:"vpc_id"` SubnetId string `json:"subnet_id"` SecurityGroupId string `json:"security_group_id"` AvailableZones []string `json:"available_zones"` ProductId CreateInstanceByEngineReqProductId `json:"product_id"` SslEnable *bool `json:"ssl_enable,omitempty"` StorageSpecCode CreateInstanceByEngineReqStorageSpecCode `json:"storage_spec_code"` EnterpriseProjectId *string `json:"enterprise_project_id,omitempty"` EnableAcl *bool `json:"enable_acl,omitempty"` Ipv6Enable *bool `json:"ipv6_enable,omitempty"` EnablePublicip *bool `json:"enable_publicip,omitempty"` PublicipId *string `json:"publicip_id,omitempty"` BrokerNum int32 `json:"broker_num"` BssParam *BssParam `json:"bss_param,omitempty"` }
func (CreateInstanceByEngineReq) String ¶
func (o CreateInstanceByEngineReq) String() string
type CreateInstanceByEngineReqEngine ¶
type CreateInstanceByEngineReqEngine struct {
// contains filtered or unexported fields
}
func (CreateInstanceByEngineReqEngine) MarshalJSON ¶
func (c CreateInstanceByEngineReqEngine) MarshalJSON() ([]byte, error)
func (*CreateInstanceByEngineReqEngine) UnmarshalJSON ¶
func (c *CreateInstanceByEngineReqEngine) UnmarshalJSON(b []byte) error
func (CreateInstanceByEngineReqEngine) Value ¶
func (c CreateInstanceByEngineReqEngine) Value() string
type CreateInstanceByEngineReqEngineEnum ¶
type CreateInstanceByEngineReqEngineEnum struct {
RELIABILITY CreateInstanceByEngineReqEngine
}
func GetCreateInstanceByEngineReqEngineEnum ¶
func GetCreateInstanceByEngineReqEngineEnum() CreateInstanceByEngineReqEngineEnum
type CreateInstanceByEngineReqEngineVersion ¶
type CreateInstanceByEngineReqEngineVersion struct {
// contains filtered or unexported fields
}
func (CreateInstanceByEngineReqEngineVersion) MarshalJSON ¶
func (c CreateInstanceByEngineReqEngineVersion) MarshalJSON() ([]byte, error)
func (*CreateInstanceByEngineReqEngineVersion) UnmarshalJSON ¶
func (c *CreateInstanceByEngineReqEngineVersion) UnmarshalJSON(b []byte) error
func (CreateInstanceByEngineReqEngineVersion) Value ¶
func (c CreateInstanceByEngineReqEngineVersion) Value() string
type CreateInstanceByEngineReqEngineVersionEnum ¶
type CreateInstanceByEngineReqEngineVersionEnum struct {
E_4_8_0 CreateInstanceByEngineReqEngineVersion
}
func GetCreateInstanceByEngineReqEngineVersionEnum ¶
func GetCreateInstanceByEngineReqEngineVersionEnum() CreateInstanceByEngineReqEngineVersionEnum
type CreateInstanceByEngineReqProductId ¶
type CreateInstanceByEngineReqProductId struct {
// contains filtered or unexported fields
}
func (CreateInstanceByEngineReqProductId) MarshalJSON ¶
func (c CreateInstanceByEngineReqProductId) MarshalJSON() ([]byte, error)
func (*CreateInstanceByEngineReqProductId) UnmarshalJSON ¶
func (c *CreateInstanceByEngineReqProductId) UnmarshalJSON(b []byte) error
func (CreateInstanceByEngineReqProductId) Value ¶
func (c CreateInstanceByEngineReqProductId) Value() string
type CreateInstanceByEngineReqProductIdEnum ¶
type CreateInstanceByEngineReqProductIdEnum struct { C6_4U8G_CLUSTER_SMALL CreateInstanceByEngineReqProductId C6_4U8G_CLUSTER CreateInstanceByEngineReqProductId C6_8U16G_CLUSTER CreateInstanceByEngineReqProductId C6_12U24G_CLUSTER CreateInstanceByEngineReqProductId C6_16U32G_CLUSTER CreateInstanceByEngineReqProductId }
func GetCreateInstanceByEngineReqProductIdEnum ¶
func GetCreateInstanceByEngineReqProductIdEnum() CreateInstanceByEngineReqProductIdEnum
type CreateInstanceByEngineReqStorageSpecCode ¶
type CreateInstanceByEngineReqStorageSpecCode struct {
// contains filtered or unexported fields
}
func (CreateInstanceByEngineReqStorageSpecCode) MarshalJSON ¶
func (c CreateInstanceByEngineReqStorageSpecCode) MarshalJSON() ([]byte, error)
func (*CreateInstanceByEngineReqStorageSpecCode) UnmarshalJSON ¶
func (c *CreateInstanceByEngineReqStorageSpecCode) UnmarshalJSON(b []byte) error
func (CreateInstanceByEngineReqStorageSpecCode) Value ¶
func (c CreateInstanceByEngineReqStorageSpecCode) Value() string
type CreateInstanceByEngineReqStorageSpecCodeEnum ¶
type CreateInstanceByEngineReqStorageSpecCodeEnum struct { DMS_PHYSICAL_STORAGE_HIGH_V2 CreateInstanceByEngineReqStorageSpecCode DMS_PHYSICAL_STORAGE_ULTRA_V2 CreateInstanceByEngineReqStorageSpecCode }
func GetCreateInstanceByEngineReqStorageSpecCodeEnum ¶
func GetCreateInstanceByEngineReqStorageSpecCodeEnum() CreateInstanceByEngineReqStorageSpecCodeEnum
type CreateInstanceByEngineRequest ¶
type CreateInstanceByEngineRequest struct { Engine CreateInstanceByEngineRequestEngine `json:"engine"` Body *CreateInstanceByEngineReq `json:"body,omitempty"` }
func (CreateInstanceByEngineRequest) String ¶
func (o CreateInstanceByEngineRequest) String() string
type CreateInstanceByEngineRequestEngine ¶
type CreateInstanceByEngineRequestEngine struct {
// contains filtered or unexported fields
}
func (CreateInstanceByEngineRequestEngine) MarshalJSON ¶
func (c CreateInstanceByEngineRequestEngine) MarshalJSON() ([]byte, error)
func (*CreateInstanceByEngineRequestEngine) UnmarshalJSON ¶
func (c *CreateInstanceByEngineRequestEngine) UnmarshalJSON(b []byte) error
func (CreateInstanceByEngineRequestEngine) Value ¶
func (c CreateInstanceByEngineRequestEngine) Value() string
type CreateInstanceByEngineRequestEngineEnum ¶
type CreateInstanceByEngineRequestEngineEnum struct {
RELIABILITY CreateInstanceByEngineRequestEngine
}
func GetCreateInstanceByEngineRequestEngineEnum ¶
func GetCreateInstanceByEngineRequestEngineEnum() CreateInstanceByEngineRequestEngineEnum
type CreateInstanceByEngineResponse ¶
type CreateInstanceByEngineResponse struct { InstanceId *string `json:"instance_id,omitempty"` HttpStatusCode int `json:"-"` }
func (CreateInstanceByEngineResponse) String ¶
func (o CreateInstanceByEngineResponse) String() string
type CreatePostPaidInstanceReq ¶
type CreatePostPaidInstanceReq struct { Name string `json:"name"` Description *string `json:"description,omitempty"` Engine CreatePostPaidInstanceReqEngine `json:"engine"` EngineVersion CreatePostPaidInstanceReqEngineVersion `json:"engine_version"` StorageSpace int32 `json:"storage_space"` VpcId string `json:"vpc_id"` SubnetId string `json:"subnet_id"` SecurityGroupId string `json:"security_group_id"` AvailableZones []string `json:"available_zones"` ProductId CreatePostPaidInstanceReqProductId `json:"product_id"` SslEnable *bool `json:"ssl_enable,omitempty"` StorageSpecCode CreatePostPaidInstanceReqStorageSpecCode `json:"storage_spec_code"` EnterpriseProjectId *string `json:"enterprise_project_id,omitempty"` EnableAcl *bool `json:"enable_acl,omitempty"` Ipv6Enable *bool `json:"ipv6_enable,omitempty"` EnablePublicip *bool `json:"enable_publicip,omitempty"` PublicipId *string `json:"publicip_id,omitempty"` BrokerNum int32 `json:"broker_num"` }
func (CreatePostPaidInstanceReq) String ¶
func (o CreatePostPaidInstanceReq) String() string
type CreatePostPaidInstanceReqEngine ¶
type CreatePostPaidInstanceReqEngine struct {
// contains filtered or unexported fields
}
func (CreatePostPaidInstanceReqEngine) MarshalJSON ¶
func (c CreatePostPaidInstanceReqEngine) MarshalJSON() ([]byte, error)
func (*CreatePostPaidInstanceReqEngine) UnmarshalJSON ¶
func (c *CreatePostPaidInstanceReqEngine) UnmarshalJSON(b []byte) error
func (CreatePostPaidInstanceReqEngine) Value ¶
func (c CreatePostPaidInstanceReqEngine) Value() string
type CreatePostPaidInstanceReqEngineEnum ¶
type CreatePostPaidInstanceReqEngineEnum struct {
RELIABILITY CreatePostPaidInstanceReqEngine
}
func GetCreatePostPaidInstanceReqEngineEnum ¶
func GetCreatePostPaidInstanceReqEngineEnum() CreatePostPaidInstanceReqEngineEnum
type CreatePostPaidInstanceReqEngineVersion ¶
type CreatePostPaidInstanceReqEngineVersion struct {
// contains filtered or unexported fields
}
func (CreatePostPaidInstanceReqEngineVersion) MarshalJSON ¶
func (c CreatePostPaidInstanceReqEngineVersion) MarshalJSON() ([]byte, error)
func (*CreatePostPaidInstanceReqEngineVersion) UnmarshalJSON ¶
func (c *CreatePostPaidInstanceReqEngineVersion) UnmarshalJSON(b []byte) error
func (CreatePostPaidInstanceReqEngineVersion) Value ¶
func (c CreatePostPaidInstanceReqEngineVersion) Value() string
type CreatePostPaidInstanceReqEngineVersionEnum ¶
type CreatePostPaidInstanceReqEngineVersionEnum struct {
E_4_8_0 CreatePostPaidInstanceReqEngineVersion
}
func GetCreatePostPaidInstanceReqEngineVersionEnum ¶
func GetCreatePostPaidInstanceReqEngineVersionEnum() CreatePostPaidInstanceReqEngineVersionEnum
type CreatePostPaidInstanceReqProductId ¶
type CreatePostPaidInstanceReqProductId struct {
// contains filtered or unexported fields
}
func (CreatePostPaidInstanceReqProductId) MarshalJSON ¶
func (c CreatePostPaidInstanceReqProductId) MarshalJSON() ([]byte, error)
func (*CreatePostPaidInstanceReqProductId) UnmarshalJSON ¶
func (c *CreatePostPaidInstanceReqProductId) UnmarshalJSON(b []byte) error
func (CreatePostPaidInstanceReqProductId) Value ¶
func (c CreatePostPaidInstanceReqProductId) Value() string
type CreatePostPaidInstanceReqProductIdEnum ¶
type CreatePostPaidInstanceReqProductIdEnum struct { C6_4U8G_CLUSTER CreatePostPaidInstanceReqProductId C6_8U16G_CLUSTER CreatePostPaidInstanceReqProductId C6_12U24G_CLUSTER CreatePostPaidInstanceReqProductId C6_16U32G_CLUSTER CreatePostPaidInstanceReqProductId }
func GetCreatePostPaidInstanceReqProductIdEnum ¶
func GetCreatePostPaidInstanceReqProductIdEnum() CreatePostPaidInstanceReqProductIdEnum
type CreatePostPaidInstanceReqStorageSpecCode ¶
type CreatePostPaidInstanceReqStorageSpecCode struct {
// contains filtered or unexported fields
}
func (CreatePostPaidInstanceReqStorageSpecCode) MarshalJSON ¶
func (c CreatePostPaidInstanceReqStorageSpecCode) MarshalJSON() ([]byte, error)
func (*CreatePostPaidInstanceReqStorageSpecCode) UnmarshalJSON ¶
func (c *CreatePostPaidInstanceReqStorageSpecCode) UnmarshalJSON(b []byte) error
func (CreatePostPaidInstanceReqStorageSpecCode) Value ¶
func (c CreatePostPaidInstanceReqStorageSpecCode) Value() string
type CreatePostPaidInstanceReqStorageSpecCodeEnum ¶
type CreatePostPaidInstanceReqStorageSpecCodeEnum struct { DMS_PHYSICAL_STORAGE_HIGH_V2 CreatePostPaidInstanceReqStorageSpecCode DMS_PHYSICAL_STORAGE_ULTRA_V2 CreatePostPaidInstanceReqStorageSpecCode }
func GetCreatePostPaidInstanceReqStorageSpecCodeEnum ¶
func GetCreatePostPaidInstanceReqStorageSpecCodeEnum() CreatePostPaidInstanceReqStorageSpecCodeEnum
type CreatePostPaidInstanceRequest ¶
type CreatePostPaidInstanceRequest struct {
Body *CreatePostPaidInstanceReq `json:"body,omitempty"`
}
func (CreatePostPaidInstanceRequest) String ¶
func (o CreatePostPaidInstanceRequest) String() string
type CreatePostPaidInstanceResponse ¶
type CreatePostPaidInstanceResponse struct { InstanceId *string `json:"instance_id,omitempty"` HttpStatusCode int `json:"-"` }
func (CreatePostPaidInstanceResponse) String ¶
func (o CreatePostPaidInstanceResponse) String() string
type CreateRocketMqMigrationTaskRequest ¶
type CreateRocketMqMigrationTaskRequest struct { InstanceId string `json:"instance_id"` Overwrite CreateRocketMqMigrationTaskRequestOverwrite `json:"overwrite"` Name string `json:"name"` Type CreateRocketMqMigrationTaskRequestType `json:"type"` Body *string `json:"body,omitempty"` }
func (CreateRocketMqMigrationTaskRequest) String ¶
func (o CreateRocketMqMigrationTaskRequest) String() string
type CreateRocketMqMigrationTaskRequestOverwrite ¶
type CreateRocketMqMigrationTaskRequestOverwrite struct {
// contains filtered or unexported fields
}
func (CreateRocketMqMigrationTaskRequestOverwrite) MarshalJSON ¶
func (c CreateRocketMqMigrationTaskRequestOverwrite) MarshalJSON() ([]byte, error)
func (*CreateRocketMqMigrationTaskRequestOverwrite) UnmarshalJSON ¶
func (c *CreateRocketMqMigrationTaskRequestOverwrite) UnmarshalJSON(b []byte) error
func (CreateRocketMqMigrationTaskRequestOverwrite) Value ¶
func (c CreateRocketMqMigrationTaskRequestOverwrite) Value() string
type CreateRocketMqMigrationTaskRequestOverwriteEnum ¶
type CreateRocketMqMigrationTaskRequestOverwriteEnum struct { TRUE CreateRocketMqMigrationTaskRequestOverwrite FALSE CreateRocketMqMigrationTaskRequestOverwrite }
func GetCreateRocketMqMigrationTaskRequestOverwriteEnum ¶
func GetCreateRocketMqMigrationTaskRequestOverwriteEnum() CreateRocketMqMigrationTaskRequestOverwriteEnum
type CreateRocketMqMigrationTaskRequestType ¶
type CreateRocketMqMigrationTaskRequestType struct {
// contains filtered or unexported fields
}
func (CreateRocketMqMigrationTaskRequestType) MarshalJSON ¶
func (c CreateRocketMqMigrationTaskRequestType) MarshalJSON() ([]byte, error)
func (*CreateRocketMqMigrationTaskRequestType) UnmarshalJSON ¶
func (c *CreateRocketMqMigrationTaskRequestType) UnmarshalJSON(b []byte) error
func (CreateRocketMqMigrationTaskRequestType) Value ¶
func (c CreateRocketMqMigrationTaskRequestType) Value() string
type CreateRocketMqMigrationTaskRequestTypeEnum ¶
type CreateRocketMqMigrationTaskRequestTypeEnum struct { ROCKETMQ CreateRocketMqMigrationTaskRequestType RABBIT_TO_ROCKET CreateRocketMqMigrationTaskRequestType }
func GetCreateRocketMqMigrationTaskRequestTypeEnum ¶
func GetCreateRocketMqMigrationTaskRequestTypeEnum() CreateRocketMqMigrationTaskRequestTypeEnum
type CreateRocketMqMigrationTaskResponse ¶
type CreateRocketMqMigrationTaskResponse struct { TaskId *string `json:"task_id,omitempty"` HttpStatusCode int `json:"-"` }
func (CreateRocketMqMigrationTaskResponse) String ¶
func (o CreateRocketMqMigrationTaskResponse) String() string
type CreateTopicOrBatchDeleteTopicReq ¶
type CreateTopicOrBatchDeleteTopicReq struct { Name *string `json:"name,omitempty"` Brokers *[]string `json:"brokers,omitempty"` QueueNum float32 `json:"queue_num,omitempty"` Permission *CreateTopicOrBatchDeleteTopicReqPermission `json:"permission,omitempty"` MessageType *CreateTopicOrBatchDeleteTopicReqMessageType `json:"message_type,omitempty"` Topics *[]string `json:"topics,omitempty"` }
func (CreateTopicOrBatchDeleteTopicReq) String ¶
func (o CreateTopicOrBatchDeleteTopicReq) String() string
type CreateTopicOrBatchDeleteTopicReqMessageType ¶
type CreateTopicOrBatchDeleteTopicReqMessageType struct {
// contains filtered or unexported fields
}
func (CreateTopicOrBatchDeleteTopicReqMessageType) MarshalJSON ¶
func (c CreateTopicOrBatchDeleteTopicReqMessageType) MarshalJSON() ([]byte, error)
func (*CreateTopicOrBatchDeleteTopicReqMessageType) UnmarshalJSON ¶
func (c *CreateTopicOrBatchDeleteTopicReqMessageType) UnmarshalJSON(b []byte) error
func (CreateTopicOrBatchDeleteTopicReqMessageType) Value ¶
func (c CreateTopicOrBatchDeleteTopicReqMessageType) Value() string
type CreateTopicOrBatchDeleteTopicReqMessageTypeEnum ¶
type CreateTopicOrBatchDeleteTopicReqMessageTypeEnum struct { NORMAL CreateTopicOrBatchDeleteTopicReqMessageType FIFO CreateTopicOrBatchDeleteTopicReqMessageType DELAY CreateTopicOrBatchDeleteTopicReqMessageType TRANSACTION CreateTopicOrBatchDeleteTopicReqMessageType }
func GetCreateTopicOrBatchDeleteTopicReqMessageTypeEnum ¶
func GetCreateTopicOrBatchDeleteTopicReqMessageTypeEnum() CreateTopicOrBatchDeleteTopicReqMessageTypeEnum
type CreateTopicOrBatchDeleteTopicReqPermission ¶
type CreateTopicOrBatchDeleteTopicReqPermission struct {
// contains filtered or unexported fields
}
func (CreateTopicOrBatchDeleteTopicReqPermission) MarshalJSON ¶
func (c CreateTopicOrBatchDeleteTopicReqPermission) MarshalJSON() ([]byte, error)
func (*CreateTopicOrBatchDeleteTopicReqPermission) UnmarshalJSON ¶
func (c *CreateTopicOrBatchDeleteTopicReqPermission) UnmarshalJSON(b []byte) error
func (CreateTopicOrBatchDeleteTopicReqPermission) Value ¶
func (c CreateTopicOrBatchDeleteTopicReqPermission) Value() string
type CreateTopicOrBatchDeleteTopicReqPermissionEnum ¶
type CreateTopicOrBatchDeleteTopicReqPermissionEnum struct { SUB CreateTopicOrBatchDeleteTopicReqPermission PUB CreateTopicOrBatchDeleteTopicReqPermission ALL CreateTopicOrBatchDeleteTopicReqPermission }
func GetCreateTopicOrBatchDeleteTopicReqPermissionEnum ¶
func GetCreateTopicOrBatchDeleteTopicReqPermissionEnum() CreateTopicOrBatchDeleteTopicReqPermissionEnum
type CreateTopicOrBatchDeleteTopicRequest ¶
type CreateTopicOrBatchDeleteTopicRequest struct { InstanceId string `json:"instance_id"` Action *string `json:"action,omitempty"` Body *CreateTopicOrBatchDeleteTopicReq `json:"body,omitempty"` }
func (CreateTopicOrBatchDeleteTopicRequest) String ¶
func (o CreateTopicOrBatchDeleteTopicRequest) String() string
type CreateTopicOrBatchDeleteTopicResponse ¶
type CreateTopicOrBatchDeleteTopicResponse struct { Id *string `json:"id,omitempty"` JobId *string `json:"job_id,omitempty"` HttpStatusCode int `json:"-"` }
func (CreateTopicOrBatchDeleteTopicResponse) String ¶
func (o CreateTopicOrBatchDeleteTopicResponse) String() string
type CreateTopicReq ¶
type CreateTopicReq struct { Name *string `json:"name,omitempty"` Brokers *[]string `json:"brokers,omitempty"` QueueNum float32 `json:"queue_num,omitempty"` Permission *CreateTopicReqPermission `json:"permission,omitempty"` MessageType *CreateTopicReqMessageType `json:"message_type,omitempty"` }
func (CreateTopicReq) String ¶
func (o CreateTopicReq) String() string
type CreateTopicReqMessageType ¶
type CreateTopicReqMessageType struct {
// contains filtered or unexported fields
}
func (CreateTopicReqMessageType) MarshalJSON ¶
func (c CreateTopicReqMessageType) MarshalJSON() ([]byte, error)
func (*CreateTopicReqMessageType) UnmarshalJSON ¶
func (c *CreateTopicReqMessageType) UnmarshalJSON(b []byte) error
func (CreateTopicReqMessageType) Value ¶
func (c CreateTopicReqMessageType) Value() string
type CreateTopicReqMessageTypeEnum ¶
type CreateTopicReqMessageTypeEnum struct { NORMAL CreateTopicReqMessageType FIFO CreateTopicReqMessageType DELAY CreateTopicReqMessageType TRANSACTION CreateTopicReqMessageType }
func GetCreateTopicReqMessageTypeEnum ¶
func GetCreateTopicReqMessageTypeEnum() CreateTopicReqMessageTypeEnum
type CreateTopicReqPermission ¶
type CreateTopicReqPermission struct {
// contains filtered or unexported fields
}
func (CreateTopicReqPermission) MarshalJSON ¶
func (c CreateTopicReqPermission) MarshalJSON() ([]byte, error)
func (*CreateTopicReqPermission) UnmarshalJSON ¶
func (c *CreateTopicReqPermission) UnmarshalJSON(b []byte) error
func (CreateTopicReqPermission) Value ¶
func (c CreateTopicReqPermission) Value() string
type CreateTopicReqPermissionEnum ¶
type CreateTopicReqPermissionEnum struct { SUB CreateTopicReqPermission PUB CreateTopicReqPermission ALL CreateTopicReqPermission }
func GetCreateTopicReqPermissionEnum ¶
func GetCreateTopicReqPermissionEnum() CreateTopicReqPermissionEnum
type CreateTopicResp ¶
type CreateTopicResp struct {
Id *string `json:"id,omitempty"`
}
func (CreateTopicResp) String ¶
func (o CreateTopicResp) String() string
type CreateUserRequest ¶
type CreateUserRequest struct { InstanceId string `json:"instance_id"` Body *User `json:"body,omitempty"` }
func (CreateUserRequest) String ¶
func (o CreateUserRequest) String() string
type CreateUserResponse ¶
type CreateUserResponse struct { AccessKey *string `json:"access_key,omitempty"` SecretKey *string `json:"secret_key,omitempty"` WhiteRemoteAddress *string `json:"white_remote_address,omitempty"` Admin *bool `json:"admin,omitempty"` DefaultTopicPerm *CreateUserResponseDefaultTopicPerm `json:"default_topic_perm,omitempty"` DefaultGroupPerm *CreateUserResponseDefaultGroupPerm `json:"default_group_perm,omitempty"` TopicPerms *[]UserTopicPerms `json:"topic_perms,omitempty"` GroupPerms *[]UserGroupPerms `json:"group_perms,omitempty"` HttpStatusCode int `json:"-"` }
func (CreateUserResponse) String ¶
func (o CreateUserResponse) String() string
type CreateUserResponseDefaultGroupPerm ¶
type CreateUserResponseDefaultGroupPerm struct {
// contains filtered or unexported fields
}
func (CreateUserResponseDefaultGroupPerm) MarshalJSON ¶
func (c CreateUserResponseDefaultGroupPerm) MarshalJSON() ([]byte, error)
func (*CreateUserResponseDefaultGroupPerm) UnmarshalJSON ¶
func (c *CreateUserResponseDefaultGroupPerm) UnmarshalJSON(b []byte) error
func (CreateUserResponseDefaultGroupPerm) Value ¶
func (c CreateUserResponseDefaultGroupPerm) Value() string
type CreateUserResponseDefaultGroupPermEnum ¶
type CreateUserResponseDefaultGroupPermEnum struct { SUB CreateUserResponseDefaultGroupPerm DENY CreateUserResponseDefaultGroupPerm }
func GetCreateUserResponseDefaultGroupPermEnum ¶
func GetCreateUserResponseDefaultGroupPermEnum() CreateUserResponseDefaultGroupPermEnum
type CreateUserResponseDefaultTopicPerm ¶
type CreateUserResponseDefaultTopicPerm struct {
// contains filtered or unexported fields
}
func (CreateUserResponseDefaultTopicPerm) MarshalJSON ¶
func (c CreateUserResponseDefaultTopicPerm) MarshalJSON() ([]byte, error)
func (*CreateUserResponseDefaultTopicPerm) UnmarshalJSON ¶
func (c *CreateUserResponseDefaultTopicPerm) UnmarshalJSON(b []byte) error
func (CreateUserResponseDefaultTopicPerm) Value ¶
func (c CreateUserResponseDefaultTopicPerm) Value() string
type CreateUserResponseDefaultTopicPermEnum ¶
type CreateUserResponseDefaultTopicPermEnum struct { PUB CreateUserResponseDefaultTopicPerm SUB CreateUserResponseDefaultTopicPerm PUB_SUB CreateUserResponseDefaultTopicPerm DENY CreateUserResponseDefaultTopicPerm }
func GetCreateUserResponseDefaultTopicPermEnum ¶
func GetCreateUserResponseDefaultTopicPermEnum() CreateUserResponseDefaultTopicPermEnum
type DeadletterResendReq ¶
type DeadletterResendReq struct { Topic *string `json:"topic,omitempty"` MsgIdList *[]string `json:"msg_id_list,omitempty"` }
func (DeadletterResendReq) String ¶
func (o DeadletterResendReq) String() string
type DeadletterResendRespResendResults ¶
type DeadletterResendRespResendResults struct { MsgId *string `json:"msg_id,omitempty"` ErrorCode *string `json:"error_code,omitempty"` ErrorMessage *string `json:"error_message,omitempty"` }
func (DeadletterResendRespResendResults) String ¶
func (o DeadletterResendRespResendResults) String() string
type DeleteConsumerGroupRequest ¶
type DeleteConsumerGroupRequest struct { InstanceId string `json:"instance_id"` Group string `json:"group"` }
func (DeleteConsumerGroupRequest) String ¶
func (o DeleteConsumerGroupRequest) String() string
type DeleteConsumerGroupResponse ¶
type DeleteConsumerGroupResponse struct {
HttpStatusCode int `json:"-"`
}
func (DeleteConsumerGroupResponse) String ¶
func (o DeleteConsumerGroupResponse) String() string
type DeleteInstanceRequest ¶
type DeleteInstanceRequest struct {
InstanceId string `json:"instance_id"`
}
func (DeleteInstanceRequest) String ¶
func (o DeleteInstanceRequest) String() string
type DeleteInstanceResponse ¶
type DeleteInstanceResponse struct {
HttpStatusCode int `json:"-"`
}
func (DeleteInstanceResponse) String ¶
func (o DeleteInstanceResponse) String() string
type DeleteRocketMqMigrationTaskRequest ¶
type DeleteRocketMqMigrationTaskRequest struct { InstanceId string `json:"instance_id"` Body *MetadataDeleteReq `json:"body,omitempty"` }
func (DeleteRocketMqMigrationTaskRequest) String ¶
func (o DeleteRocketMqMigrationTaskRequest) String() string
type DeleteRocketMqMigrationTaskResponse ¶
type DeleteRocketMqMigrationTaskResponse struct { Body *string `json:"body,omitempty"` HttpStatusCode int `json:"-"` }
func (DeleteRocketMqMigrationTaskResponse) String ¶
func (o DeleteRocketMqMigrationTaskResponse) String() string
type DeleteTopicRequest ¶
type DeleteTopicRequest struct { InstanceId string `json:"instance_id"` Topic string `json:"topic"` }
func (DeleteTopicRequest) String ¶
func (o DeleteTopicRequest) String() string
type DeleteTopicResponse ¶
type DeleteTopicResponse struct {
HttpStatusCode int `json:"-"`
}
func (DeleteTopicResponse) String ¶
func (o DeleteTopicResponse) String() string
type DeleteUserRequest ¶
type DeleteUserRequest struct { InstanceId string `json:"instance_id"` UserName string `json:"user_name"` }
func (DeleteUserRequest) String ¶
func (o DeleteUserRequest) String() string
type DeleteUserResponse ¶
type DeleteUserResponse struct { Message *string `json:"message,omitempty"` HttpStatusCode int `json:"-"` }
func (DeleteUserResponse) String ¶
func (o DeleteUserResponse) String() string
type ExportDlqMessageReq ¶
type ExportDlqMessageReq struct { Topic *string `json:"topic,omitempty"` MsgIdList *[]string `json:"msg_id_list,omitempty"` UniqKeyList *[]string `json:"uniq_key_list,omitempty"` }
func (ExportDlqMessageReq) String ¶
func (o ExportDlqMessageReq) String() string
type ExportDlqMessageRequest ¶
type ExportDlqMessageRequest struct { InstanceId string `json:"instance_id"` Body *ExportDlqMessageReq `json:"body,omitempty"` }
func (ExportDlqMessageRequest) String ¶
func (o ExportDlqMessageRequest) String() string
type ExportDlqMessageResponse ¶
type ExportDlqMessageResponse struct { Body *[]Message `json:"body,omitempty"` HttpStatusCode int `json:"-"` }
func (ExportDlqMessageResponse) String ¶
func (o ExportDlqMessageResponse) String() string
type ListAccessPolicyRespPolicies ¶
type ListAccessPolicyRespPolicies struct { AccessKey *string `json:"access_key,omitempty"` SecretKey *string `json:"secret_key,omitempty"` WhiteRemoteAddress *string `json:"white_remote_address,omitempty"` Admin *bool `json:"admin,omitempty"` Perm *string `json:"perm,omitempty"` }
func (ListAccessPolicyRespPolicies) String ¶
func (o ListAccessPolicyRespPolicies) String() string
type ListAvailableZonesRequest ¶
type ListAvailableZonesRequest struct { }
func (ListAvailableZonesRequest) String ¶
func (o ListAvailableZonesRequest) String() string
type ListAvailableZonesRespAvailableZones ¶
type ListAvailableZonesRespAvailableZones struct { SoldOut *bool `json:"soldOut,omitempty"` Id *string `json:"id,omitempty"` Code *string `json:"code,omitempty"` Name *string `json:"name,omitempty"` Port *string `json:"port,omitempty"` ResourceAvailability *string `json:"resource_availability,omitempty"` DefaultAz *bool `json:"default_az,omitempty"` RemainTime *int64 `json:"remain_time,omitempty"` Ipv6Enable *bool `json:"ipv6_enable,omitempty"` }
func (ListAvailableZonesRespAvailableZones) String ¶
func (o ListAvailableZonesRespAvailableZones) String() string
type ListAvailableZonesResponse ¶
type ListAvailableZonesResponse struct { RegionId *string `json:"region_id,omitempty"` AvailableZones *[]ListAvailableZonesRespAvailableZones `json:"available_zones,omitempty"` HttpStatusCode int `json:"-"` }
func (ListAvailableZonesResponse) String ¶
func (o ListAvailableZonesResponse) String() string
type ListBrokersRequest ¶
type ListBrokersRequest struct {
InstanceId string `json:"instance_id"`
}
func (ListBrokersRequest) String ¶
func (o ListBrokersRequest) String() string
type ListBrokersRespBrokers ¶
type ListBrokersRespBrokers struct { Ids *[]float32 `json:"ids,omitempty"` BrokerName *string `json:"broker_name,omitempty"` }
func (ListBrokersRespBrokers) String ¶
func (o ListBrokersRespBrokers) String() string
type ListBrokersResponse ¶
type ListBrokersResponse struct { Brokers *[]ListBrokersRespBrokers `json:"brokers,omitempty"` HttpStatusCode int `json:"-"` }
func (ListBrokersResponse) String ¶
func (o ListBrokersResponse) String() string
type ListConsumeGroupAccessPolicyRequest ¶
type ListConsumeGroupAccessPolicyRequest struct { Engine ListConsumeGroupAccessPolicyRequestEngine `json:"engine"` InstanceId string `json:"instance_id"` GroupId string `json:"group_id"` Offset *string `json:"offset,omitempty"` Limit *string `json:"limit,omitempty"` }
func (ListConsumeGroupAccessPolicyRequest) String ¶
func (o ListConsumeGroupAccessPolicyRequest) String() string
type ListConsumeGroupAccessPolicyRequestEngine ¶
type ListConsumeGroupAccessPolicyRequestEngine struct {
// contains filtered or unexported fields
}
func (ListConsumeGroupAccessPolicyRequestEngine) MarshalJSON ¶
func (c ListConsumeGroupAccessPolicyRequestEngine) MarshalJSON() ([]byte, error)
func (*ListConsumeGroupAccessPolicyRequestEngine) UnmarshalJSON ¶
func (c *ListConsumeGroupAccessPolicyRequestEngine) UnmarshalJSON(b []byte) error
func (ListConsumeGroupAccessPolicyRequestEngine) Value ¶
func (c ListConsumeGroupAccessPolicyRequestEngine) Value() string
type ListConsumeGroupAccessPolicyRequestEngineEnum ¶
type ListConsumeGroupAccessPolicyRequestEngineEnum struct {
RELIABILITY ListConsumeGroupAccessPolicyRequestEngine
}
func GetListConsumeGroupAccessPolicyRequestEngineEnum ¶
func GetListConsumeGroupAccessPolicyRequestEngineEnum() ListConsumeGroupAccessPolicyRequestEngineEnum
type ListConsumeGroupAccessPolicyResponse ¶
type ListConsumeGroupAccessPolicyResponse struct { Policies *[]ListAccessPolicyRespPolicies `json:"policies,omitempty"` Total float32 `json:"total,omitempty"` Name *string `json:"name,omitempty"` HttpStatusCode int `json:"-"` }
func (ListConsumeGroupAccessPolicyResponse) String ¶
func (o ListConsumeGroupAccessPolicyResponse) String() string
type ListConsumerGroupOfTopicRequest ¶
type ListConsumerGroupOfTopicRequest struct { InstanceId string `json:"instance_id"` Topic string `json:"topic"` Limit *int32 `json:"limit,omitempty"` Offset *int32 `json:"offset,omitempty"` }
func (ListConsumerGroupOfTopicRequest) String ¶
func (o ListConsumerGroupOfTopicRequest) String() string
type ListConsumerGroupOfTopicResponse ¶
type ListConsumerGroupOfTopicResponse struct { Groups *[]string `json:"groups,omitempty"` HttpStatusCode int `json:"-"` }
func (ListConsumerGroupOfTopicResponse) String ¶
func (o ListConsumerGroupOfTopicResponse) String() string
type ListInstanceConsumerGroupsRequest ¶
type ListInstanceConsumerGroupsRequest struct { InstanceId string `json:"instance_id"` Group *string `json:"group,omitempty"` Limit *int32 `json:"limit,omitempty"` Offset *int32 `json:"offset,omitempty"` }
func (ListInstanceConsumerGroupsRequest) String ¶
func (o ListInstanceConsumerGroupsRequest) String() string
type ListInstanceConsumerGroupsResponse ¶
type ListInstanceConsumerGroupsResponse struct { Total float32 `json:"total,omitempty"` Groups *[]ConsumerGroup `json:"groups,omitempty"` Max float32 `json:"max,omitempty"` Remaining float32 `json:"remaining,omitempty"` NextOffset float32 `json:"next_offset,omitempty"` PreviousOffset float32 `json:"previous_offset,omitempty"` HttpStatusCode int `json:"-"` }
func (ListInstanceConsumerGroupsResponse) String ¶
func (o ListInstanceConsumerGroupsResponse) String() string
type ListInstancesRequest ¶
type ListInstancesRequest struct { Engine *ListInstancesRequestEngine `json:"engine,omitempty"` Name *string `json:"name,omitempty"` InstanceId *string `json:"instance_id,omitempty"` Status *ListInstancesRequestStatus `json:"status,omitempty"` IncludeFailure *ListInstancesRequestIncludeFailure `json:"include_failure,omitempty"` ExactMatchName *ListInstancesRequestExactMatchName `json:"exact_match_name,omitempty"` EnterpriseProjectId *string `json:"enterprise_project_id,omitempty"` Limit *int32 `json:"limit,omitempty"` Offset *int32 `json:"offset,omitempty"` }
func (ListInstancesRequest) String ¶
func (o ListInstancesRequest) String() string
type ListInstancesRequestEngine ¶
type ListInstancesRequestEngine struct {
// contains filtered or unexported fields
}
func (ListInstancesRequestEngine) MarshalJSON ¶
func (c ListInstancesRequestEngine) MarshalJSON() ([]byte, error)
func (*ListInstancesRequestEngine) UnmarshalJSON ¶
func (c *ListInstancesRequestEngine) UnmarshalJSON(b []byte) error
func (ListInstancesRequestEngine) Value ¶
func (c ListInstancesRequestEngine) Value() string
type ListInstancesRequestEngineEnum ¶
type ListInstancesRequestEngineEnum struct {
RELIABILITY ListInstancesRequestEngine
}
func GetListInstancesRequestEngineEnum ¶
func GetListInstancesRequestEngineEnum() ListInstancesRequestEngineEnum
type ListInstancesRequestExactMatchName ¶
type ListInstancesRequestExactMatchName struct {
// contains filtered or unexported fields
}
func (ListInstancesRequestExactMatchName) MarshalJSON ¶
func (c ListInstancesRequestExactMatchName) MarshalJSON() ([]byte, error)
func (*ListInstancesRequestExactMatchName) UnmarshalJSON ¶
func (c *ListInstancesRequestExactMatchName) UnmarshalJSON(b []byte) error
func (ListInstancesRequestExactMatchName) Value ¶
func (c ListInstancesRequestExactMatchName) Value() string
type ListInstancesRequestExactMatchNameEnum ¶
type ListInstancesRequestExactMatchNameEnum struct { TRUE ListInstancesRequestExactMatchName FALSE ListInstancesRequestExactMatchName }
func GetListInstancesRequestExactMatchNameEnum ¶
func GetListInstancesRequestExactMatchNameEnum() ListInstancesRequestExactMatchNameEnum
type ListInstancesRequestIncludeFailure ¶
type ListInstancesRequestIncludeFailure struct {
// contains filtered or unexported fields
}
func (ListInstancesRequestIncludeFailure) MarshalJSON ¶
func (c ListInstancesRequestIncludeFailure) MarshalJSON() ([]byte, error)
func (*ListInstancesRequestIncludeFailure) UnmarshalJSON ¶
func (c *ListInstancesRequestIncludeFailure) UnmarshalJSON(b []byte) error
func (ListInstancesRequestIncludeFailure) Value ¶
func (c ListInstancesRequestIncludeFailure) Value() string
type ListInstancesRequestIncludeFailureEnum ¶
type ListInstancesRequestIncludeFailureEnum struct { TRUE ListInstancesRequestIncludeFailure FALSE ListInstancesRequestIncludeFailure }
func GetListInstancesRequestIncludeFailureEnum ¶
func GetListInstancesRequestIncludeFailureEnum() ListInstancesRequestIncludeFailureEnum
type ListInstancesRequestStatus ¶
type ListInstancesRequestStatus struct {
// contains filtered or unexported fields
}
func (ListInstancesRequestStatus) MarshalJSON ¶
func (c ListInstancesRequestStatus) MarshalJSON() ([]byte, error)
func (*ListInstancesRequestStatus) UnmarshalJSON ¶
func (c *ListInstancesRequestStatus) UnmarshalJSON(b []byte) error
func (ListInstancesRequestStatus) Value ¶
func (c ListInstancesRequestStatus) Value() string
type ListInstancesRequestStatusEnum ¶
type ListInstancesRequestStatusEnum struct { CREATING ListInstancesRequestStatus RUNNING ListInstancesRequestStatus FAULTY ListInstancesRequestStatus RESTARTING ListInstancesRequestStatus RESIZING ListInstancesRequestStatus RESIZING_FAILED ListInstancesRequestStatus FROZEN ListInstancesRequestStatus }
func GetListInstancesRequestStatusEnum ¶
func GetListInstancesRequestStatusEnum() ListInstancesRequestStatusEnum
type ListInstancesResponse ¶
type ListInstancesResponse struct { Instances *[]ShowInstanceResp `json:"instances,omitempty"` InstanceNum *int32 `json:"instance_num,omitempty"` HttpStatusCode int `json:"-"` }
func (ListInstancesResponse) String ¶
func (o ListInstancesResponse) String() string
type ListMessageTraceRequest ¶
type ListMessageTraceRequest struct { Engine ListMessageTraceRequestEngine `json:"engine"` InstanceId string `json:"instance_id"` MsgId string `json:"msg_id"` }
func (ListMessageTraceRequest) String ¶
func (o ListMessageTraceRequest) String() string
type ListMessageTraceRequestEngine ¶
type ListMessageTraceRequestEngine struct {
// contains filtered or unexported fields
}
func (ListMessageTraceRequestEngine) MarshalJSON ¶
func (c ListMessageTraceRequestEngine) MarshalJSON() ([]byte, error)
func (*ListMessageTraceRequestEngine) UnmarshalJSON ¶
func (c *ListMessageTraceRequestEngine) UnmarshalJSON(b []byte) error
func (ListMessageTraceRequestEngine) Value ¶
func (c ListMessageTraceRequestEngine) Value() string
type ListMessageTraceRequestEngineEnum ¶
type ListMessageTraceRequestEngineEnum struct {
RELIABILITY ListMessageTraceRequestEngine
}
func GetListMessageTraceRequestEngineEnum ¶
func GetListMessageTraceRequestEngineEnum() ListMessageTraceRequestEngineEnum
type ListMessageTraceRespTrace ¶
type ListMessageTraceRespTrace struct { Success *bool `json:"success,omitempty"` TraceType *ListMessageTraceRespTraceTraceType `json:"trace_type,omitempty"` Timestamp float32 `json:"timestamp,omitempty"` GroupName *string `json:"group_name,omitempty"` CostTime float32 `json:"cost_time,omitempty"` RequestId *string `json:"request_id,omitempty"` ConsumeStatus float32 `json:"consume_status,omitempty"` Topic *string `json:"topic,omitempty"` MsgId *string `json:"msg_id,omitempty"` OffsetMsgId *string `json:"offset_msg_id,omitempty"` Tags *string `json:"tags,omitempty"` Keys *string `json:"keys,omitempty"` StoreHost *string `json:"store_host,omitempty"` ClientHost *string `json:"client_host,omitempty"` RetryTimes *string `json:"retry_times,omitempty"` BodyLength float32 `json:"body_length,omitempty"` MsgType *ListMessageTraceRespTraceMsgType `json:"msg_type,omitempty"` TransactionState *ListMessageTraceRespTraceTransactionState `json:"transaction_state,omitempty"` TransactionId *string `json:"transaction_id,omitempty"` FromTransactionCheck *bool `json:"from_transaction_check,omitempty"` }
func (ListMessageTraceRespTrace) String ¶
func (o ListMessageTraceRespTrace) String() string
type ListMessageTraceRespTraceMsgType ¶
type ListMessageTraceRespTraceMsgType struct {
// contains filtered or unexported fields
}
func (ListMessageTraceRespTraceMsgType) MarshalJSON ¶
func (c ListMessageTraceRespTraceMsgType) MarshalJSON() ([]byte, error)
func (*ListMessageTraceRespTraceMsgType) UnmarshalJSON ¶
func (c *ListMessageTraceRespTraceMsgType) UnmarshalJSON(b []byte) error
func (ListMessageTraceRespTraceMsgType) Value ¶
func (c ListMessageTraceRespTraceMsgType) Value() string
type ListMessageTraceRespTraceMsgTypeEnum ¶
type ListMessageTraceRespTraceMsgTypeEnum struct { NORMAL_MSG ListMessageTraceRespTraceMsgType TRANS_MSG_HALF ListMessageTraceRespTraceMsgType TRANS_MSG_COMMIT ListMessageTraceRespTraceMsgType DELAY_MSG ListMessageTraceRespTraceMsgType }
func GetListMessageTraceRespTraceMsgTypeEnum ¶
func GetListMessageTraceRespTraceMsgTypeEnum() ListMessageTraceRespTraceMsgTypeEnum
type ListMessageTraceRespTraceTraceType ¶
type ListMessageTraceRespTraceTraceType struct {
// contains filtered or unexported fields
}
func (ListMessageTraceRespTraceTraceType) MarshalJSON ¶
func (c ListMessageTraceRespTraceTraceType) MarshalJSON() ([]byte, error)
func (*ListMessageTraceRespTraceTraceType) UnmarshalJSON ¶
func (c *ListMessageTraceRespTraceTraceType) UnmarshalJSON(b []byte) error
func (ListMessageTraceRespTraceTraceType) Value ¶
func (c ListMessageTraceRespTraceTraceType) Value() string
type ListMessageTraceRespTraceTraceTypeEnum ¶
type ListMessageTraceRespTraceTraceTypeEnum struct { PUB ListMessageTraceRespTraceTraceType SUB ListMessageTraceRespTraceTraceType END_TRANSACTION ListMessageTraceRespTraceTraceType }
func GetListMessageTraceRespTraceTraceTypeEnum ¶
func GetListMessageTraceRespTraceTraceTypeEnum() ListMessageTraceRespTraceTraceTypeEnum
type ListMessageTraceRespTraceTransactionState ¶
type ListMessageTraceRespTraceTransactionState struct {
// contains filtered or unexported fields
}
func (ListMessageTraceRespTraceTransactionState) MarshalJSON ¶
func (c ListMessageTraceRespTraceTransactionState) MarshalJSON() ([]byte, error)
func (*ListMessageTraceRespTraceTransactionState) UnmarshalJSON ¶
func (c *ListMessageTraceRespTraceTransactionState) UnmarshalJSON(b []byte) error
func (ListMessageTraceRespTraceTransactionState) Value ¶
func (c ListMessageTraceRespTraceTransactionState) Value() string
type ListMessageTraceRespTraceTransactionStateEnum ¶
type ListMessageTraceRespTraceTransactionStateEnum struct { COMMIT_MESSAGE ListMessageTraceRespTraceTransactionState ROLLBACK_MESSAGE ListMessageTraceRespTraceTransactionState UNKNOW ListMessageTraceRespTraceTransactionState }
func GetListMessageTraceRespTraceTransactionStateEnum ¶
func GetListMessageTraceRespTraceTransactionStateEnum() ListMessageTraceRespTraceTransactionStateEnum
type ListMessageTraceResponse ¶
type ListMessageTraceResponse struct { Trace *[]ListMessageTraceRespTrace `json:"trace,omitempty"` HttpStatusCode int `json:"-"` }
func (ListMessageTraceResponse) String ¶
func (o ListMessageTraceResponse) String() string
type ListMessagesRequest ¶
type ListMessagesRequest struct { Engine ListMessagesRequestEngine `json:"engine"` InstanceId string `json:"instance_id"` Topic string `json:"topic"` Limit *string `json:"limit,omitempty"` Offset *string `json:"offset,omitempty"` Key *string `json:"key,omitempty"` StartTime *string `json:"start_time,omitempty"` EndTime *string `json:"end_time,omitempty"` MsgId *string `json:"msg_id,omitempty"` }
func (ListMessagesRequest) String ¶
func (o ListMessagesRequest) String() string
type ListMessagesRequestEngine ¶
type ListMessagesRequestEngine struct {
// contains filtered or unexported fields
}
func (ListMessagesRequestEngine) MarshalJSON ¶
func (c ListMessagesRequestEngine) MarshalJSON() ([]byte, error)
func (*ListMessagesRequestEngine) UnmarshalJSON ¶
func (c *ListMessagesRequestEngine) UnmarshalJSON(b []byte) error
func (ListMessagesRequestEngine) Value ¶
func (c ListMessagesRequestEngine) Value() string
type ListMessagesRequestEngineEnum ¶
type ListMessagesRequestEngineEnum struct {
RELIABILITY ListMessagesRequestEngine
}
func GetListMessagesRequestEngineEnum ¶
func GetListMessagesRequestEngineEnum() ListMessagesRequestEngineEnum
type ListMessagesResponse ¶
type ListMessagesResponse struct { Messages *[]Message `json:"messages,omitempty"` Total float32 `json:"total,omitempty"` HttpStatusCode int `json:"-"` }
func (ListMessagesResponse) String ¶
func (o ListMessagesResponse) String() string
type ListRocketInstanceTopicsRequest ¶
type ListRocketInstanceTopicsRequest struct { InstanceId string `json:"instance_id"` Limit *int32 `json:"limit,omitempty"` Offset *int32 `json:"offset,omitempty"` }
func (ListRocketInstanceTopicsRequest) String ¶
func (o ListRocketInstanceTopicsRequest) String() string
type ListRocketInstanceTopicsResponse ¶
type ListRocketInstanceTopicsResponse struct { Total *int32 `json:"total,omitempty"` Max *int32 `json:"max,omitempty"` Remaining *int32 `json:"remaining,omitempty"` NextOffset *int32 `json:"next_offset,omitempty"` PreviousOffset *int32 `json:"previous_offset,omitempty"` Topics *[]Topic `json:"topics,omitempty"` HttpStatusCode int `json:"-"` }
func (ListRocketInstanceTopicsResponse) String ¶
func (o ListRocketInstanceTopicsResponse) String() string
type ListRocketMqMigrationTaskRequest ¶
type ListRocketMqMigrationTaskRequest struct { InstanceId string `json:"instance_id"` Id *string `json:"id,omitempty"` Type *ListRocketMqMigrationTaskRequestType `json:"type,omitempty"` Offset *string `json:"offset,omitempty"` Limit *string `json:"limit,omitempty"` Name *string `json:"name,omitempty"` }
func (ListRocketMqMigrationTaskRequest) String ¶
func (o ListRocketMqMigrationTaskRequest) String() string
type ListRocketMqMigrationTaskRequestType ¶
type ListRocketMqMigrationTaskRequestType struct {
// contains filtered or unexported fields
}
func (ListRocketMqMigrationTaskRequestType) MarshalJSON ¶
func (c ListRocketMqMigrationTaskRequestType) MarshalJSON() ([]byte, error)
func (*ListRocketMqMigrationTaskRequestType) UnmarshalJSON ¶
func (c *ListRocketMqMigrationTaskRequestType) UnmarshalJSON(b []byte) error
func (ListRocketMqMigrationTaskRequestType) Value ¶
func (c ListRocketMqMigrationTaskRequestType) Value() string
type ListRocketMqMigrationTaskRequestTypeEnum ¶
type ListRocketMqMigrationTaskRequestTypeEnum struct { VHOST ListRocketMqMigrationTaskRequestType EXCHANGE ListRocketMqMigrationTaskRequestType QUEUE ListRocketMqMigrationTaskRequestType ALL ListRocketMqMigrationTaskRequestType }
func GetListRocketMqMigrationTaskRequestTypeEnum ¶
func GetListRocketMqMigrationTaskRequestTypeEnum() ListRocketMqMigrationTaskRequestTypeEnum
type ListRocketMqMigrationTaskResponse ¶
type ListRocketMqMigrationTaskResponse struct { Total *int32 `json:"total,omitempty"` Task *[]MetadataTask `json:"task,omitempty"` HttpStatusCode int `json:"-"` }
func (ListRocketMqMigrationTaskResponse) String ¶
func (o ListRocketMqMigrationTaskResponse) String() string
type ListTopicAccessPolicyRequest ¶
type ListTopicAccessPolicyRequest struct { InstanceId string `json:"instance_id"` Topic string `json:"topic"` Offset *string `json:"offset,omitempty"` Limit *string `json:"limit,omitempty"` }
func (ListTopicAccessPolicyRequest) String ¶
func (o ListTopicAccessPolicyRequest) String() string
type ListTopicAccessPolicyResponse ¶
type ListTopicAccessPolicyResponse struct { Policies *[]ListAccessPolicyRespPolicies `json:"policies,omitempty"` Total float32 `json:"total,omitempty"` Name *string `json:"name,omitempty"` HttpStatusCode int `json:"-"` }
func (ListTopicAccessPolicyResponse) String ¶
func (o ListTopicAccessPolicyResponse) String() string
type ListUserRequest ¶
type ListUserRequest struct { InstanceId string `json:"instance_id"` Offset *string `json:"offset,omitempty"` Limit *string `json:"limit,omitempty"` }
func (ListUserRequest) String ¶
func (o ListUserRequest) String() string
type ListUserResponse ¶
type ListUserResponse struct { Users *[]User `json:"users,omitempty"` Total float32 `json:"total,omitempty"` HttpStatusCode int `json:"-"` }
func (ListUserResponse) String ¶
func (o ListUserResponse) String() string
type Message ¶
type Message struct { MsgId *string `json:"msg_id,omitempty"` InstanceId *string `json:"instance_id,omitempty"` Topic *string `json:"topic,omitempty"` StoreTimestamp float32 `json:"store_timestamp,omitempty"` BornTimestamp float32 `json:"born_timestamp,omitempty"` ReconsumeTimes *int32 `json:"reconsume_times,omitempty"` Body *string `json:"body,omitempty"` BodyCrc float32 `json:"body_crc,omitempty"` StoreSize float32 `json:"store_size,omitempty"` PropertyList *[]MessagePropertyList `json:"property_list,omitempty"` BornHost *string `json:"born_host,omitempty"` StoreHost *string `json:"store_host,omitempty"` QueueId *int32 `json:"queue_id,omitempty"` QueueOffset *int32 `json:"queue_offset,omitempty"` }
type MessagePropertyList ¶
type MessagePropertyList struct { Name *string `json:"name,omitempty"` Value *string `json:"value,omitempty"` }
func (MessagePropertyList) String ¶
func (o MessagePropertyList) String() string
type MetadataDeleteReq ¶
type MetadataDeleteReq struct {
TaskIds []string `json:"taskIds"`
}
func (MetadataDeleteReq) String ¶
func (o MetadataDeleteReq) String() string
type MetadataTask ¶
type MetadataTask struct { Id *string `json:"id,omitempty"` Name *string `json:"name,omitempty"` StartDate *string `json:"start_date,omitempty"` Status *string `json:"status,omitempty"` Type *string `json:"type,omitempty"` }
func (MetadataTask) String ¶
func (o MetadataTask) String() string
type Queue ¶
type ResendReq ¶
type ResetConsumeOffsetReq ¶
type ResetConsumeOffsetReq struct { Topic *string `json:"topic,omitempty"` Timestamp float32 `json:"timestamp,omitempty"` }
func (ResetConsumeOffsetReq) String ¶
func (o ResetConsumeOffsetReq) String() string
type ResetConsumeOffsetRequest ¶
type ResetConsumeOffsetRequest struct { Engine ResetConsumeOffsetRequestEngine `json:"engine"` InstanceId string `json:"instance_id"` GroupId string `json:"group_id"` Body *ResetConsumeOffsetReq `json:"body,omitempty"` }
func (ResetConsumeOffsetRequest) String ¶
func (o ResetConsumeOffsetRequest) String() string
type ResetConsumeOffsetRequestEngine ¶
type ResetConsumeOffsetRequestEngine struct {
// contains filtered or unexported fields
}
func (ResetConsumeOffsetRequestEngine) MarshalJSON ¶
func (c ResetConsumeOffsetRequestEngine) MarshalJSON() ([]byte, error)
func (*ResetConsumeOffsetRequestEngine) UnmarshalJSON ¶
func (c *ResetConsumeOffsetRequestEngine) UnmarshalJSON(b []byte) error
func (ResetConsumeOffsetRequestEngine) Value ¶
func (c ResetConsumeOffsetRequestEngine) Value() string
type ResetConsumeOffsetRequestEngineEnum ¶
type ResetConsumeOffsetRequestEngineEnum struct {
RELIABILITY ResetConsumeOffsetRequestEngine
}
func GetResetConsumeOffsetRequestEngineEnum ¶
func GetResetConsumeOffsetRequestEngineEnum() ResetConsumeOffsetRequestEngineEnum
type ResetConsumeOffsetRespQueues ¶
type ResetConsumeOffsetRespQueues struct { BrokerName *string `json:"broker_name,omitempty"` QueueId *int32 `json:"queue_id,omitempty"` TimestampOffset *int64 `json:"timestamp_offset,omitempty"` }
func (ResetConsumeOffsetRespQueues) String ¶
func (o ResetConsumeOffsetRespQueues) String() string
type ResetConsumeOffsetResponse ¶
type ResetConsumeOffsetResponse struct { Queues *[]ResetConsumeOffsetRespQueues `json:"queues,omitempty"` HttpStatusCode int `json:"-"` }
func (ResetConsumeOffsetResponse) String ¶
func (o ResetConsumeOffsetResponse) String() string
type SendDlqMessageRequest ¶
type SendDlqMessageRequest struct { Engine SendDlqMessageRequestEngine `json:"engine"` InstanceId string `json:"instance_id"` Body *DeadletterResendReq `json:"body,omitempty"` }
func (SendDlqMessageRequest) String ¶
func (o SendDlqMessageRequest) String() string
type SendDlqMessageRequestEngine ¶
type SendDlqMessageRequestEngine struct {
// contains filtered or unexported fields
}
func (SendDlqMessageRequestEngine) MarshalJSON ¶
func (c SendDlqMessageRequestEngine) MarshalJSON() ([]byte, error)
func (*SendDlqMessageRequestEngine) UnmarshalJSON ¶
func (c *SendDlqMessageRequestEngine) UnmarshalJSON(b []byte) error
func (SendDlqMessageRequestEngine) Value ¶
func (c SendDlqMessageRequestEngine) Value() string
type SendDlqMessageRequestEngineEnum ¶
type SendDlqMessageRequestEngineEnum struct {
RELIABILITY SendDlqMessageRequestEngine
}
func GetSendDlqMessageRequestEngineEnum ¶
func GetSendDlqMessageRequestEngineEnum() SendDlqMessageRequestEngineEnum
type SendDlqMessageResponse ¶
type SendDlqMessageResponse struct { ResendResults *[]DeadletterResendRespResendResults `json:"resend_results,omitempty"` HttpStatusCode int `json:"-"` }
func (SendDlqMessageResponse) String ¶
func (o SendDlqMessageResponse) String() string
type ShowConsumerConnectionsRequest ¶
type ShowConsumerConnectionsRequest struct { InstanceId string `json:"instance_id"` Group string `json:"group"` Limit *int32 `json:"limit,omitempty"` Offset *int32 `json:"offset,omitempty"` IsDetail *bool `json:"is_detail,omitempty"` }
func (ShowConsumerConnectionsRequest) String ¶
func (o ShowConsumerConnectionsRequest) String() string
type ShowConsumerConnectionsResponse ¶
type ShowConsumerConnectionsResponse struct { GroupName *string `json:"group_name,omitempty"` Online *bool `json:"online,omitempty"` SubscriptionConsistency *bool `json:"subscription_consistency,omitempty"` Total *int32 `json:"total,omitempty"` NextOffset *int32 `json:"next_offset,omitempty"` PreviousOffset *int32 `json:"previous_offset,omitempty"` Clients *[]ClientData `json:"clients,omitempty"` HttpStatusCode int `json:"-"` }
func (ShowConsumerConnectionsResponse) String ¶
func (o ShowConsumerConnectionsResponse) String() string
type ShowConsumerListOrDetailsRequest ¶
type ShowConsumerListOrDetailsRequest struct { InstanceId string `json:"instance_id"` Group string `json:"group"` Topic *string `json:"topic,omitempty"` Limit *int32 `json:"limit,omitempty"` Offset *int32 `json:"offset,omitempty"` }
func (ShowConsumerListOrDetailsRequest) String ¶
func (o ShowConsumerListOrDetailsRequest) String() string
type ShowConsumerListOrDetailsResponse ¶
type ShowConsumerListOrDetailsResponse struct { Topics *[]string `json:"topics,omitempty"` Total *int32 `json:"total,omitempty"` Lag *int64 `json:"lag,omitempty"` MaxOffset *int64 `json:"max_offset,omitempty"` ConsumerOffset *int64 `json:"consumer_offset,omitempty"` Brokers *[]Brokers `json:"brokers,omitempty"` HttpStatusCode int `json:"-"` }
func (ShowConsumerListOrDetailsResponse) String ¶
func (o ShowConsumerListOrDetailsResponse) String() string
type ShowGroupRequest ¶
func (ShowGroupRequest) String ¶
func (o ShowGroupRequest) String() string
type ShowGroupResponse ¶
type ShowGroupResponse struct { Enabled *bool `json:"enabled,omitempty"` Broadcast *bool `json:"broadcast,omitempty"` Brokers *[]string `json:"brokers,omitempty"` Name *string `json:"name,omitempty"` GroupDesc *string `json:"group_desc,omitempty"` RetryMaxTime float32 `json:"retry_max_time,omitempty"` AppId *string `json:"app_id,omitempty"` AppName *string `json:"app_name,omitempty"` Permissions *[]string `json:"permissions,omitempty"` HttpStatusCode int `json:"-"` }
func (ShowGroupResponse) String ¶
func (o ShowGroupResponse) String() string
type ShowInstanceRequest ¶
type ShowInstanceRequest struct {
InstanceId string `json:"instance_id"`
}
func (ShowInstanceRequest) String ¶
func (o ShowInstanceRequest) String() string
type ShowInstanceResp ¶
type ShowInstanceResp struct { Name *string `json:"name,omitempty"` Engine *string `json:"engine,omitempty"` Status *string `json:"status,omitempty"` Description *string `json:"description,omitempty"` Type *ShowInstanceRespType `json:"type,omitempty"` Specification *string `json:"specification,omitempty"` EngineVersion *string `json:"engine_version,omitempty"` InstanceId *string `json:"instance_id,omitempty"` ChargingMode *int32 `json:"charging_mode,omitempty"` VpcId *string `json:"vpc_id,omitempty"` VpcName *string `json:"vpc_name,omitempty"` CreatedAt *string `json:"created_at,omitempty"` ProductId *string `json:"product_id,omitempty"` SecurityGroupId *string `json:"security_group_id,omitempty"` SecurityGroupName *string `json:"security_group_name,omitempty"` SubnetId *string `json:"subnet_id,omitempty"` SubnetName *string `json:"subnet_name,omitempty"` SubnetCidr *string `json:"subnet_cidr,omitempty"` AvailableZones *[]string `json:"available_zones,omitempty"` UserId *string `json:"user_id,omitempty"` UserName *string `json:"user_name,omitempty"` MaintainBegin *string `json:"maintain_begin,omitempty"` MaintainEnd *string `json:"maintain_end,omitempty"` EnableLogCollection *bool `json:"enable_log_collection,omitempty"` StorageSpace *int32 `json:"storage_space,omitempty"` UsedStorageSpace *int32 `json:"used_storage_space,omitempty"` EnablePublicip *bool `json:"enable_publicip,omitempty"` PublicipId *string `json:"publicip_id,omitempty"` PublicipAddress *string `json:"publicip_address,omitempty"` SslEnable *bool `json:"ssl_enable,omitempty"` CrossVpcInfo *string `json:"cross_vpc_info,omitempty"` StorageResourceId *string `json:"storage_resource_id,omitempty"` StorageSpecCode *string `json:"storage_spec_code,omitempty"` ServiceType *string `json:"service_type,omitempty"` StorageType *string `json:"storage_type,omitempty"` ExtendTimes *int64 `json:"extend_times,omitempty"` Ipv6Enable *bool `json:"ipv6_enable,omitempty"` SupportFeatures *string `json:"support_features,omitempty"` DiskEncrypted *bool `json:"disk_encrypted,omitempty"` CesVersion *string `json:"ces_version,omitempty"` NodeNum *int32 `json:"node_num,omitempty"` NewSpecBillingEnable *bool `json:"new_spec_billing_enable,omitempty"` EnableAcl *bool `json:"enable_acl,omitempty"` BrokerNum *int32 `json:"broker_num,omitempty"` NamesrvAddress *string `json:"namesrv_address,omitempty"` BrokerAddress *string `json:"broker_address,omitempty"` PublicNamesrvAddress *string `json:"public_namesrv_address,omitempty"` PublicBrokerAddress *string `json:"public_broker_address,omitempty"` GrpcAddress *string `json:"grpc_address,omitempty"` PublicGrpcAddress *string `json:"public_grpc_address,omitempty"` Tags *[]TagEntity `json:"tags,omitempty"` TotalStorageSpace *int32 `json:"total_storage_space,omitempty"` ResourceSpecCode *string `json:"resource_spec_code,omitempty"` }
func (ShowInstanceResp) String ¶
func (o ShowInstanceResp) String() string
type ShowInstanceRespType ¶
type ShowInstanceRespType struct {
// contains filtered or unexported fields
}
func (ShowInstanceRespType) MarshalJSON ¶
func (c ShowInstanceRespType) MarshalJSON() ([]byte, error)
func (*ShowInstanceRespType) UnmarshalJSON ¶
func (c *ShowInstanceRespType) UnmarshalJSON(b []byte) error
func (ShowInstanceRespType) Value ¶
func (c ShowInstanceRespType) Value() string
type ShowInstanceRespTypeEnum ¶
type ShowInstanceRespTypeEnum struct { SINGLE ShowInstanceRespType CLUSTER ShowInstanceRespType }
func GetShowInstanceRespTypeEnum ¶
func GetShowInstanceRespTypeEnum() ShowInstanceRespTypeEnum
type ShowInstanceResponse ¶
type ShowInstanceResponse struct { Name *string `json:"name,omitempty"` Engine *string `json:"engine,omitempty"` Status *string `json:"status,omitempty"` Description *string `json:"description,omitempty"` Type *ShowInstanceResponseType `json:"type,omitempty"` Specification *string `json:"specification,omitempty"` EngineVersion *string `json:"engine_version,omitempty"` InstanceId *string `json:"instance_id,omitempty"` ChargingMode *int32 `json:"charging_mode,omitempty"` VpcId *string `json:"vpc_id,omitempty"` VpcName *string `json:"vpc_name,omitempty"` CreatedAt *string `json:"created_at,omitempty"` ProductId *string `json:"product_id,omitempty"` SecurityGroupId *string `json:"security_group_id,omitempty"` SecurityGroupName *string `json:"security_group_name,omitempty"` SubnetId *string `json:"subnet_id,omitempty"` SubnetName *string `json:"subnet_name,omitempty"` SubnetCidr *string `json:"subnet_cidr,omitempty"` AvailableZones *[]string `json:"available_zones,omitempty"` UserId *string `json:"user_id,omitempty"` UserName *string `json:"user_name,omitempty"` MaintainBegin *string `json:"maintain_begin,omitempty"` MaintainEnd *string `json:"maintain_end,omitempty"` EnableLogCollection *bool `json:"enable_log_collection,omitempty"` StorageSpace *int32 `json:"storage_space,omitempty"` UsedStorageSpace *int32 `json:"used_storage_space,omitempty"` EnablePublicip *bool `json:"enable_publicip,omitempty"` PublicipId *string `json:"publicip_id,omitempty"` PublicipAddress *string `json:"publicip_address,omitempty"` SslEnable *bool `json:"ssl_enable,omitempty"` CrossVpcInfo *string `json:"cross_vpc_info,omitempty"` StorageResourceId *string `json:"storage_resource_id,omitempty"` StorageSpecCode *string `json:"storage_spec_code,omitempty"` ServiceType *string `json:"service_type,omitempty"` StorageType *string `json:"storage_type,omitempty"` ExtendTimes *int64 `json:"extend_times,omitempty"` Ipv6Enable *bool `json:"ipv6_enable,omitempty"` SupportFeatures *string `json:"support_features,omitempty"` DiskEncrypted *bool `json:"disk_encrypted,omitempty"` CesVersion *string `json:"ces_version,omitempty"` NodeNum *int32 `json:"node_num,omitempty"` NewSpecBillingEnable *bool `json:"new_spec_billing_enable,omitempty"` EnableAcl *bool `json:"enable_acl,omitempty"` BrokerNum *int32 `json:"broker_num,omitempty"` NamesrvAddress *string `json:"namesrv_address,omitempty"` BrokerAddress *string `json:"broker_address,omitempty"` PublicNamesrvAddress *string `json:"public_namesrv_address,omitempty"` PublicBrokerAddress *string `json:"public_broker_address,omitempty"` GrpcAddress *string `json:"grpc_address,omitempty"` PublicGrpcAddress *string `json:"public_grpc_address,omitempty"` Tags *[]TagEntity `json:"tags,omitempty"` TotalStorageSpace *int32 `json:"total_storage_space,omitempty"` ResourceSpecCode *string `json:"resource_spec_code,omitempty"` HttpStatusCode int `json:"-"` }
func (ShowInstanceResponse) String ¶
func (o ShowInstanceResponse) String() string
type ShowInstanceResponseType ¶
type ShowInstanceResponseType struct {
// contains filtered or unexported fields
}
func (ShowInstanceResponseType) MarshalJSON ¶
func (c ShowInstanceResponseType) MarshalJSON() ([]byte, error)
func (*ShowInstanceResponseType) UnmarshalJSON ¶
func (c *ShowInstanceResponseType) UnmarshalJSON(b []byte) error
func (ShowInstanceResponseType) Value ¶
func (c ShowInstanceResponseType) Value() string
type ShowInstanceResponseTypeEnum ¶
type ShowInstanceResponseTypeEnum struct { SINGLE ShowInstanceResponseType CLUSTER ShowInstanceResponseType }
func GetShowInstanceResponseTypeEnum ¶
func GetShowInstanceResponseTypeEnum() ShowInstanceResponseTypeEnum
type ShowOneTopicRequest ¶
type ShowOneTopicRequest struct { InstanceId string `json:"instance_id"` Topic string `json:"topic"` }
func (ShowOneTopicRequest) String ¶
func (o ShowOneTopicRequest) String() string
type ShowOneTopicResponse ¶
type ShowOneTopicResponse struct { Name *string `json:"name,omitempty"` TotalReadQueueNum float32 `json:"total_read_queue_num,omitempty"` TotalWriteQueueNum float32 `json:"total_write_queue_num,omitempty"` Permission *ShowOneTopicResponsePermission `json:"permission,omitempty"` Brokers *[]TopicBrokers `json:"brokers,omitempty"` MessageType *ShowOneTopicResponseMessageType `json:"message_type,omitempty"` HttpStatusCode int `json:"-"` }
func (ShowOneTopicResponse) String ¶
func (o ShowOneTopicResponse) String() string
type ShowOneTopicResponseMessageType ¶
type ShowOneTopicResponseMessageType struct {
// contains filtered or unexported fields
}
func (ShowOneTopicResponseMessageType) MarshalJSON ¶
func (c ShowOneTopicResponseMessageType) MarshalJSON() ([]byte, error)
func (*ShowOneTopicResponseMessageType) UnmarshalJSON ¶
func (c *ShowOneTopicResponseMessageType) UnmarshalJSON(b []byte) error
func (ShowOneTopicResponseMessageType) Value ¶
func (c ShowOneTopicResponseMessageType) Value() string
type ShowOneTopicResponseMessageTypeEnum ¶
type ShowOneTopicResponseMessageTypeEnum struct { NORMAL ShowOneTopicResponseMessageType FIFO ShowOneTopicResponseMessageType DELAY ShowOneTopicResponseMessageType TRANSACTION ShowOneTopicResponseMessageType }
func GetShowOneTopicResponseMessageTypeEnum ¶
func GetShowOneTopicResponseMessageTypeEnum() ShowOneTopicResponseMessageTypeEnum
type ShowOneTopicResponsePermission ¶
type ShowOneTopicResponsePermission struct {
// contains filtered or unexported fields
}
func (ShowOneTopicResponsePermission) MarshalJSON ¶
func (c ShowOneTopicResponsePermission) MarshalJSON() ([]byte, error)
func (*ShowOneTopicResponsePermission) UnmarshalJSON ¶
func (c *ShowOneTopicResponsePermission) UnmarshalJSON(b []byte) error
func (ShowOneTopicResponsePermission) Value ¶
func (c ShowOneTopicResponsePermission) Value() string
type ShowOneTopicResponsePermissionEnum ¶
type ShowOneTopicResponsePermissionEnum struct { SUB ShowOneTopicResponsePermission PUB ShowOneTopicResponsePermission ALL ShowOneTopicResponsePermission }
func GetShowOneTopicResponsePermissionEnum ¶
func GetShowOneTopicResponsePermissionEnum() ShowOneTopicResponsePermissionEnum
type ShowRocketmqProjectTagsRequest ¶
type ShowRocketmqProjectTagsRequest struct { }
func (ShowRocketmqProjectTagsRequest) String ¶
func (o ShowRocketmqProjectTagsRequest) String() string
type ShowRocketmqProjectTagsResponse ¶
type ShowRocketmqProjectTagsResponse struct { Tags *[]TagMultyValueEntity `json:"tags,omitempty"` HttpStatusCode int `json:"-"` }
func (ShowRocketmqProjectTagsResponse) String ¶
func (o ShowRocketmqProjectTagsResponse) String() string
type ShowRocketmqTagsRequest ¶
type ShowRocketmqTagsRequest struct {
InstanceId string `json:"instance_id"`
}
func (ShowRocketmqTagsRequest) String ¶
func (o ShowRocketmqTagsRequest) String() string
type ShowRocketmqTagsResponse ¶
type ShowRocketmqTagsResponse struct { Tags *[]TagEntity `json:"tags,omitempty"` HttpStatusCode int `json:"-"` }
func (ShowRocketmqTagsResponse) String ¶
func (o ShowRocketmqTagsResponse) String() string
type ShowTopicStatusRequest ¶
type ShowTopicStatusRequest struct { InstanceId string `json:"instance_id"` Topic string `json:"topic"` }
func (ShowTopicStatusRequest) String ¶
func (o ShowTopicStatusRequest) String() string
type ShowTopicStatusRespBrokers ¶
type ShowTopicStatusRespBrokers struct { Queues *[]ShowTopicStatusRespQueues `json:"queues,omitempty"` BrokerName *string `json:"broker_name,omitempty"` }
func (ShowTopicStatusRespBrokers) String ¶
func (o ShowTopicStatusRespBrokers) String() string
type ShowTopicStatusRespQueues ¶
type ShowTopicStatusRespQueues struct { Id *int32 `json:"id,omitempty"` MinOffset *int32 `json:"min_offset,omitempty"` MaxOffset *int32 `json:"max_offset,omitempty"` LastMessageTime *int64 `json:"last_message_time,omitempty"` }
func (ShowTopicStatusRespQueues) String ¶
func (o ShowTopicStatusRespQueues) String() string
type ShowTopicStatusResponse ¶
type ShowTopicStatusResponse struct { MaxOffset *int32 `json:"max_offset,omitempty"` MinOffset *int32 `json:"min_offset,omitempty"` Brokers *[]ShowTopicStatusRespBrokers `json:"brokers,omitempty"` HttpStatusCode int `json:"-"` }
func (ShowTopicStatusResponse) String ¶
func (o ShowTopicStatusResponse) String() string
type ShowUserRequest ¶
type ShowUserRequest struct { InstanceId string `json:"instance_id"` UserName string `json:"user_name"` }
func (ShowUserRequest) String ¶
func (o ShowUserRequest) String() string
type ShowUserResponse ¶
type ShowUserResponse struct { AccessKey *string `json:"access_key,omitempty"` SecretKey *string `json:"secret_key,omitempty"` WhiteRemoteAddress *string `json:"white_remote_address,omitempty"` Admin *bool `json:"admin,omitempty"` DefaultTopicPerm *ShowUserResponseDefaultTopicPerm `json:"default_topic_perm,omitempty"` DefaultGroupPerm *ShowUserResponseDefaultGroupPerm `json:"default_group_perm,omitempty"` TopicPerms *[]UserTopicPerms `json:"topic_perms,omitempty"` GroupPerms *[]UserGroupPerms `json:"group_perms,omitempty"` HttpStatusCode int `json:"-"` }
func (ShowUserResponse) String ¶
func (o ShowUserResponse) String() string
type ShowUserResponseDefaultGroupPerm ¶
type ShowUserResponseDefaultGroupPerm struct {
// contains filtered or unexported fields
}
func (ShowUserResponseDefaultGroupPerm) MarshalJSON ¶
func (c ShowUserResponseDefaultGroupPerm) MarshalJSON() ([]byte, error)
func (*ShowUserResponseDefaultGroupPerm) UnmarshalJSON ¶
func (c *ShowUserResponseDefaultGroupPerm) UnmarshalJSON(b []byte) error
func (ShowUserResponseDefaultGroupPerm) Value ¶
func (c ShowUserResponseDefaultGroupPerm) Value() string
type ShowUserResponseDefaultGroupPermEnum ¶
type ShowUserResponseDefaultGroupPermEnum struct { SUB ShowUserResponseDefaultGroupPerm DENY ShowUserResponseDefaultGroupPerm }
func GetShowUserResponseDefaultGroupPermEnum ¶
func GetShowUserResponseDefaultGroupPermEnum() ShowUserResponseDefaultGroupPermEnum
type ShowUserResponseDefaultTopicPerm ¶
type ShowUserResponseDefaultTopicPerm struct {
// contains filtered or unexported fields
}
func (ShowUserResponseDefaultTopicPerm) MarshalJSON ¶
func (c ShowUserResponseDefaultTopicPerm) MarshalJSON() ([]byte, error)
func (*ShowUserResponseDefaultTopicPerm) UnmarshalJSON ¶
func (c *ShowUserResponseDefaultTopicPerm) UnmarshalJSON(b []byte) error
func (ShowUserResponseDefaultTopicPerm) Value ¶
func (c ShowUserResponseDefaultTopicPerm) Value() string
type ShowUserResponseDefaultTopicPermEnum ¶
type ShowUserResponseDefaultTopicPermEnum struct { PUB ShowUserResponseDefaultTopicPerm SUB ShowUserResponseDefaultTopicPerm PUB_SUB ShowUserResponseDefaultTopicPerm DENY ShowUserResponseDefaultTopicPerm }
func GetShowUserResponseDefaultTopicPermEnum ¶
func GetShowUserResponseDefaultTopicPermEnum() ShowUserResponseDefaultTopicPermEnum
type Subscription ¶
type Subscription struct { Topic *string `json:"topic,omitempty"` Type *string `json:"type,omitempty"` Expression *string `json:"expression,omitempty"` }
func (Subscription) String ¶
func (o Subscription) String() string
type TagMultyValueEntity ¶
type TagMultyValueEntity struct { Key *string `json:"key,omitempty"` Values *[]string `json:"values,omitempty"` }
func (TagMultyValueEntity) String ¶
func (o TagMultyValueEntity) String() string
type Topic ¶
type Topic struct { Name *string `json:"name,omitempty"` TotalReadQueueNum float32 `json:"total_read_queue_num,omitempty"` TotalWriteQueueNum float32 `json:"total_write_queue_num,omitempty"` Permission *TopicPermission `json:"permission,omitempty"` Brokers *[]TopicBrokers `json:"brokers,omitempty"` MessageType *TopicMessageType `json:"message_type,omitempty"` }
type TopicBrokers ¶
type TopicBrokers struct { BrokerName *string `json:"broker_name,omitempty"` ReadQueueNum float32 `json:"read_queue_num,omitempty"` WriteQueueNum float32 `json:"write_queue_num,omitempty"` }
func (TopicBrokers) String ¶
func (o TopicBrokers) String() string
type TopicMessageType ¶
type TopicMessageType struct {
// contains filtered or unexported fields
}
func (TopicMessageType) MarshalJSON ¶
func (c TopicMessageType) MarshalJSON() ([]byte, error)
func (*TopicMessageType) UnmarshalJSON ¶
func (c *TopicMessageType) UnmarshalJSON(b []byte) error
func (TopicMessageType) Value ¶
func (c TopicMessageType) Value() string
type TopicMessageTypeEnum ¶
type TopicMessageTypeEnum struct { NORMAL TopicMessageType FIFO TopicMessageType DELAY TopicMessageType TRANSACTION TopicMessageType }
func GetTopicMessageTypeEnum ¶
func GetTopicMessageTypeEnum() TopicMessageTypeEnum
type TopicPermission ¶
type TopicPermission struct {
// contains filtered or unexported fields
}
func (TopicPermission) MarshalJSON ¶
func (c TopicPermission) MarshalJSON() ([]byte, error)
func (*TopicPermission) UnmarshalJSON ¶
func (c *TopicPermission) UnmarshalJSON(b []byte) error
func (TopicPermission) Value ¶
func (c TopicPermission) Value() string
type TopicPermissionEnum ¶
type TopicPermissionEnum struct { SUB TopicPermission PUB TopicPermission ALL TopicPermission }
func GetTopicPermissionEnum ¶
func GetTopicPermissionEnum() TopicPermissionEnum
type UpdateConsumerGroup ¶
type UpdateConsumerGroup struct { Enabled bool `json:"enabled"` Broadcast bool `json:"broadcast"` Brokers *[]string `json:"brokers,omitempty"` Name *string `json:"name,omitempty"` RetryMaxTime float32 `json:"retry_max_time"` FromBeginning *bool `json:"from_beginning,omitempty"` }
func (UpdateConsumerGroup) String ¶
func (o UpdateConsumerGroup) String() string
type UpdateConsumerGroupRequest ¶
type UpdateConsumerGroupRequest struct { InstanceId string `json:"instance_id"` Group string `json:"group"` Body *UpdateConsumerGroup `json:"body,omitempty"` }
func (UpdateConsumerGroupRequest) String ¶
func (o UpdateConsumerGroupRequest) String() string
type UpdateConsumerGroupResponse ¶
type UpdateConsumerGroupResponse struct {
HttpStatusCode int `json:"-"`
}
func (UpdateConsumerGroupResponse) String ¶
func (o UpdateConsumerGroupResponse) String() string
type UpdateInstanceReq ¶
type UpdateInstanceReq struct { Name *string `json:"name,omitempty"` Description *string `json:"description,omitempty"` SecurityGroupId *string `json:"security_group_id,omitempty"` EnableAcl *bool `json:"enable_acl,omitempty"` EnablePublicip *bool `json:"enable_publicip,omitempty"` PublicipId *string `json:"publicip_id,omitempty"` }
func (UpdateInstanceReq) String ¶
func (o UpdateInstanceReq) String() string
type UpdateInstanceRequest ¶
type UpdateInstanceRequest struct { InstanceId string `json:"instance_id"` Body *UpdateInstanceReq `json:"body,omitempty"` }
func (UpdateInstanceRequest) String ¶
func (o UpdateInstanceRequest) String() string
type UpdateInstanceResponse ¶
type UpdateInstanceResponse struct {
HttpStatusCode int `json:"-"`
}
func (UpdateInstanceResponse) String ¶
func (o UpdateInstanceResponse) String() string
type UpdateTopicReq ¶
type UpdateTopicReq struct { ReadQueueNum float32 `json:"read_queue_num,omitempty"` WriteQueueNum float32 `json:"write_queue_num,omitempty"` Permission *UpdateTopicReqPermission `json:"permission,omitempty"` }
func (UpdateTopicReq) String ¶
func (o UpdateTopicReq) String() string
type UpdateTopicReqPermission ¶
type UpdateTopicReqPermission struct {
// contains filtered or unexported fields
}
func (UpdateTopicReqPermission) MarshalJSON ¶
func (c UpdateTopicReqPermission) MarshalJSON() ([]byte, error)
func (*UpdateTopicReqPermission) UnmarshalJSON ¶
func (c *UpdateTopicReqPermission) UnmarshalJSON(b []byte) error
func (UpdateTopicReqPermission) Value ¶
func (c UpdateTopicReqPermission) Value() string
type UpdateTopicReqPermissionEnum ¶
type UpdateTopicReqPermissionEnum struct { SUB UpdateTopicReqPermission PUB UpdateTopicReqPermission ALL UpdateTopicReqPermission }
func GetUpdateTopicReqPermissionEnum ¶
func GetUpdateTopicReqPermissionEnum() UpdateTopicReqPermissionEnum
type UpdateTopicRequest ¶
type UpdateTopicRequest struct { InstanceId string `json:"instance_id"` Topic string `json:"topic"` Body *UpdateTopicReq `json:"body,omitempty"` }
func (UpdateTopicRequest) String ¶
func (o UpdateTopicRequest) String() string
type UpdateTopicResponse ¶
type UpdateTopicResponse struct {
HttpStatusCode int `json:"-"`
}
func (UpdateTopicResponse) String ¶
func (o UpdateTopicResponse) String() string
type UpdateUserRequest ¶
type UpdateUserRequest struct { InstanceId string `json:"instance_id"` UserName string `json:"user_name"` Body *User `json:"body,omitempty"` }
func (UpdateUserRequest) String ¶
func (o UpdateUserRequest) String() string
type UpdateUserResponse ¶
type UpdateUserResponse struct { AccessKey *string `json:"access_key,omitempty"` SecretKey *string `json:"secret_key,omitempty"` WhiteRemoteAddress *string `json:"white_remote_address,omitempty"` Admin *bool `json:"admin,omitempty"` DefaultTopicPerm *UpdateUserResponseDefaultTopicPerm `json:"default_topic_perm,omitempty"` DefaultGroupPerm *UpdateUserResponseDefaultGroupPerm `json:"default_group_perm,omitempty"` TopicPerms *[]UserTopicPerms `json:"topic_perms,omitempty"` GroupPerms *[]UserGroupPerms `json:"group_perms,omitempty"` HttpStatusCode int `json:"-"` }
func (UpdateUserResponse) String ¶
func (o UpdateUserResponse) String() string
type UpdateUserResponseDefaultGroupPerm ¶
type UpdateUserResponseDefaultGroupPerm struct {
// contains filtered or unexported fields
}
func (UpdateUserResponseDefaultGroupPerm) MarshalJSON ¶
func (c UpdateUserResponseDefaultGroupPerm) MarshalJSON() ([]byte, error)
func (*UpdateUserResponseDefaultGroupPerm) UnmarshalJSON ¶
func (c *UpdateUserResponseDefaultGroupPerm) UnmarshalJSON(b []byte) error
func (UpdateUserResponseDefaultGroupPerm) Value ¶
func (c UpdateUserResponseDefaultGroupPerm) Value() string
type UpdateUserResponseDefaultGroupPermEnum ¶
type UpdateUserResponseDefaultGroupPermEnum struct { SUB UpdateUserResponseDefaultGroupPerm DENY UpdateUserResponseDefaultGroupPerm }
func GetUpdateUserResponseDefaultGroupPermEnum ¶
func GetUpdateUserResponseDefaultGroupPermEnum() UpdateUserResponseDefaultGroupPermEnum
type UpdateUserResponseDefaultTopicPerm ¶
type UpdateUserResponseDefaultTopicPerm struct {
// contains filtered or unexported fields
}
func (UpdateUserResponseDefaultTopicPerm) MarshalJSON ¶
func (c UpdateUserResponseDefaultTopicPerm) MarshalJSON() ([]byte, error)
func (*UpdateUserResponseDefaultTopicPerm) UnmarshalJSON ¶
func (c *UpdateUserResponseDefaultTopicPerm) UnmarshalJSON(b []byte) error
func (UpdateUserResponseDefaultTopicPerm) Value ¶
func (c UpdateUserResponseDefaultTopicPerm) Value() string
type UpdateUserResponseDefaultTopicPermEnum ¶
type UpdateUserResponseDefaultTopicPermEnum struct { PUB UpdateUserResponseDefaultTopicPerm SUB UpdateUserResponseDefaultTopicPerm PUB_SUB UpdateUserResponseDefaultTopicPerm DENY UpdateUserResponseDefaultTopicPerm }
func GetUpdateUserResponseDefaultTopicPermEnum ¶
func GetUpdateUserResponseDefaultTopicPermEnum() UpdateUserResponseDefaultTopicPermEnum
type User ¶
type User struct { AccessKey *string `json:"access_key,omitempty"` SecretKey *string `json:"secret_key,omitempty"` WhiteRemoteAddress *string `json:"white_remote_address,omitempty"` Admin *bool `json:"admin,omitempty"` DefaultTopicPerm *UserDefaultTopicPerm `json:"default_topic_perm,omitempty"` DefaultGroupPerm *UserDefaultGroupPerm `json:"default_group_perm,omitempty"` TopicPerms *[]UserTopicPerms `json:"topic_perms,omitempty"` GroupPerms *[]UserGroupPerms `json:"group_perms,omitempty"` }
type UserDefaultGroupPerm ¶
type UserDefaultGroupPerm struct {
// contains filtered or unexported fields
}
func (UserDefaultGroupPerm) MarshalJSON ¶
func (c UserDefaultGroupPerm) MarshalJSON() ([]byte, error)
func (*UserDefaultGroupPerm) UnmarshalJSON ¶
func (c *UserDefaultGroupPerm) UnmarshalJSON(b []byte) error
func (UserDefaultGroupPerm) Value ¶
func (c UserDefaultGroupPerm) Value() string
type UserDefaultGroupPermEnum ¶
type UserDefaultGroupPermEnum struct { SUB UserDefaultGroupPerm DENY UserDefaultGroupPerm }
func GetUserDefaultGroupPermEnum ¶
func GetUserDefaultGroupPermEnum() UserDefaultGroupPermEnum
type UserDefaultTopicPerm ¶
type UserDefaultTopicPerm struct {
// contains filtered or unexported fields
}
func (UserDefaultTopicPerm) MarshalJSON ¶
func (c UserDefaultTopicPerm) MarshalJSON() ([]byte, error)
func (*UserDefaultTopicPerm) UnmarshalJSON ¶
func (c *UserDefaultTopicPerm) UnmarshalJSON(b []byte) error
func (UserDefaultTopicPerm) Value ¶
func (c UserDefaultTopicPerm) Value() string
type UserDefaultTopicPermEnum ¶
type UserDefaultTopicPermEnum struct { PUB UserDefaultTopicPerm SUB UserDefaultTopicPerm PUB_SUB UserDefaultTopicPerm DENY UserDefaultTopicPerm }
func GetUserDefaultTopicPermEnum ¶
func GetUserDefaultTopicPermEnum() UserDefaultTopicPermEnum
type UserGroupPerms ¶
type UserGroupPerms struct { Name *string `json:"name,omitempty"` Perm *UserGroupPermsPerm `json:"perm,omitempty"` }
func (UserGroupPerms) String ¶
func (o UserGroupPerms) String() string
type UserGroupPermsPerm ¶
type UserGroupPermsPerm struct {
// contains filtered or unexported fields
}
func (UserGroupPermsPerm) MarshalJSON ¶
func (c UserGroupPermsPerm) MarshalJSON() ([]byte, error)
func (*UserGroupPermsPerm) UnmarshalJSON ¶
func (c *UserGroupPermsPerm) UnmarshalJSON(b []byte) error
func (UserGroupPermsPerm) Value ¶
func (c UserGroupPermsPerm) Value() string
type UserGroupPermsPermEnum ¶
type UserGroupPermsPermEnum struct { SUB UserGroupPermsPerm DENY UserGroupPermsPerm }
func GetUserGroupPermsPermEnum ¶
func GetUserGroupPermsPermEnum() UserGroupPermsPermEnum
type UserTopicPerms ¶
type UserTopicPerms struct { Name *string `json:"name,omitempty"` Perm *UserTopicPermsPerm `json:"perm,omitempty"` }
func (UserTopicPerms) String ¶
func (o UserTopicPerms) String() string
type UserTopicPermsPerm ¶
type UserTopicPermsPerm struct {
// contains filtered or unexported fields
}
func (UserTopicPermsPerm) MarshalJSON ¶
func (c UserTopicPermsPerm) MarshalJSON() ([]byte, error)
func (*UserTopicPermsPerm) UnmarshalJSON ¶
func (c *UserTopicPermsPerm) UnmarshalJSON(b []byte) error
func (UserTopicPermsPerm) Value ¶
func (c UserTopicPermsPerm) Value() string
type UserTopicPermsPermEnum ¶
type UserTopicPermsPermEnum struct { PUB UserTopicPermsPerm SUB UserTopicPermsPerm PUB_SUB UserTopicPermsPerm DENY UserTopicPermsPerm }
func GetUserTopicPermsPermEnum ¶
func GetUserTopicPermsPermEnum() UserTopicPermsPermEnum
type ValidateConsumedMessageRequest ¶
type ValidateConsumedMessageRequest struct { Engine ValidateConsumedMessageRequestEngine `json:"engine"` InstanceId string `json:"instance_id"` Body *ResendReq `json:"body,omitempty"` }
func (ValidateConsumedMessageRequest) String ¶
func (o ValidateConsumedMessageRequest) String() string
type ValidateConsumedMessageRequestEngine ¶
type ValidateConsumedMessageRequestEngine struct {
// contains filtered or unexported fields
}
func (ValidateConsumedMessageRequestEngine) MarshalJSON ¶
func (c ValidateConsumedMessageRequestEngine) MarshalJSON() ([]byte, error)
func (*ValidateConsumedMessageRequestEngine) UnmarshalJSON ¶
func (c *ValidateConsumedMessageRequestEngine) UnmarshalJSON(b []byte) error
func (ValidateConsumedMessageRequestEngine) Value ¶
func (c ValidateConsumedMessageRequestEngine) Value() string
type ValidateConsumedMessageRequestEngineEnum ¶
type ValidateConsumedMessageRequestEngineEnum struct {
RELIABILITY ValidateConsumedMessageRequestEngine
}
func GetValidateConsumedMessageRequestEngineEnum ¶
func GetValidateConsumedMessageRequestEngineEnum() ValidateConsumedMessageRequestEngineEnum
type ValidateConsumedMessageResponse ¶
type ValidateConsumedMessageResponse struct { ResendResults *[]DeadletterResendRespResendResults `json:"resend_results,omitempty"` HttpStatusCode int `json:"-"` }
func (ValidateConsumedMessageResponse) String ¶
func (o ValidateConsumedMessageResponse) String() string
Source Files ¶
- model_batch_create_or_delete_rocketmq_tag_request.go
- model_batch_create_or_delete_rocketmq_tag_response.go
- model_batch_create_or_delete_tag_req.go
- model_batch_delete_consumer_group_req.go
- model_batch_delete_consumer_group_resp.go
- model_batch_delete_instance_req.go
- model_batch_delete_instance_resp_results.go
- model_batch_delete_instances_request.go
- model_batch_delete_instances_response.go
- model_batch_delete_topic_req.go
- model_batch_delete_topic_resp.go
- model_batch_update_consumer_group_req.go
- model_batch_update_consumer_group_request.go
- model_batch_update_consumer_group_response.go
- model_brokers.go
- model_bss_param.go
- model_client_data.go
- model_consumer_detail_resp.go
- model_consumer_group.go
- model_consumer_list.go
- model_create_consumer_group_or_batch_delete_consumer_group_req.go
- model_create_consumer_group_or_batch_delete_consumer_group_request.go
- model_create_consumer_group_or_batch_delete_consumer_group_response.go
- model_create_group_resp.go
- model_create_instance_by_engine_req.go
- model_create_instance_by_engine_request.go
- model_create_instance_by_engine_response.go
- model_create_post_paid_instance_req.go
- model_create_post_paid_instance_request.go
- model_create_post_paid_instance_response.go
- model_create_rocket_mq_migration_task_request.go
- model_create_rocket_mq_migration_task_response.go
- model_create_topic_or_batch_delete_topic_req.go
- model_create_topic_or_batch_delete_topic_request.go
- model_create_topic_or_batch_delete_topic_response.go
- model_create_topic_req.go
- model_create_topic_resp.go
- model_create_user_request.go
- model_create_user_response.go
- model_deadletter_resend_req.go
- model_deadletter_resend_resp_resend_results.go
- model_delete_consumer_group_request.go
- model_delete_consumer_group_response.go
- model_delete_instance_request.go
- model_delete_instance_response.go
- model_delete_rocket_mq_migration_task_request.go
- model_delete_rocket_mq_migration_task_response.go
- model_delete_topic_request.go
- model_delete_topic_response.go
- model_delete_user_request.go
- model_delete_user_response.go
- model_export_dlq_message_req.go
- model_export_dlq_message_request.go
- model_export_dlq_message_response.go
- model_list_access_policy_resp_policies.go
- model_list_available_zones_request.go
- model_list_available_zones_resp_available_zones.go
- model_list_available_zones_response.go
- model_list_brokers_request.go
- model_list_brokers_resp_brokers.go
- model_list_brokers_response.go
- model_list_consume_group_access_policy_request.go
- model_list_consume_group_access_policy_response.go
- model_list_consumer_group_of_topic_request.go
- model_list_consumer_group_of_topic_response.go
- model_list_instance_consumer_groups_request.go
- model_list_instance_consumer_groups_response.go
- model_list_instances_request.go
- model_list_instances_response.go
- model_list_message_trace_request.go
- model_list_message_trace_resp_trace.go
- model_list_message_trace_response.go
- model_list_messages_request.go
- model_list_messages_response.go
- model_list_rocket_instance_topics_request.go
- model_list_rocket_instance_topics_response.go
- model_list_rocket_mq_migration_task_request.go
- model_list_rocket_mq_migration_task_response.go
- model_list_topic_access_policy_request.go
- model_list_topic_access_policy_response.go
- model_list_user_request.go
- model_list_user_response.go
- model_message.go
- model_message_property_list.go
- model_metadata_delete_req.go
- model_metadata_task.go
- model_queue.go
- model_resend_req.go
- model_reset_consume_offset_req.go
- model_reset_consume_offset_request.go
- model_reset_consume_offset_resp_queues.go
- model_reset_consume_offset_response.go
- model_send_dlq_message_request.go
- model_send_dlq_message_response.go
- model_show_consumer_connections_request.go
- model_show_consumer_connections_response.go
- model_show_consumer_list_or_details_request.go
- model_show_consumer_list_or_details_response.go
- model_show_group_request.go
- model_show_group_response.go
- model_show_instance_request.go
- model_show_instance_resp.go
- model_show_instance_response.go
- model_show_one_topic_request.go
- model_show_one_topic_response.go
- model_show_rocketmq_project_tags_request.go
- model_show_rocketmq_project_tags_response.go
- model_show_rocketmq_tags_request.go
- model_show_rocketmq_tags_response.go
- model_show_topic_status_request.go
- model_show_topic_status_resp_brokers.go
- model_show_topic_status_resp_queues.go
- model_show_topic_status_response.go
- model_show_user_request.go
- model_show_user_response.go
- model_subscription.go
- model_tag_entity.go
- model_tag_multy_value_entity.go
- model_topic.go
- model_topic_brokers.go
- model_update_consumer_group.go
- model_update_consumer_group_request.go
- model_update_consumer_group_response.go
- model_update_instance_req.go
- model_update_instance_request.go
- model_update_instance_response.go
- model_update_topic_req.go
- model_update_topic_request.go
- model_update_topic_response.go
- model_update_user_request.go
- model_update_user_response.go
- model_user.go
- model_user_group_perms.go
- model_user_topic_perms.go
- model_validate_consumed_message_request.go
- model_validate_consumed_message_response.go
Click to show internal directories.
Click to hide internal directories.