apis

package
v1.66.0 Latest Latest
Warning

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

 Go to latest Published: Jun 8, 2026 License: Apache-2.0 Imports: 2 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type CreateConsumerGroupRequest 

type CreateConsumerGroupRequest struct {
	core.JDCloudRequest

	/* 区域ID  */
	RegionId string `json:"regionId"`

	/* 实例id  */
	InstanceId string `json:"instanceId"`

	/* consumerGroup名称  */
	ConsumerGroup string `json:"consumerGroup"`

	/* 描述，长度不大于128 (Optional) */
	Description *string `json:"description"`

	/* 消费重试次数（默认16） (Optional) */
	RetryMaxTimes *int `json:"retryMaxTimes"`

	/* 是否开启死信（默认开启） (Optional) */
	EnableDlq *bool `json:"enableDlq"`
}

func NewCreateConsumerGroupRequest 

func NewCreateConsumerGroupRequest(
	regionId string,
	instanceId string,
	consumerGroup string,
) *CreateConsumerGroupRequest

* param regionId: 区域ID (Required) * param instanceId: 实例id (Required) * param consumerGroup: consumerGroup名称 (Required) * * @Deprecated, not compatible when mandatory parameters changed

func NewCreateConsumerGroupRequestWithAllParams 

func NewCreateConsumerGroupRequestWithAllParams(
	regionId string,
	instanceId string,
	consumerGroup string,
	description *string,
	retryMaxTimes *int,
	enableDlq *bool,
) *CreateConsumerGroupRequest

* param regionId: 区域ID (Required) * param instanceId: 实例id (Required) * param consumerGroup: consumerGroup名称 (Required) * param description: 描述，长度不大于128 (Optional) * param retryMaxTimes: 消费重试次数（默认16） (Optional) * param enableDlq: 是否开启死信（默认开启） (Optional)

func NewCreateConsumerGroupRequestWithoutParam 

func NewCreateConsumerGroupRequestWithoutParam() *CreateConsumerGroupRequest

This constructor has better compatible ability when API parameters changed

func (CreateConsumerGroupRequest) GetRegionId 

func (r CreateConsumerGroupRequest) GetRegionId() string

GetRegionId returns path parameter 'regionId' if exist, otherwise return empty string

func (*CreateConsumerGroupRequest) SetConsumerGroup 

func (r *CreateConsumerGroupRequest) SetConsumerGroup(consumerGroup string)

param consumerGroup: consumerGroup名称(Required)

func (*CreateConsumerGroupRequest) SetDescription 

func (r *CreateConsumerGroupRequest) SetDescription(description string)

param description: 描述，长度不大于128(Optional)

func (*CreateConsumerGroupRequest) SetEnableDlq 

func (r *CreateConsumerGroupRequest) SetEnableDlq(enableDlq bool)

param enableDlq: 是否开启死信（默认开启）(Optional)

func (*CreateConsumerGroupRequest) SetInstanceId 

func (r *CreateConsumerGroupRequest) SetInstanceId(instanceId string)

param instanceId: 实例id(Required)

func (*CreateConsumerGroupRequest) SetRegionId 

func (r *CreateConsumerGroupRequest) SetRegionId(regionId string)

param regionId: 区域ID(Required)

func (*CreateConsumerGroupRequest) SetRetryMaxTimes 

func (r *CreateConsumerGroupRequest) SetRetryMaxTimes(retryMaxTimes int)

param retryMaxTimes: 消费重试次数（默认16）(Optional)

type CreateConsumerGroupResponse 

type CreateConsumerGroupResponse struct {
	RequestID string                    `json:"requestId"`
	Error     core.ErrorResponse        `json:"error"`
	Result    CreateConsumerGroupResult `json:"result"`
}

type CreateConsumerGroupResult 

type CreateConsumerGroupResult struct {
	ConsumerGroup string `json:"consumerGroup"`
}

type CreateTopicRequest 

type CreateTopicRequest struct {
	core.JDCloudRequest

	/* 区域id  */
	RegionId string `json:"regionId"`

	/* 实例id  */
	InstanceId string `json:"instanceId"`

	/* topic名称  */
	Topic string `json:"topic"`

	/* 类型，[NORMAL,GLOBAL_ORDER，PARTITION_ORDER，TRANSACTION，DELAY]  */
	TopicType string `json:"topicType"`

	/* 描述，长度不大于128 (Optional) */
	Description *string `json:"description"`

	/* 分区数[1-32] (Optional) */
	QueueNums *int `json:"queueNums"`
}

func NewCreateTopicRequest 

func NewCreateTopicRequest(
	regionId string,
	instanceId string,
	topic string,
	topicType string,
) *CreateTopicRequest

* param regionId: 区域id (Required) * param instanceId: 实例id (Required) * param topic: topic名称 (Required) * param topicType: 类型，[NORMAL,GLOBAL_ORDER，PARTITION_ORDER，TRANSACTION，DELAY] (Required) * * @Deprecated, not compatible when mandatory parameters changed

func NewCreateTopicRequestWithAllParams 

func NewCreateTopicRequestWithAllParams(
	regionId string,
	instanceId string,
	topic string,
	topicType string,
	description *string,
	queueNums *int,
) *CreateTopicRequest

* param regionId: 区域id (Required) * param instanceId: 实例id (Required) * param topic: topic名称 (Required) * param topicType: 类型，[NORMAL,GLOBAL_ORDER，PARTITION_ORDER，TRANSACTION，DELAY] (Required) * param description: 描述，长度不大于128 (Optional) * param queueNums: 分区数[1-32] (Optional)

func NewCreateTopicRequestWithoutParam 

func NewCreateTopicRequestWithoutParam() *CreateTopicRequest

This constructor has better compatible ability when API parameters changed

func (CreateTopicRequest) GetRegionId 

func (r CreateTopicRequest) GetRegionId() string

GetRegionId returns path parameter 'regionId' if exist, otherwise return empty string

func (*CreateTopicRequest) SetDescription 

func (r *CreateTopicRequest) SetDescription(description string)

param description: 描述，长度不大于128(Optional)

func (*CreateTopicRequest) SetInstanceId 

func (r *CreateTopicRequest) SetInstanceId(instanceId string)

param instanceId: 实例id(Required)

func (*CreateTopicRequest) SetQueueNums 

func (r *CreateTopicRequest) SetQueueNums(queueNums int)

param queueNums: 分区数[1-32](Optional)

func (*CreateTopicRequest) SetRegionId 

func (r *CreateTopicRequest) SetRegionId(regionId string)

param regionId: 区域id(Required)

func (*CreateTopicRequest) SetTopic 

func (r *CreateTopicRequest) SetTopic(topic string)

param topic: topic名称(Required)

func (*CreateTopicRequest) SetTopicType 

func (r *CreateTopicRequest) SetTopicType(topicType string)

param topicType: 类型，[NORMAL,GLOBAL_ORDER，PARTITION_ORDER，TRANSACTION，DELAY](Required)

type CreateTopicResponse 

type CreateTopicResponse struct {
	RequestID string             `json:"requestId"`
	Error     core.ErrorResponse `json:"error"`
	Result    CreateTopicResult  `json:"result"`
}

type CreateTopicResult 

type CreateTopicResult struct {
	Topic string `json:"topic"`
}

type DeleteConsumerGroupRequest 

type DeleteConsumerGroupRequest struct {
	core.JDCloudRequest

	/* 区域ID  */
	RegionId string `json:"regionId"`

	/* 实例id  */
	InstanceId string `json:"instanceId"`

	/* 消费组名称  */
	ConsumerGroup string `json:"consumerGroup"`
}

func NewDeleteConsumerGroupRequest 

func NewDeleteConsumerGroupRequest(
	regionId string,
	instanceId string,
	consumerGroup string,
) *DeleteConsumerGroupRequest

* param regionId: 区域ID (Required) * param instanceId: 实例id (Required) * param consumerGroup: 消费组名称 (Required) * * @Deprecated, not compatible when mandatory parameters changed

func NewDeleteConsumerGroupRequestWithAllParams 

func NewDeleteConsumerGroupRequestWithAllParams(
	regionId string,
	instanceId string,
	consumerGroup string,
) *DeleteConsumerGroupRequest

* param regionId: 区域ID (Required) * param instanceId: 实例id (Required) * param consumerGroup: 消费组名称 (Required)

func NewDeleteConsumerGroupRequestWithoutParam 

func NewDeleteConsumerGroupRequestWithoutParam() *DeleteConsumerGroupRequest

This constructor has better compatible ability when API parameters changed

func (DeleteConsumerGroupRequest) GetRegionId 

func (r DeleteConsumerGroupRequest) GetRegionId() string

GetRegionId returns path parameter 'regionId' if exist, otherwise return empty string

func (*DeleteConsumerGroupRequest) SetConsumerGroup 

func (r *DeleteConsumerGroupRequest) SetConsumerGroup(consumerGroup string)

param consumerGroup: 消费组名称(Required)

func (*DeleteConsumerGroupRequest) SetInstanceId 

func (r *DeleteConsumerGroupRequest) SetInstanceId(instanceId string)

param instanceId: 实例id(Required)

func (*DeleteConsumerGroupRequest) SetRegionId 

func (r *DeleteConsumerGroupRequest) SetRegionId(regionId string)

param regionId: 区域ID(Required)

type DeleteConsumerGroupResponse 

type DeleteConsumerGroupResponse struct {
	RequestID string                    `json:"requestId"`
	Error     core.ErrorResponse        `json:"error"`
	Result    DeleteConsumerGroupResult `json:"result"`
}

type DeleteConsumerGroupResult 

type DeleteConsumerGroupResult struct {
	ConsumerGroup string `json:"consumerGroup"`
}

type DeleteTopicRequest 

type DeleteTopicRequest struct {
	core.JDCloudRequest

	/* 区域id  */
	RegionId string `json:"regionId"`

	/* 实例id  */
	InstanceId string `json:"instanceId"`

	/* topic 名称  */
	Topic string `json:"topic"`
}

func NewDeleteTopicRequest 

func NewDeleteTopicRequest(
	regionId string,
	instanceId string,
	topic string,
) *DeleteTopicRequest

* param regionId: 区域id (Required) * param instanceId: 实例id (Required) * param topic: topic 名称 (Required) * * @Deprecated, not compatible when mandatory parameters changed

func NewDeleteTopicRequestWithAllParams 

func NewDeleteTopicRequestWithAllParams(
	regionId string,
	instanceId string,
	topic string,
) *DeleteTopicRequest

* param regionId: 区域id (Required) * param instanceId: 实例id (Required) * param topic: topic 名称 (Required)

func NewDeleteTopicRequestWithoutParam 

func NewDeleteTopicRequestWithoutParam() *DeleteTopicRequest

This constructor has better compatible ability when API parameters changed

func (DeleteTopicRequest) GetRegionId 

func (r DeleteTopicRequest) GetRegionId() string

GetRegionId returns path parameter 'regionId' if exist, otherwise return empty string

func (*DeleteTopicRequest) SetInstanceId 

func (r *DeleteTopicRequest) SetInstanceId(instanceId string)

param instanceId: 实例id(Required)

func (*DeleteTopicRequest) SetRegionId 

func (r *DeleteTopicRequest) SetRegionId(regionId string)

param regionId: 区域id(Required)

func (*DeleteTopicRequest) SetTopic 

func (r *DeleteTopicRequest) SetTopic(topic string)

param topic: topic 名称(Required)

type DeleteTopicResponse 

type DeleteTopicResponse struct {
	RequestID string             `json:"requestId"`
	Error     core.ErrorResponse `json:"error"`
	Result    DeleteTopicResult  `json:"result"`
}

type DeleteTopicResult 

type DeleteTopicResult struct {
	Topic string `json:"topic"`
}

type DescribeConsumeTraceDetailRequest 

type DescribeConsumeTraceDetailRequest struct {
	core.JDCloudRequest

	/* 区域ID  */
	RegionId string `json:"regionId"`

	/* 实例id  */
	InstanceId string `json:"instanceId"`

	/* topic 名称  */
	Topic string `json:"topic"`

	/* message Id  */
	MessageId string `json:"messageId"`

	/* 取决于客户端使用，如果未指定traceTopic,则不填 (Optional) */
	TraceTopic *string `json:"traceTopic"`

	/* 查该consumerGroup的客户端消费轨迹详情  */
	ConsumerGroup string `json:"consumerGroup"`

	/* 分页大小  */
	PageSize int `json:"pageSize"`

	/* 页码  */
	PageNumber int `json:"pageNumber"`
}

func NewDescribeConsumeTraceDetailRequest 

func NewDescribeConsumeTraceDetailRequest(
	regionId string,
	instanceId string,
	topic string,
	messageId string,
	consumerGroup string,
	pageSize int,
	pageNumber int,
) *DescribeConsumeTraceDetailRequest

* param regionId: 区域ID (Required) * param instanceId: 实例id (Required) * param topic: topic 名称 (Required) * param messageId: message Id (Required) * param consumerGroup: 查该consumerGroup的客户端消费轨迹详情 (Required) * param pageSize: 分页大小 (Required) * param pageNumber: 页码 (Required) * * @Deprecated, not compatible when mandatory parameters changed

func NewDescribeConsumeTraceDetailRequestWithAllParams 

func NewDescribeConsumeTraceDetailRequestWithAllParams(
	regionId string,
	instanceId string,
	topic string,
	messageId string,
	traceTopic *string,
	consumerGroup string,
	pageSize int,
	pageNumber int,
) *DescribeConsumeTraceDetailRequest

* param regionId: 区域ID (Required) * param instanceId: 实例id (Required) * param topic: topic 名称 (Required) * param messageId: message Id (Required) * param traceTopic: 取决于客户端使用，如果未指定traceTopic,则不填 (Optional) * param consumerGroup: 查该consumerGroup的客户端消费轨迹详情 (Required) * param pageSize: 分页大小 (Required) * param pageNumber: 页码 (Required)

func NewDescribeConsumeTraceDetailRequestWithoutParam 

func NewDescribeConsumeTraceDetailRequestWithoutParam() *DescribeConsumeTraceDetailRequest

This constructor has better compatible ability when API parameters changed

func (DescribeConsumeTraceDetailRequest) GetRegionId 

func (r DescribeConsumeTraceDetailRequest) GetRegionId() string

GetRegionId returns path parameter 'regionId' if exist, otherwise return empty string

func (*DescribeConsumeTraceDetailRequest) SetConsumerGroup 

func (r *DescribeConsumeTraceDetailRequest) SetConsumerGroup(consumerGroup string)

param consumerGroup: 查该consumerGroup的客户端消费轨迹详情(Required)

func (*DescribeConsumeTraceDetailRequest) SetInstanceId 

func (r *DescribeConsumeTraceDetailRequest) SetInstanceId(instanceId string)

param instanceId: 实例id(Required)

func (*DescribeConsumeTraceDetailRequest) SetMessageId 

func (r *DescribeConsumeTraceDetailRequest) SetMessageId(messageId string)

param messageId: message Id(Required)

func (*DescribeConsumeTraceDetailRequest) SetPageNumber 

func (r *DescribeConsumeTraceDetailRequest) SetPageNumber(pageNumber int)

param pageNumber: 页码(Required)

func (*DescribeConsumeTraceDetailRequest) SetPageSize 

func (r *DescribeConsumeTraceDetailRequest) SetPageSize(pageSize int)

param pageSize: 分页大小(Required)

func (*DescribeConsumeTraceDetailRequest) SetRegionId 

func (r *DescribeConsumeTraceDetailRequest) SetRegionId(regionId string)

param regionId: 区域ID(Required)

func (*DescribeConsumeTraceDetailRequest) SetTopic 

func (r *DescribeConsumeTraceDetailRequest) SetTopic(topic string)

param topic: topic 名称(Required)

func (*DescribeConsumeTraceDetailRequest) SetTraceTopic 

func (r *DescribeConsumeTraceDetailRequest) SetTraceTopic(traceTopic string)

param traceTopic: 取决于客户端使用，如果未指定traceTopic,则不填(Optional)

type DescribeConsumeTraceDetailResponse 

type DescribeConsumeTraceDetailResponse struct {
	RequestID string                           `json:"requestId"`
	Error     core.ErrorResponse               `json:"error"`
	Result    DescribeConsumeTraceDetailResult `json:"result"`
}

type DescribeConsumeTraceDetailResult 

type DescribeConsumeTraceDetailResult struct {
	TotalCount   int                           `json:"totalCount"`
	ConsumerList []rocketmq.ConsumerInfoDetail `json:"consumerList"`
}

type DescribeConsumeTraceRequest 

type DescribeConsumeTraceRequest struct {
	core.JDCloudRequest

	/* 区域ID  */
	RegionId string `json:"regionId"`

	/* 实例id  */
	InstanceId string `json:"instanceId"`

	/* topic 名称  */
	Topic string `json:"topic"`

	/* message Id  */
	MessageId string `json:"messageId"`

	/* 取决于客户端使用，如果未指定traceTopic,则不填 (Optional) */
	TraceTopic *string `json:"traceTopic"`

	/* 分页大小  */
	PageSize int `json:"pageSize"`

	/* 页码  */
	PageNumber int `json:"pageNumber"`
}

func NewDescribeConsumeTraceRequest 

func NewDescribeConsumeTraceRequest(
	regionId string,
	instanceId string,
	topic string,
	messageId string,
	pageSize int,
	pageNumber int,
) *DescribeConsumeTraceRequest

* param regionId: 区域ID (Required) * param instanceId: 实例id (Required) * param topic: topic 名称 (Required) * param messageId: message Id (Required) * param pageSize: 分页大小 (Required) * param pageNumber: 页码 (Required) * * @Deprecated, not compatible when mandatory parameters changed

func NewDescribeConsumeTraceRequestWithAllParams 

func NewDescribeConsumeTraceRequestWithAllParams(
	regionId string,
	instanceId string,
	topic string,
	messageId string,
	traceTopic *string,
	pageSize int,
	pageNumber int,
) *DescribeConsumeTraceRequest

* param regionId: 区域ID (Required) * param instanceId: 实例id (Required) * param topic: topic 名称 (Required) * param messageId: message Id (Required) * param traceTopic: 取决于客户端使用，如果未指定traceTopic,则不填 (Optional) * param pageSize: 分页大小 (Required) * param pageNumber: 页码 (Required)

func NewDescribeConsumeTraceRequestWithoutParam 

func NewDescribeConsumeTraceRequestWithoutParam() *DescribeConsumeTraceRequest

This constructor has better compatible ability when API parameters changed

func (DescribeConsumeTraceRequest) GetRegionId 

func (r DescribeConsumeTraceRequest) GetRegionId() string

GetRegionId returns path parameter 'regionId' if exist, otherwise return empty string

func (*DescribeConsumeTraceRequest) SetInstanceId 

func (r *DescribeConsumeTraceRequest) SetInstanceId(instanceId string)

param instanceId: 实例id(Required)

func (*DescribeConsumeTraceRequest) SetMessageId 

func (r *DescribeConsumeTraceRequest) SetMessageId(messageId string)

param messageId: message Id(Required)

func (*DescribeConsumeTraceRequest) SetPageNumber 

func (r *DescribeConsumeTraceRequest) SetPageNumber(pageNumber int)

param pageNumber: 页码(Required)

func (*DescribeConsumeTraceRequest) SetPageSize 

func (r *DescribeConsumeTraceRequest) SetPageSize(pageSize int)

param pageSize: 分页大小(Required)

func (*DescribeConsumeTraceRequest) SetRegionId 

func (r *DescribeConsumeTraceRequest) SetRegionId(regionId string)

param regionId: 区域ID(Required)

func (*DescribeConsumeTraceRequest) SetTopic 

func (r *DescribeConsumeTraceRequest) SetTopic(topic string)

param topic: topic 名称(Required)

func (*DescribeConsumeTraceRequest) SetTraceTopic 

func (r *DescribeConsumeTraceRequest) SetTraceTopic(traceTopic string)

param traceTopic: 取决于客户端使用，如果未指定traceTopic,则不填(Optional)

type DescribeConsumeTraceResponse 

type DescribeConsumeTraceResponse struct {
	RequestID string                     `json:"requestId"`
	Error     core.ErrorResponse         `json:"error"`
	Result    DescribeConsumeTraceResult `json:"result"`
}

type DescribeConsumeTraceResult 

type DescribeConsumeTraceResult struct {
	TotalCount        int      `json:"totalCount"`
	ConsumerGroupList []string `json:"consumerGroupList"`
}

type DescribeConsumerAllTopicsRequest 

type DescribeConsumerAllTopicsRequest struct {
	core.JDCloudRequest

	/* 区域ID  */
	RegionId string `json:"regionId"`

	/* 实例id  */
	InstanceId string `json:"instanceId"`

	/* 消费组名称  */
	ConsumerGroup string `json:"consumerGroup"`

	/* topic的过滤条件 (Optional) */
	TopicFilter *string `json:"topicFilter"`
}

func NewDescribeConsumerAllTopicsRequest 

func NewDescribeConsumerAllTopicsRequest(
	regionId string,
	instanceId string,
	consumerGroup string,
) *DescribeConsumerAllTopicsRequest

* param regionId: 区域ID (Required) * param instanceId: 实例id (Required) * param consumerGroup: 消费组名称 (Required) * * @Deprecated, not compatible when mandatory parameters changed

func NewDescribeConsumerAllTopicsRequestWithAllParams 

func NewDescribeConsumerAllTopicsRequestWithAllParams(
	regionId string,
	instanceId string,
	consumerGroup string,
	topicFilter *string,
) *DescribeConsumerAllTopicsRequest

* param regionId: 区域ID (Required) * param instanceId: 实例id (Required) * param consumerGroup: 消费组名称 (Required) * param topicFilter: topic的过滤条件 (Optional)

func NewDescribeConsumerAllTopicsRequestWithoutParam 

func NewDescribeConsumerAllTopicsRequestWithoutParam() *DescribeConsumerAllTopicsRequest

This constructor has better compatible ability when API parameters changed

func (DescribeConsumerAllTopicsRequest) GetRegionId 

func (r DescribeConsumerAllTopicsRequest) GetRegionId() string

GetRegionId returns path parameter 'regionId' if exist, otherwise return empty string

func (*DescribeConsumerAllTopicsRequest) SetConsumerGroup 

func (r *DescribeConsumerAllTopicsRequest) SetConsumerGroup(consumerGroup string)

param consumerGroup: 消费组名称(Required)

func (*DescribeConsumerAllTopicsRequest) SetInstanceId 

func (r *DescribeConsumerAllTopicsRequest) SetInstanceId(instanceId string)

param instanceId: 实例id(Required)

func (*DescribeConsumerAllTopicsRequest) SetRegionId 

func (r *DescribeConsumerAllTopicsRequest) SetRegionId(regionId string)

param regionId: 区域ID(Required)

func (*DescribeConsumerAllTopicsRequest) SetTopicFilter 

func (r *DescribeConsumerAllTopicsRequest) SetTopicFilter(topicFilter string)

param topicFilter: topic的过滤条件(Optional)

type DescribeConsumerAllTopicsResponse 

type DescribeConsumerAllTopicsResponse struct {
	RequestID string                          `json:"requestId"`
	Error     core.ErrorResponse              `json:"error"`
	Result    DescribeConsumerAllTopicsResult `json:"result"`
}

type DescribeConsumerAllTopicsResult 

type DescribeConsumerAllTopicsResult struct {
	TotalCount    int      `json:"totalCount"`
	TopicNameList []string `json:"topicNameList"`
}

type DescribeConsumerGroupNamesRequest 

type DescribeConsumerGroupNamesRequest struct {
	core.JDCloudRequest

	/* 区域ID  */
	RegionId string `json:"regionId"`

	/* 实例id  */
	InstanceId string `json:"instanceId"`

	/* consumerGroup的过滤条件 (Optional) */
	ConsumerFilter *string `json:"consumerFilter"`
}

func NewDescribeConsumerGroupNamesRequest 

func NewDescribeConsumerGroupNamesRequest(
	regionId string,
	instanceId string,
) *DescribeConsumerGroupNamesRequest

* param regionId: 区域ID (Required) * param instanceId: 实例id (Required) * * @Deprecated, not compatible when mandatory parameters changed

func NewDescribeConsumerGroupNamesRequestWithAllParams 

func NewDescribeConsumerGroupNamesRequestWithAllParams(
	regionId string,
	instanceId string,
	consumerFilter *string,
) *DescribeConsumerGroupNamesRequest

* param regionId: 区域ID (Required) * param instanceId: 实例id (Required) * param consumerFilter: consumerGroup的过滤条件 (Optional)

func NewDescribeConsumerGroupNamesRequestWithoutParam 

func NewDescribeConsumerGroupNamesRequestWithoutParam() *DescribeConsumerGroupNamesRequest

This constructor has better compatible ability when API parameters changed

func (DescribeConsumerGroupNamesRequest) GetRegionId 

func (r DescribeConsumerGroupNamesRequest) GetRegionId() string

GetRegionId returns path parameter 'regionId' if exist, otherwise return empty string

func (*DescribeConsumerGroupNamesRequest) SetConsumerFilter 

func (r *DescribeConsumerGroupNamesRequest) SetConsumerFilter(consumerFilter string)

param consumerFilter: consumerGroup的过滤条件(Optional)

func (*DescribeConsumerGroupNamesRequest) SetInstanceId 

func (r *DescribeConsumerGroupNamesRequest) SetInstanceId(instanceId string)

param instanceId: 实例id(Required)

func (*DescribeConsumerGroupNamesRequest) SetRegionId 

func (r *DescribeConsumerGroupNamesRequest) SetRegionId(regionId string)

param regionId: 区域ID(Required)

type DescribeConsumerGroupNamesResponse 

type DescribeConsumerGroupNamesResponse struct {
	RequestID string                           `json:"requestId"`
	Error     core.ErrorResponse               `json:"error"`
	Result    DescribeConsumerGroupNamesResult `json:"result"`
}

type DescribeConsumerGroupNamesResult 

type DescribeConsumerGroupNamesResult struct {
	ConsumerGroupNameList []string `json:"consumerGroupNameList"`
}

type DescribeConsumerGroupStatusRequest 

type DescribeConsumerGroupStatusRequest struct {
	core.JDCloudRequest

	/* 区域ID  */
	RegionId string `json:"regionId"`

	/* 实例id  */
	InstanceId string `json:"instanceId"`

	/* 消费组名称  */
	ConsumerGroup string `json:"consumerGroup"`
}

func NewDescribeConsumerGroupStatusRequest 

func NewDescribeConsumerGroupStatusRequest(
	regionId string,
	instanceId string,
	consumerGroup string,
) *DescribeConsumerGroupStatusRequest

* param regionId: 区域ID (Required) * param instanceId: 实例id (Required) * param consumerGroup: 消费组名称 (Required) * * @Deprecated, not compatible when mandatory parameters changed

func NewDescribeConsumerGroupStatusRequestWithAllParams 

func NewDescribeConsumerGroupStatusRequestWithAllParams(
	regionId string,
	instanceId string,
	consumerGroup string,
) *DescribeConsumerGroupStatusRequest

* param regionId: 区域ID (Required) * param instanceId: 实例id (Required) * param consumerGroup: 消费组名称 (Required)

func NewDescribeConsumerGroupStatusRequestWithoutParam 

func NewDescribeConsumerGroupStatusRequestWithoutParam() *DescribeConsumerGroupStatusRequest

This constructor has better compatible ability when API parameters changed

func (DescribeConsumerGroupStatusRequest) GetRegionId 

func (r DescribeConsumerGroupStatusRequest) GetRegionId() string

GetRegionId returns path parameter 'regionId' if exist, otherwise return empty string

func (*DescribeConsumerGroupStatusRequest) SetConsumerGroup 

func (r *DescribeConsumerGroupStatusRequest) SetConsumerGroup(consumerGroup string)

param consumerGroup: 消费组名称(Required)

func (*DescribeConsumerGroupStatusRequest) SetInstanceId 

func (r *DescribeConsumerGroupStatusRequest) SetInstanceId(instanceId string)

param instanceId: 实例id(Required)

func (*DescribeConsumerGroupStatusRequest) SetRegionId 

func (r *DescribeConsumerGroupStatusRequest) SetRegionId(regionId string)

param regionId: 区域ID(Required)

type DescribeConsumerGroupStatusResponse 

type DescribeConsumerGroupStatusResponse struct {
	RequestID string                            `json:"requestId"`
	Error     core.ErrorResponse                `json:"error"`
	Result    DescribeConsumerGroupStatusResult `json:"result"`
}

type DescribeConsumerGroupStatusResult 

type DescribeConsumerGroupStatusResult struct {
	ConsumerGroupStatus rocketmq.ConsumerGroupStatus `json:"consumerGroupStatus"`
}

type DescribeConsumerGroupsRequest 

type DescribeConsumerGroupsRequest struct {
	core.JDCloudRequest

	/* 区域ID  */
	RegionId string `json:"regionId"`

	/* 实例id  */
	InstanceId string `json:"instanceId"`

	/* consumerGroup的过滤条件 (Optional) */
	ConsumerFilter *string `json:"consumerFilter"`

	/* 分页大小  */
	PageSize int `json:"pageSize"`

	/* 页码  */
	PageNumber int `json:"pageNumber"`
}

func NewDescribeConsumerGroupsRequest 

func NewDescribeConsumerGroupsRequest(
	regionId string,
	instanceId string,
	pageSize int,
	pageNumber int,
) *DescribeConsumerGroupsRequest

* param regionId: 区域ID (Required) * param instanceId: 实例id (Required) * param pageSize: 分页大小 (Required) * param pageNumber: 页码 (Required) * * @Deprecated, not compatible when mandatory parameters changed

func NewDescribeConsumerGroupsRequestWithAllParams 

func NewDescribeConsumerGroupsRequestWithAllParams(
	regionId string,
	instanceId string,
	consumerFilter *string,
	pageSize int,
	pageNumber int,
) *DescribeConsumerGroupsRequest

* param regionId: 区域ID (Required) * param instanceId: 实例id (Required) * param consumerFilter: consumerGroup的过滤条件 (Optional) * param pageSize: 分页大小 (Required) * param pageNumber: 页码 (Required)

func NewDescribeConsumerGroupsRequestWithoutParam 

func NewDescribeConsumerGroupsRequestWithoutParam() *DescribeConsumerGroupsRequest

This constructor has better compatible ability when API parameters changed

func (DescribeConsumerGroupsRequest) GetRegionId 

func (r DescribeConsumerGroupsRequest) GetRegionId() string

GetRegionId returns path parameter 'regionId' if exist, otherwise return empty string

func (*DescribeConsumerGroupsRequest) SetConsumerFilter 

func (r *DescribeConsumerGroupsRequest) SetConsumerFilter(consumerFilter string)

param consumerFilter: consumerGroup的过滤条件(Optional)

func (*DescribeConsumerGroupsRequest) SetInstanceId 

func (r *DescribeConsumerGroupsRequest) SetInstanceId(instanceId string)

param instanceId: 实例id(Required)

func (*DescribeConsumerGroupsRequest) SetPageNumber 

func (r *DescribeConsumerGroupsRequest) SetPageNumber(pageNumber int)

param pageNumber: 页码(Required)

func (*DescribeConsumerGroupsRequest) SetPageSize 

func (r *DescribeConsumerGroupsRequest) SetPageSize(pageSize int)

param pageSize: 分页大小(Required)

func (*DescribeConsumerGroupsRequest) SetRegionId 

func (r *DescribeConsumerGroupsRequest) SetRegionId(regionId string)

param regionId: 区域ID(Required)

type DescribeConsumerGroupsResponse 

type DescribeConsumerGroupsResponse struct {
	RequestID string                       `json:"requestId"`
	Error     core.ErrorResponse           `json:"error"`
	Result    DescribeConsumerGroupsResult `json:"result"`
}

type DescribeConsumerGroupsResult 

type DescribeConsumerGroupsResult struct {
	TotalCount        int                          `json:"totalCount"`
	ConsumerGroupList []rocketmq.ConsumerGroupInfo `json:"consumerGroupList"`
}

type DescribeConsumerSubTopicsRequest 

type DescribeConsumerSubTopicsRequest struct {
	core.JDCloudRequest

	/* 区域ID  */
	RegionId string `json:"regionId"`

	/* 实例id  */
	InstanceId string `json:"instanceId"`

	/* 消费组名称  */
	ConsumerGroup string `json:"consumerGroup"`

	/* 分页大小  */
	PageSize int `json:"pageSize"`

	/* 页码  */
	PageNumber int `json:"pageNumber"`

	/* topic匹配字段 (Optional) */
	TopicFilter *string `json:"topicFilter"`
}

func NewDescribeConsumerSubTopicsRequest 

func NewDescribeConsumerSubTopicsRequest(
	regionId string,
	instanceId string,
	consumerGroup string,
	pageSize int,
	pageNumber int,
) *DescribeConsumerSubTopicsRequest

* param regionId: 区域ID (Required) * param instanceId: 实例id (Required) * param consumerGroup: 消费组名称 (Required) * param pageSize: 分页大小 (Required) * param pageNumber: 页码 (Required) * * @Deprecated, not compatible when mandatory parameters changed

func NewDescribeConsumerSubTopicsRequestWithAllParams 

func NewDescribeConsumerSubTopicsRequestWithAllParams(
	regionId string,
	instanceId string,
	consumerGroup string,
	pageSize int,
	pageNumber int,
	topicFilter *string,
) *DescribeConsumerSubTopicsRequest

* param regionId: 区域ID (Required) * param instanceId: 实例id (Required) * param consumerGroup: 消费组名称 (Required) * param pageSize: 分页大小 (Required) * param pageNumber: 页码 (Required) * param topicFilter: topic匹配字段 (Optional)

func NewDescribeConsumerSubTopicsRequestWithoutParam 

func NewDescribeConsumerSubTopicsRequestWithoutParam() *DescribeConsumerSubTopicsRequest

This constructor has better compatible ability when API parameters changed

func (DescribeConsumerSubTopicsRequest) GetRegionId 

func (r DescribeConsumerSubTopicsRequest) GetRegionId() string

GetRegionId returns path parameter 'regionId' if exist, otherwise return empty string

func (*DescribeConsumerSubTopicsRequest) SetConsumerGroup 

func (r *DescribeConsumerSubTopicsRequest) SetConsumerGroup(consumerGroup string)

param consumerGroup: 消费组名称(Required)

func (*DescribeConsumerSubTopicsRequest) SetInstanceId 

func (r *DescribeConsumerSubTopicsRequest) SetInstanceId(instanceId string)

param instanceId: 实例id(Required)

func (*DescribeConsumerSubTopicsRequest) SetPageNumber 

func (r *DescribeConsumerSubTopicsRequest) SetPageNumber(pageNumber int)

param pageNumber: 页码(Required)

func (*DescribeConsumerSubTopicsRequest) SetPageSize 

func (r *DescribeConsumerSubTopicsRequest) SetPageSize(pageSize int)

param pageSize: 分页大小(Required)

func (*DescribeConsumerSubTopicsRequest) SetRegionId 

func (r *DescribeConsumerSubTopicsRequest) SetRegionId(regionId string)

param regionId: 区域ID(Required)

func (*DescribeConsumerSubTopicsRequest) SetTopicFilter 

func (r *DescribeConsumerSubTopicsRequest) SetTopicFilter(topicFilter string)

param topicFilter: topic匹配字段(Optional)

type DescribeConsumerSubTopicsResponse 

type DescribeConsumerSubTopicsResponse struct {
	RequestID string                          `json:"requestId"`
	Error     core.ErrorResponse              `json:"error"`
	Result    DescribeConsumerSubTopicsResult `json:"result"`
}

type DescribeConsumerSubTopicsResult 

type DescribeConsumerSubTopicsResult struct {
	TotalCount                int                          `json:"totalCount"`
	ConsumerGroupSubTopicList []rocketmq.ConsumerSubTopics `json:"consumerGroupSubTopicList"`
}

type DescribeConsumersByTopicRequest 

type DescribeConsumersByTopicRequest struct {
	core.JDCloudRequest

	/* 区域id  */
	RegionId string `json:"regionId"`

	/* 实例id  */
	InstanceId string `json:"instanceId"`

	/* topic 名称  */
	Topic string `json:"topic"`

	/* 分页大小；默认为10；取值范围[10, 100]  */
	PageSize int `json:"pageSize"`

	/* 页码  */
	PageNumber int `json:"pageNumber"`

	/* 按照consumerGroup过滤 (Optional) */
	ConsumerGroup *string `json:"consumerGroup"`
}

func NewDescribeConsumersByTopicRequest 

func NewDescribeConsumersByTopicRequest(
	regionId string,
	instanceId string,
	topic string,
	pageSize int,
	pageNumber int,
) *DescribeConsumersByTopicRequest

* param regionId: 区域id (Required) * param instanceId: 实例id (Required) * param topic: topic 名称 (Required) * param pageSize: 分页大小；默认为10；取值范围[10, 100] (Required) * param pageNumber: 页码 (Required) * * @Deprecated, not compatible when mandatory parameters changed

func NewDescribeConsumersByTopicRequestWithAllParams 

func NewDescribeConsumersByTopicRequestWithAllParams(
	regionId string,
	instanceId string,
	topic string,
	pageSize int,
	pageNumber int,
	consumerGroup *string,
) *DescribeConsumersByTopicRequest

* param regionId: 区域id (Required) * param instanceId: 实例id (Required) * param topic: topic 名称 (Required) * param pageSize: 分页大小；默认为10；取值范围[10, 100] (Required) * param pageNumber: 页码 (Required) * param consumerGroup: 按照consumerGroup过滤 (Optional)

func NewDescribeConsumersByTopicRequestWithoutParam 

func NewDescribeConsumersByTopicRequestWithoutParam() *DescribeConsumersByTopicRequest

This constructor has better compatible ability when API parameters changed

func (DescribeConsumersByTopicRequest) GetRegionId 

func (r DescribeConsumersByTopicRequest) GetRegionId() string

GetRegionId returns path parameter 'regionId' if exist, otherwise return empty string

func (*DescribeConsumersByTopicRequest) SetConsumerGroup 

func (r *DescribeConsumersByTopicRequest) SetConsumerGroup(consumerGroup string)

param consumerGroup: 按照consumerGroup过滤(Optional)

func (*DescribeConsumersByTopicRequest) SetInstanceId 

func (r *DescribeConsumersByTopicRequest) SetInstanceId(instanceId string)

param instanceId: 实例id(Required)

func (*DescribeConsumersByTopicRequest) SetPageNumber 

func (r *DescribeConsumersByTopicRequest) SetPageNumber(pageNumber int)

param pageNumber: 页码(Required)

func (*DescribeConsumersByTopicRequest) SetPageSize 

func (r *DescribeConsumersByTopicRequest) SetPageSize(pageSize int)

param pageSize: 分页大小；默认为10；取值范围[10, 100](Required)

func (*DescribeConsumersByTopicRequest) SetRegionId 

func (r *DescribeConsumersByTopicRequest) SetRegionId(regionId string)

param regionId: 区域id(Required)

func (*DescribeConsumersByTopicRequest) SetTopic 

func (r *DescribeConsumersByTopicRequest) SetTopic(topic string)

param topic: topic 名称(Required)

type DescribeConsumersByTopicResponse 

type DescribeConsumersByTopicResponse struct {
	RequestID string                         `json:"requestId"`
	Error     core.ErrorResponse             `json:"error"`
	Result    DescribeConsumersByTopicResult `json:"result"`
}

type DescribeConsumersByTopicResult 

type DescribeConsumersByTopicResult struct {
	TotalCount            int                          `json:"totalCount"`
	TopicSubscriptionList []rocketmq.TopicSubscription `json:"topicSubscriptionList"`
}

type DescribeMessageByMsgIdRequest 

type DescribeMessageByMsgIdRequest struct {
	core.JDCloudRequest

	/* 区域ID  */
	RegionId string `json:"regionId"`

	/* 实例id  */
	InstanceId string `json:"instanceId"`

	/* topic 名称  */
	Topic string `json:"topic"`

	/* message Id  */
	MessageId string `json:"messageId"`
}

func NewDescribeMessageByMsgIdRequest 

func NewDescribeMessageByMsgIdRequest(
	regionId string,
	instanceId string,
	topic string,
	messageId string,
) *DescribeMessageByMsgIdRequest

* param regionId: 区域ID (Required) * param instanceId: 实例id (Required) * param topic: topic 名称 (Required) * param messageId: message Id (Required) * * @Deprecated, not compatible when mandatory parameters changed

func NewDescribeMessageByMsgIdRequestWithAllParams 

func NewDescribeMessageByMsgIdRequestWithAllParams(
	regionId string,
	instanceId string,
	topic string,
	messageId string,
) *DescribeMessageByMsgIdRequest

* param regionId: 区域ID (Required) * param instanceId: 实例id (Required) * param topic: topic 名称 (Required) * param messageId: message Id (Required)

func NewDescribeMessageByMsgIdRequestWithoutParam 

func NewDescribeMessageByMsgIdRequestWithoutParam() *DescribeMessageByMsgIdRequest

This constructor has better compatible ability when API parameters changed

func (DescribeMessageByMsgIdRequest) GetRegionId 

func (r DescribeMessageByMsgIdRequest) GetRegionId() string

GetRegionId returns path parameter 'regionId' if exist, otherwise return empty string

func (*DescribeMessageByMsgIdRequest) SetInstanceId 

func (r *DescribeMessageByMsgIdRequest) SetInstanceId(instanceId string)

param instanceId: 实例id(Required)

func (*DescribeMessageByMsgIdRequest) SetMessageId 

func (r *DescribeMessageByMsgIdRequest) SetMessageId(messageId string)

param messageId: message Id(Required)

func (*DescribeMessageByMsgIdRequest) SetRegionId 

func (r *DescribeMessageByMsgIdRequest) SetRegionId(regionId string)

param regionId: 区域ID(Required)

func (*DescribeMessageByMsgIdRequest) SetTopic 

func (r *DescribeMessageByMsgIdRequest) SetTopic(topic string)

param topic: topic 名称(Required)

type DescribeMessageByMsgIdResponse 

type DescribeMessageByMsgIdResponse struct {
	RequestID string                       `json:"requestId"`
	Error     core.ErrorResponse           `json:"error"`
	Result    DescribeMessageByMsgIdResult `json:"result"`
}

type DescribeMessageByMsgIdResult 

type DescribeMessageByMsgIdResult struct {
	Message rocketmq.Message `json:"message"`
}

type DescribeMessagesRequest 

type DescribeMessagesRequest struct {
	core.JDCloudRequest

	/* 区域ID  */
	RegionId string `json:"regionId"`

	/* 实例id  */
	InstanceId string `json:"instanceId"`

	/* topic 名称  */
	Topic string `json:"topic"`

	/* 如果填写了就按messageId查询 (Optional) */
	MessageId *string `json:"messageId"`

	/* 如果填写了就按key查询 (Optional) */
	Key *string `json:"key"`

	/* 开始时间 (Optional) */
	Begin *string `json:"begin"`

	/* 结束时间 (Optional) */
	End *string `json:"end"`

	/* 分页大小；  */
	PageSize int `json:"pageSize"`

	/* 页码  */
	PageNumber int `json:"pageNumber"`
}

func NewDescribeMessagesRequest 

func NewDescribeMessagesRequest(
	regionId string,
	instanceId string,
	topic string,
	pageSize int,
	pageNumber int,
) *DescribeMessagesRequest

* param regionId: 区域ID (Required) * param instanceId: 实例id (Required) * param topic: topic 名称 (Required) * param pageSize: 分页大小； (Required) * param pageNumber: 页码 (Required) * * @Deprecated, not compatible when mandatory parameters changed

func NewDescribeMessagesRequestWithAllParams 

func NewDescribeMessagesRequestWithAllParams(
	regionId string,
	instanceId string,
	topic string,
	messageId *string,
	key *string,
	begin *string,
	end *string,
	pageSize int,
	pageNumber int,
) *DescribeMessagesRequest

* param regionId: 区域ID (Required) * param instanceId: 实例id (Required) * param topic: topic 名称 (Required) * param messageId: 如果填写了就按messageId查询 (Optional) * param key: 如果填写了就按key查询 (Optional) * param begin: 开始时间 (Optional) * param end: 结束时间 (Optional) * param pageSize: 分页大小； (Required) * param pageNumber: 页码 (Required)

func NewDescribeMessagesRequestWithoutParam 

func NewDescribeMessagesRequestWithoutParam() *DescribeMessagesRequest

This constructor has better compatible ability when API parameters changed

func (DescribeMessagesRequest) GetRegionId 

func (r DescribeMessagesRequest) GetRegionId() string

GetRegionId returns path parameter 'regionId' if exist, otherwise return empty string

func (*DescribeMessagesRequest) SetBegin 

func (r *DescribeMessagesRequest) SetBegin(begin string)

param begin: 开始时间(Optional)

func (*DescribeMessagesRequest) SetEnd 

func (r *DescribeMessagesRequest) SetEnd(end string)

param end: 结束时间(Optional)

func (*DescribeMessagesRequest) SetInstanceId 

func (r *DescribeMessagesRequest) SetInstanceId(instanceId string)

param instanceId: 实例id(Required)

func (*DescribeMessagesRequest) SetKey 

func (r *DescribeMessagesRequest) SetKey(key string)

param key: 如果填写了就按key查询(Optional)

func (*DescribeMessagesRequest) SetMessageId 

func (r *DescribeMessagesRequest) SetMessageId(messageId string)

param messageId: 如果填写了就按messageId查询(Optional)

func (*DescribeMessagesRequest) SetPageNumber 

func (r *DescribeMessagesRequest) SetPageNumber(pageNumber int)

param pageNumber: 页码(Required)

func (*DescribeMessagesRequest) SetPageSize 

func (r *DescribeMessagesRequest) SetPageSize(pageSize int)

param pageSize: 分页大小；(Required)

func (*DescribeMessagesRequest) SetRegionId 

func (r *DescribeMessagesRequest) SetRegionId(regionId string)

param regionId: 区域ID(Required)

func (*DescribeMessagesRequest) SetTopic 

func (r *DescribeMessagesRequest) SetTopic(topic string)

param topic: topic 名称(Required)

type DescribeMessagesResponse 

type DescribeMessagesResponse struct {
	RequestID string                 `json:"requestId"`
	Error     core.ErrorResponse     `json:"error"`
	Result    DescribeMessagesResult `json:"result"`
}

type DescribeMessagesResult 

type DescribeMessagesResult struct {
	MessageList []rocketmq.Message `json:"messageList"`
	TotalCount  int                `json:"totalCount"`
}

type DescribeProduceTraceRequest 

type DescribeProduceTraceRequest struct {
	core.JDCloudRequest

	/* 区域ID  */
	RegionId string `json:"regionId"`

	/* 实例id  */
	InstanceId string `json:"instanceId"`

	/* topic 名称  */
	Topic string `json:"topic"`

	/* message Id  */
	MessageId string `json:"messageId"`

	/* 取决于客户端使用，如果未指定traceTopic,则不填 (Optional) */
	TraceTopic *string `json:"traceTopic"`
}

func NewDescribeProduceTraceRequest 

func NewDescribeProduceTraceRequest(
	regionId string,
	instanceId string,
	topic string,
	messageId string,
) *DescribeProduceTraceRequest

* param regionId: 区域ID (Required) * param instanceId: 实例id (Required) * param topic: topic 名称 (Required) * param messageId: message Id (Required) * * @Deprecated, not compatible when mandatory parameters changed

func NewDescribeProduceTraceRequestWithAllParams 

func NewDescribeProduceTraceRequestWithAllParams(
	regionId string,
	instanceId string,
	topic string,
	messageId string,
	traceTopic *string,
) *DescribeProduceTraceRequest

* param regionId: 区域ID (Required) * param instanceId: 实例id (Required) * param topic: topic 名称 (Required) * param messageId: message Id (Required) * param traceTopic: 取决于客户端使用，如果未指定traceTopic,则不填 (Optional)

func NewDescribeProduceTraceRequestWithoutParam 

func NewDescribeProduceTraceRequestWithoutParam() *DescribeProduceTraceRequest

This constructor has better compatible ability when API parameters changed

func (DescribeProduceTraceRequest) GetRegionId 

func (r DescribeProduceTraceRequest) GetRegionId() string

GetRegionId returns path parameter 'regionId' if exist, otherwise return empty string

func (*DescribeProduceTraceRequest) SetInstanceId 

func (r *DescribeProduceTraceRequest) SetInstanceId(instanceId string)

param instanceId: 实例id(Required)

func (*DescribeProduceTraceRequest) SetMessageId 

func (r *DescribeProduceTraceRequest) SetMessageId(messageId string)

param messageId: message Id(Required)

func (*DescribeProduceTraceRequest) SetRegionId 

func (r *DescribeProduceTraceRequest) SetRegionId(regionId string)

param regionId: 区域ID(Required)

func (*DescribeProduceTraceRequest) SetTopic 

func (r *DescribeProduceTraceRequest) SetTopic(topic string)

param topic: topic 名称(Required)

func (*DescribeProduceTraceRequest) SetTraceTopic 

func (r *DescribeProduceTraceRequest) SetTraceTopic(traceTopic string)

param traceTopic: 取决于客户端使用，如果未指定traceTopic,则不填(Optional)

type DescribeProduceTraceResponse 

type DescribeProduceTraceResponse struct {
	RequestID string                     `json:"requestId"`
	Error     core.ErrorResponse         `json:"error"`
	Result    DescribeProduceTraceResult `json:"result"`
}

type DescribeProduceTraceResult 

type DescribeProduceTraceResult struct {
	ProduceInfo rocketmq.ProduceInfo `json:"produceInfo"`
}

type DescribeTopicNamesRequest 

type DescribeTopicNamesRequest struct {
	core.JDCloudRequest

	/* 区域id  */
	RegionId string `json:"regionId"`

	/* 实例id  */
	InstanceId string `json:"instanceId"`

	/* topic名称的过滤条件 (Optional) */
	TopicFilter *string `json:"topicFilter"`
}

func NewDescribeTopicNamesRequest 

func NewDescribeTopicNamesRequest(
	regionId string,
	instanceId string,
) *DescribeTopicNamesRequest

* param regionId: 区域id (Required) * param instanceId: 实例id (Required) * * @Deprecated, not compatible when mandatory parameters changed

func NewDescribeTopicNamesRequestWithAllParams 

func NewDescribeTopicNamesRequestWithAllParams(
	regionId string,
	instanceId string,
	topicFilter *string,
) *DescribeTopicNamesRequest

* param regionId: 区域id (Required) * param instanceId: 实例id (Required) * param topicFilter: topic名称的过滤条件 (Optional)

func NewDescribeTopicNamesRequestWithoutParam 

func NewDescribeTopicNamesRequestWithoutParam() *DescribeTopicNamesRequest

This constructor has better compatible ability when API parameters changed

func (DescribeTopicNamesRequest) GetRegionId 

func (r DescribeTopicNamesRequest) GetRegionId() string

GetRegionId returns path parameter 'regionId' if exist, otherwise return empty string

func (*DescribeTopicNamesRequest) SetInstanceId 

func (r *DescribeTopicNamesRequest) SetInstanceId(instanceId string)

param instanceId: 实例id(Required)

func (*DescribeTopicNamesRequest) SetRegionId 

func (r *DescribeTopicNamesRequest) SetRegionId(regionId string)

param regionId: 区域id(Required)

func (*DescribeTopicNamesRequest) SetTopicFilter 

func (r *DescribeTopicNamesRequest) SetTopicFilter(topicFilter string)

param topicFilter: topic名称的过滤条件(Optional)

type DescribeTopicNamesResponse 

type DescribeTopicNamesResponse struct {
	RequestID string                   `json:"requestId"`
	Error     core.ErrorResponse       `json:"error"`
	Result    DescribeTopicNamesResult `json:"result"`
}

type DescribeTopicNamesResult 

type DescribeTopicNamesResult struct {
	TotalCount    int      `json:"totalCount"`
	TopicNameList []string `json:"topicNameList"`
}

type DescribeTopicRequest 

type DescribeTopicRequest struct {
	core.JDCloudRequest

	/* 区域id  */
	RegionId string `json:"regionId"`

	/* 实例id  */
	InstanceId string `json:"instanceId"`

	/* topic 名称  */
	Topic string `json:"topic"`
}

func NewDescribeTopicRequest 

func NewDescribeTopicRequest(
	regionId string,
	instanceId string,
	topic string,
) *DescribeTopicRequest

* param regionId: 区域id (Required) * param instanceId: 实例id (Required) * param topic: topic 名称 (Required) * * @Deprecated, not compatible when mandatory parameters changed

func NewDescribeTopicRequestWithAllParams 

func NewDescribeTopicRequestWithAllParams(
	regionId string,
	instanceId string,
	topic string,
) *DescribeTopicRequest

* param regionId: 区域id (Required) * param instanceId: 实例id (Required) * param topic: topic 名称 (Required)

func NewDescribeTopicRequestWithoutParam 

func NewDescribeTopicRequestWithoutParam() *DescribeTopicRequest

This constructor has better compatible ability when API parameters changed

func (DescribeTopicRequest) GetRegionId 

func (r DescribeTopicRequest) GetRegionId() string

GetRegionId returns path parameter 'regionId' if exist, otherwise return empty string

func (*DescribeTopicRequest) SetInstanceId 

func (r *DescribeTopicRequest) SetInstanceId(instanceId string)

param instanceId: 实例id(Required)

func (*DescribeTopicRequest) SetRegionId 

func (r *DescribeTopicRequest) SetRegionId(regionId string)

param regionId: 区域id(Required)

func (*DescribeTopicRequest) SetTopic 

func (r *DescribeTopicRequest) SetTopic(topic string)

param topic: topic 名称(Required)

type DescribeTopicResponse 

type DescribeTopicResponse struct {
	RequestID string              `json:"requestId"`
	Error     core.ErrorResponse  `json:"error"`
	Result    DescribeTopicResult `json:"result"`
}

type DescribeTopicResult 

type DescribeTopicResult struct {
	Topic rocketmq.Topic `json:"topic"`
}

type DescribeTopicsRequest 

type DescribeTopicsRequest struct {
	core.JDCloudRequest

	/* 区域id  */
	RegionId string `json:"regionId"`

	/* 实例id  */
	InstanceId string `json:"instanceId"`

	/* 分页大小；默认为10；取值范围[10, 100]  */
	PageSize int `json:"pageSize"`

	/* 页码  */
	PageNumber int `json:"pageNumber"`

	/* topic名称的过滤条件 (Optional) */
	TopicFilter *string `json:"topicFilter"`

	/* topic类型的过滤条件 (Optional) */
	TypeFilter *string `json:"typeFilter"`
}

func NewDescribeTopicsRequest 

func NewDescribeTopicsRequest(
	regionId string,
	instanceId string,
	pageSize int,
	pageNumber int,
) *DescribeTopicsRequest

* param regionId: 区域id (Required) * param instanceId: 实例id (Required) * param pageSize: 分页大小；默认为10；取值范围[10, 100] (Required) * param pageNumber: 页码 (Required) * * @Deprecated, not compatible when mandatory parameters changed

func NewDescribeTopicsRequestWithAllParams 

func NewDescribeTopicsRequestWithAllParams(
	regionId string,
	instanceId string,
	pageSize int,
	pageNumber int,
	topicFilter *string,
	typeFilter *string,
) *DescribeTopicsRequest

* param regionId: 区域id (Required) * param instanceId: 实例id (Required) * param pageSize: 分页大小；默认为10；取值范围[10, 100] (Required) * param pageNumber: 页码 (Required) * param topicFilter: topic名称的过滤条件 (Optional) * param typeFilter: topic类型的过滤条件 (Optional)

func NewDescribeTopicsRequestWithoutParam 

func NewDescribeTopicsRequestWithoutParam() *DescribeTopicsRequest

This constructor has better compatible ability when API parameters changed

func (DescribeTopicsRequest) GetRegionId 

func (r DescribeTopicsRequest) GetRegionId() string

GetRegionId returns path parameter 'regionId' if exist, otherwise return empty string

func (*DescribeTopicsRequest) SetInstanceId 

func (r *DescribeTopicsRequest) SetInstanceId(instanceId string)

param instanceId: 实例id(Required)

func (*DescribeTopicsRequest) SetPageNumber 

func (r *DescribeTopicsRequest) SetPageNumber(pageNumber int)

param pageNumber: 页码(Required)

func (*DescribeTopicsRequest) SetPageSize 

func (r *DescribeTopicsRequest) SetPageSize(pageSize int)

param pageSize: 分页大小；默认为10；取值范围[10, 100](Required)

func (*DescribeTopicsRequest) SetRegionId 

func (r *DescribeTopicsRequest) SetRegionId(regionId string)

param regionId: 区域id(Required)

func (*DescribeTopicsRequest) SetTopicFilter 

func (r *DescribeTopicsRequest) SetTopicFilter(topicFilter string)

param topicFilter: topic名称的过滤条件(Optional)

func (*DescribeTopicsRequest) SetTypeFilter 

func (r *DescribeTopicsRequest) SetTypeFilter(typeFilter string)

param typeFilter: topic类型的过滤条件(Optional)

type DescribeTopicsResponse 

type DescribeTopicsResponse struct {
	RequestID string               `json:"requestId"`
	Error     core.ErrorResponse   `json:"error"`
	Result    DescribeTopicsResult `json:"result"`
}

type DescribeTopicsResult 

type DescribeTopicsResult struct {
	TotalCount int              `json:"totalCount"`
	TopicList  []rocketmq.Topic `json:"topicList"`
}

type ResetOffsetRequest 

type ResetOffsetRequest struct {
	core.JDCloudRequest

	/* 区域ID  */
	RegionId string `json:"regionId"`

	/* 实例id  */
	InstanceId string `json:"instanceId"`

	/* 消费组名称  */
	ConsumerGroup string `json:"consumerGroup"`

	/* topic名称  */
	Topic string `json:"topic"`

	/* 重置时间点，不填就跳过所有消息（重置到当前时间） (Optional) */
	ResetTime *string `json:"resetTime"`
}

func NewResetOffsetRequest 

func NewResetOffsetRequest(
	regionId string,
	instanceId string,
	consumerGroup string,
	topic string,
) *ResetOffsetRequest

* param regionId: 区域ID (Required) * param instanceId: 实例id (Required) * param consumerGroup: 消费组名称 (Required) * param topic: topic名称 (Required) * * @Deprecated, not compatible when mandatory parameters changed

func NewResetOffsetRequestWithAllParams 

func NewResetOffsetRequestWithAllParams(
	regionId string,
	instanceId string,
	consumerGroup string,
	topic string,
	resetTime *string,
) *ResetOffsetRequest

* param regionId: 区域ID (Required) * param instanceId: 实例id (Required) * param consumerGroup: 消费组名称 (Required) * param topic: topic名称 (Required) * param resetTime: 重置时间点，不填就跳过所有消息（重置到当前时间） (Optional)

func NewResetOffsetRequestWithoutParam 

func NewResetOffsetRequestWithoutParam() *ResetOffsetRequest

This constructor has better compatible ability when API parameters changed

func (ResetOffsetRequest) GetRegionId 

func (r ResetOffsetRequest) GetRegionId() string

GetRegionId returns path parameter 'regionId' if exist, otherwise return empty string

func (*ResetOffsetRequest) SetConsumerGroup 

func (r *ResetOffsetRequest) SetConsumerGroup(consumerGroup string)

param consumerGroup: 消费组名称(Required)

func (*ResetOffsetRequest) SetInstanceId 

func (r *ResetOffsetRequest) SetInstanceId(instanceId string)

param instanceId: 实例id(Required)

func (*ResetOffsetRequest) SetRegionId 

func (r *ResetOffsetRequest) SetRegionId(regionId string)

param regionId: 区域ID(Required)

func (*ResetOffsetRequest) SetResetTime 

func (r *ResetOffsetRequest) SetResetTime(resetTime string)

param resetTime: 重置时间点，不填就跳过所有消息（重置到当前时间）(Optional)

func (*ResetOffsetRequest) SetTopic 

func (r *ResetOffsetRequest) SetTopic(topic string)

param topic: topic名称(Required)

type ResetOffsetResponse 

type ResetOffsetResponse struct {
	RequestID string             `json:"requestId"`
	Error     core.ErrorResponse `json:"error"`
	Result    ResetOffsetResult  `json:"result"`
}

type ResetOffsetResult 

type ResetOffsetResult struct {
	Result bool `json:"result"`
}

type SendMessageRequest 

type SendMessageRequest struct {
	core.JDCloudRequest

	/* 区域ID  */
	RegionId string `json:"regionId"`

	/* 实例id  */
	InstanceId string `json:"instanceId"`

	/* topic 名称  */
	Topic string `json:"topic"`

	/* 消息内容  */
	MessageBody string `json:"messageBody"`

	/* 消息tag (Optional) */
	Tag *string `json:"tag"`

	/* key id (Optional) */
	Key *string `json:"key"`

	/* 是否延时  */
	EnableDelay bool `json:"enableDelay"`

	/* 延时秒数 (Optional) */
	DelaySecond *int `json:"delaySecond"`
}

func NewSendMessageRequest 

func NewSendMessageRequest(
	regionId string,
	instanceId string,
	topic string,
	messageBody string,
	enableDelay bool,
) *SendMessageRequest

* param regionId: 区域ID (Required) * param instanceId: 实例id (Required) * param topic: topic 名称 (Required) * param messageBody: 消息内容 (Required) * param enableDelay: 是否延时 (Required) * * @Deprecated, not compatible when mandatory parameters changed

func NewSendMessageRequestWithAllParams 

func NewSendMessageRequestWithAllParams(
	regionId string,
	instanceId string,
	topic string,
	messageBody string,
	tag *string,
	key *string,
	enableDelay bool,
	delaySecond *int,
) *SendMessageRequest

* param regionId: 区域ID (Required) * param instanceId: 实例id (Required) * param topic: topic 名称 (Required) * param messageBody: 消息内容 (Required) * param tag: 消息tag (Optional) * param key: key id (Optional) * param enableDelay: 是否延时 (Required) * param delaySecond: 延时秒数 (Optional)

func NewSendMessageRequestWithoutParam 

func NewSendMessageRequestWithoutParam() *SendMessageRequest

This constructor has better compatible ability when API parameters changed

func (SendMessageRequest) GetRegionId 

func (r SendMessageRequest) GetRegionId() string

GetRegionId returns path parameter 'regionId' if exist, otherwise return empty string

func (*SendMessageRequest) SetDelaySecond 

func (r *SendMessageRequest) SetDelaySecond(delaySecond int)

param delaySecond: 延时秒数(Optional)

func (*SendMessageRequest) SetEnableDelay 

func (r *SendMessageRequest) SetEnableDelay(enableDelay bool)

param enableDelay: 是否延时(Required)

func (*SendMessageRequest) SetInstanceId 

func (r *SendMessageRequest) SetInstanceId(instanceId string)

param instanceId: 实例id(Required)

func (*SendMessageRequest) SetKey 

func (r *SendMessageRequest) SetKey(key string)

param key: key id(Optional)

func (*SendMessageRequest) SetMessageBody 

func (r *SendMessageRequest) SetMessageBody(messageBody string)

param messageBody: 消息内容(Required)

func (*SendMessageRequest) SetRegionId 

func (r *SendMessageRequest) SetRegionId(regionId string)

param regionId: 区域ID(Required)

func (*SendMessageRequest) SetTag 

func (r *SendMessageRequest) SetTag(tag string)

param tag: 消息tag(Optional)

func (*SendMessageRequest) SetTopic 

func (r *SendMessageRequest) SetTopic(topic string)

param topic: topic 名称(Required)

type SendMessageResponse 

type SendMessageResponse struct {
	RequestID string             `json:"requestId"`
	Error     core.ErrorResponse `json:"error"`
	Result    SendMessageResult  `json:"result"`
}

type SendMessageResult 

type SendMessageResult struct {
	MsgId      string `json:"msgId"`
	SendStatus string `json:"sendStatus"`
}

type UpdateConsumerGroupRequest 

type UpdateConsumerGroupRequest struct {
	core.JDCloudRequest

	/* 区域ID  */
	RegionId string `json:"regionId"`

	/* 实例id  */
	InstanceId string `json:"instanceId"`

	/* consumerGroup名称  */
	ConsumerGroup string `json:"consumerGroup"`

	/* 描述 (Optional) */
	Description *string `json:"description"`

	/* 消费重试次数 (Optional) */
	RetryMaxTimes *int `json:"retryMaxTimes"`

	/* 是否开启死信（默认开启） (Optional) */
	EnableDlq *bool `json:"enableDlq"`
}

func NewUpdateConsumerGroupRequest 

func NewUpdateConsumerGroupRequest(
	regionId string,
	instanceId string,
	consumerGroup string,
) *UpdateConsumerGroupRequest

* param regionId: 区域ID (Required) * param instanceId: 实例id (Required) * param consumerGroup: consumerGroup名称 (Required) * * @Deprecated, not compatible when mandatory parameters changed

func NewUpdateConsumerGroupRequestWithAllParams 

func NewUpdateConsumerGroupRequestWithAllParams(
	regionId string,
	instanceId string,
	consumerGroup string,
	description *string,
	retryMaxTimes *int,
	enableDlq *bool,
) *UpdateConsumerGroupRequest

* param regionId: 区域ID (Required) * param instanceId: 实例id (Required) * param consumerGroup: consumerGroup名称 (Required) * param description: 描述 (Optional) * param retryMaxTimes: 消费重试次数 (Optional) * param enableDlq: 是否开启死信（默认开启） (Optional)

func NewUpdateConsumerGroupRequestWithoutParam 

func NewUpdateConsumerGroupRequestWithoutParam() *UpdateConsumerGroupRequest

This constructor has better compatible ability when API parameters changed

func (UpdateConsumerGroupRequest) GetRegionId 

func (r UpdateConsumerGroupRequest) GetRegionId() string

GetRegionId returns path parameter 'regionId' if exist, otherwise return empty string

func (*UpdateConsumerGroupRequest) SetConsumerGroup 

func (r *UpdateConsumerGroupRequest) SetConsumerGroup(consumerGroup string)

param consumerGroup: consumerGroup名称(Required)

func (*UpdateConsumerGroupRequest) SetDescription 

func (r *UpdateConsumerGroupRequest) SetDescription(description string)

param description: 描述(Optional)

func (*UpdateConsumerGroupRequest) SetEnableDlq 

func (r *UpdateConsumerGroupRequest) SetEnableDlq(enableDlq bool)

param enableDlq: 是否开启死信（默认开启）(Optional)

func (*UpdateConsumerGroupRequest) SetInstanceId 

func (r *UpdateConsumerGroupRequest) SetInstanceId(instanceId string)

param instanceId: 实例id(Required)

func (*UpdateConsumerGroupRequest) SetRegionId 

func (r *UpdateConsumerGroupRequest) SetRegionId(regionId string)

param regionId: 区域ID(Required)

func (*UpdateConsumerGroupRequest) SetRetryMaxTimes 

func (r *UpdateConsumerGroupRequest) SetRetryMaxTimes(retryMaxTimes int)

param retryMaxTimes: 消费重试次数(Optional)

type UpdateConsumerGroupResponse 

type UpdateConsumerGroupResponse struct {
	RequestID string                    `json:"requestId"`
	Error     core.ErrorResponse        `json:"error"`
	Result    UpdateConsumerGroupResult `json:"result"`
}

type UpdateConsumerGroupResult 

type UpdateConsumerGroupResult struct {
	ConsumerGroup string `json:"consumerGroup"`
}

type UpdateTopicDescriptionRequest 

type UpdateTopicDescriptionRequest struct {
	core.JDCloudRequest

	/* 区域id  */
	RegionId string `json:"regionId"`

	/* 实例id  */
	InstanceId string `json:"instanceId"`

	/* topic 名称  */
	Topic string `json:"topic"`

	/* 描述 (Optional) */
	Description *string `json:"description"`
}

func NewUpdateTopicDescriptionRequest 

func NewUpdateTopicDescriptionRequest(
	regionId string,
	instanceId string,
	topic string,
) *UpdateTopicDescriptionRequest

* param regionId: 区域id (Required) * param instanceId: 实例id (Required) * param topic: topic 名称 (Required) * * @Deprecated, not compatible when mandatory parameters changed

func NewUpdateTopicDescriptionRequestWithAllParams 

func NewUpdateTopicDescriptionRequestWithAllParams(
	regionId string,
	instanceId string,
	topic string,
	description *string,
) *UpdateTopicDescriptionRequest

* param regionId: 区域id (Required) * param instanceId: 实例id (Required) * param topic: topic 名称 (Required) * param description: 描述 (Optional)

func NewUpdateTopicDescriptionRequestWithoutParam 

func NewUpdateTopicDescriptionRequestWithoutParam() *UpdateTopicDescriptionRequest

This constructor has better compatible ability when API parameters changed

func (UpdateTopicDescriptionRequest) GetRegionId 

func (r UpdateTopicDescriptionRequest) GetRegionId() string

GetRegionId returns path parameter 'regionId' if exist, otherwise return empty string

func (*UpdateTopicDescriptionRequest) SetDescription 

func (r *UpdateTopicDescriptionRequest) SetDescription(description string)

param description: 描述(Optional)

func (*UpdateTopicDescriptionRequest) SetInstanceId 

func (r *UpdateTopicDescriptionRequest) SetInstanceId(instanceId string)

param instanceId: 实例id(Required)

func (*UpdateTopicDescriptionRequest) SetRegionId 

func (r *UpdateTopicDescriptionRequest) SetRegionId(regionId string)

param regionId: 区域id(Required)

func (*UpdateTopicDescriptionRequest) SetTopic 

func (r *UpdateTopicDescriptionRequest) SetTopic(topic string)

param topic: topic 名称(Required)

type UpdateTopicDescriptionResponse 

type UpdateTopicDescriptionResponse struct {
	RequestID string                       `json:"requestId"`
	Error     core.ErrorResponse           `json:"error"`
	Result    UpdateTopicDescriptionResult `json:"result"`
}

type UpdateTopicDescriptionResult 

type UpdateTopicDescriptionResult struct {
	Topic string `json:"topic"`
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.