apis

package
v1.12.0 Latest Latest
Warning

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

 Go to latest Published: Aug 23, 2019 License: Apache-2.0 Imports: 3 Imported by: 8

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AddPermissionRequest 

type AddPermissionRequest struct {
	core.JDCloudRequest

	/* 所在区域的Region ID  */
	RegionId string `json:"regionId"`

	/* topic 名称  */
	TopicName string `json:"topicName"`

	/* 权限类型，[PUB,SUB,PUBSUB]  */
	Permission string `json:"permission"`

	/* 目标用户UserId  */
	TargetUserId string `json:"targetUserId"`
}

func NewAddPermissionRequest 

func NewAddPermissionRequest(
	regionId string,
	topicName string,
	permission string,
	targetUserId string,
) *AddPermissionRequest

* param regionId: 所在区域的Region ID (Required) * param topicName: topic 名称 (Required) * param permission: 权限类型，[PUB,SUB,PUBSUB] (Required) * param targetUserId: 目标用户UserId (Required) * * @Deprecated, not compatible when mandatory parameters changed

func NewAddPermissionRequestWithAllParams 

func NewAddPermissionRequestWithAllParams(
	regionId string,
	topicName string,
	permission string,
	targetUserId string,
) *AddPermissionRequest

* param regionId: 所在区域的Region ID (Required) * param topicName: topic 名称 (Required) * param permission: 权限类型，[PUB,SUB,PUBSUB] (Required) * param targetUserId: 目标用户UserId (Required)

func NewAddPermissionRequestWithoutParam 

func NewAddPermissionRequestWithoutParam() *AddPermissionRequest

This constructor has better compatible ability when API parameters changed

func (AddPermissionRequest) GetRegionId 

func (r AddPermissionRequest) GetRegionId() string

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

func (*AddPermissionRequest) SetPermission 

func (r *AddPermissionRequest) SetPermission(permission string)

param permission: 权限类型，[PUB,SUB,PUBSUB](Required)

func (*AddPermissionRequest) SetRegionId 

func (r *AddPermissionRequest) SetRegionId(regionId string)

param regionId: 所在区域的Region ID(Required)

func (*AddPermissionRequest) SetTargetUserId 

func (r *AddPermissionRequest) SetTargetUserId(targetUserId string)

param targetUserId: 目标用户UserId(Required)

func (*AddPermissionRequest) SetTopicName 

func (r *AddPermissionRequest) SetTopicName(topicName string)

param topicName: topic 名称(Required)

type AddPermissionResponse 

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

type AddPermissionResult 

type AddPermissionResult struct {
}

type CleanMessagesRequest 

type CleanMessagesRequest struct {
	core.JDCloudRequest

	/* 所在区域的Region ID  */
	RegionId string `json:"regionId"`

	/* topic 名称  */
	TopicName string `json:"topicName"`

	/* consumerGroupId  */
	ConsumerGroupId string `json:"consumerGroupId"`
}

func NewCleanMessagesRequest 

func NewCleanMessagesRequest(
	regionId string,
	topicName string,
	consumerGroupId string,
) *CleanMessagesRequest

* param regionId: 所在区域的Region ID (Required) * param topicName: topic 名称 (Required) * param consumerGroupId: consumerGroupId (Required) * * @Deprecated, not compatible when mandatory parameters changed

func NewCleanMessagesRequestWithAllParams 

func NewCleanMessagesRequestWithAllParams(
	regionId string,
	topicName string,
	consumerGroupId string,
) *CleanMessagesRequest

* param regionId: 所在区域的Region ID (Required) * param topicName: topic 名称 (Required) * param consumerGroupId: consumerGroupId (Required)

func NewCleanMessagesRequestWithoutParam 

func NewCleanMessagesRequestWithoutParam() *CleanMessagesRequest

This constructor has better compatible ability when API parameters changed

func (CleanMessagesRequest) GetRegionId 

func (r CleanMessagesRequest) GetRegionId() string

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

func (*CleanMessagesRequest) SetConsumerGroupId 

func (r *CleanMessagesRequest) SetConsumerGroupId(consumerGroupId string)

param consumerGroupId: consumerGroupId(Required)

func (*CleanMessagesRequest) SetRegionId 

func (r *CleanMessagesRequest) SetRegionId(regionId string)

param regionId: 所在区域的Region ID(Required)

func (*CleanMessagesRequest) SetTopicName 

func (r *CleanMessagesRequest) SetTopicName(topicName string)

param topicName: topic 名称(Required)

type CleanMessagesResponse 

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

type CleanMessagesResult 

type CleanMessagesResult struct {
}

type CreateSubscriptionRequest 

type CreateSubscriptionRequest struct {
	core.JDCloudRequest

	/* 所在区域的Region ID  */
	RegionId string `json:"regionId"`

	/* topic 名称  */
	TopicName string `json:"topicName"`

	/* consumerGroupId  */
	ConsumerGroupId string `json:"consumerGroupId"`
}

func NewCreateSubscriptionRequest 

func NewCreateSubscriptionRequest(
	regionId string,
	topicName string,
	consumerGroupId string,
) *CreateSubscriptionRequest

* param regionId: 所在区域的Region ID (Required) * param topicName: topic 名称 (Required) * param consumerGroupId: consumerGroupId (Required) * * @Deprecated, not compatible when mandatory parameters changed

func NewCreateSubscriptionRequestWithAllParams 

func NewCreateSubscriptionRequestWithAllParams(
	regionId string,
	topicName string,
	consumerGroupId string,
) *CreateSubscriptionRequest

* param regionId: 所在区域的Region ID (Required) * param topicName: topic 名称 (Required) * param consumerGroupId: consumerGroupId (Required)

func NewCreateSubscriptionRequestWithoutParam 

func NewCreateSubscriptionRequestWithoutParam() *CreateSubscriptionRequest

This constructor has better compatible ability when API parameters changed

func (CreateSubscriptionRequest) GetRegionId 

func (r CreateSubscriptionRequest) GetRegionId() string

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

func (*CreateSubscriptionRequest) SetConsumerGroupId 

func (r *CreateSubscriptionRequest) SetConsumerGroupId(consumerGroupId string)

param consumerGroupId: consumerGroupId(Required)

func (*CreateSubscriptionRequest) SetRegionId 

func (r *CreateSubscriptionRequest) SetRegionId(regionId string)

param regionId: 所在区域的Region ID(Required)

func (*CreateSubscriptionRequest) SetTopicName 

func (r *CreateSubscriptionRequest) SetTopicName(topicName string)

param topicName: topic 名称(Required)

type CreateSubscriptionResponse 

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

type CreateSubscriptionResult 

type CreateSubscriptionResult struct {
}

type CreateTopicRequest 

type CreateTopicRequest struct {
	core.JDCloudRequest

	/* 所在区域的Region ID  */
	RegionId string `json:"regionId"`

	/* topic名称  */
	TopicName string `json:"topicName"`

	/* 类型，[normal,global_order]  */
	Type string `json:"type"`

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

func NewCreateTopicRequest 

func NewCreateTopicRequest(
	regionId string,
	topicName string,
	type_ string,
) *CreateTopicRequest

* param regionId: 所在区域的Region ID (Required) * param topicName: topic名称 (Required) * param type_: 类型，[normal,global_order] (Required) * * @Deprecated, not compatible when mandatory parameters changed

func NewCreateTopicRequestWithAllParams 

func NewCreateTopicRequestWithAllParams(
	regionId string,
	topicName string,
	type_ string,
	description *string,
) *CreateTopicRequest

* param regionId: 所在区域的Region ID (Required) * param topicName: topic名称 (Required) * param type_: 类型，[normal,global_order] (Required) * param description: 描述，长度不大于255 (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: 描述，长度不大于255(Optional)

func (*CreateTopicRequest) SetRegionId 

func (r *CreateTopicRequest) SetRegionId(regionId string)

param regionId: 所在区域的Region ID(Required)

func (*CreateTopicRequest) SetTopicName 

func (r *CreateTopicRequest) SetTopicName(topicName string)

param topicName: topic名称(Required)

func (*CreateTopicRequest) SetType 

func (r *CreateTopicRequest) SetType(type_ string)

param type_: 类型，[normal,global_order](Required)

type CreateTopicResponse 

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

type CreateTopicResult 

type CreateTopicResult struct {
}

type DeleteDeadLettersRequest 

type DeleteDeadLettersRequest struct {
	core.JDCloudRequest

	/* 所在区域的Region ID  */
	RegionId string `json:"regionId"`

	/* topic 名称  */
	TopicName string `json:"topicName"`

	/* consumerGroupId  */
	ConsumerGroupId string `json:"consumerGroupId"`

	/* messageIds,多个逗号隔开，不传该值就是删除所有的死信 (Optional) */
	MessageIds *string `json:"messageIds"`
}

func NewDeleteDeadLettersRequest 

func NewDeleteDeadLettersRequest(
	regionId string,
	topicName string,
	consumerGroupId string,
) *DeleteDeadLettersRequest

* param regionId: 所在区域的Region ID (Required) * param topicName: topic 名称 (Required) * param consumerGroupId: consumerGroupId (Required) * * @Deprecated, not compatible when mandatory parameters changed

func NewDeleteDeadLettersRequestWithAllParams 

func NewDeleteDeadLettersRequestWithAllParams(
	regionId string,
	topicName string,
	consumerGroupId string,
	messageIds *string,
) *DeleteDeadLettersRequest

* param regionId: 所在区域的Region ID (Required) * param topicName: topic 名称 (Required) * param consumerGroupId: consumerGroupId (Required) * param messageIds: messageIds,多个逗号隔开，不传该值就是删除所有的死信 (Optional)

func NewDeleteDeadLettersRequestWithoutParam 

func NewDeleteDeadLettersRequestWithoutParam() *DeleteDeadLettersRequest

This constructor has better compatible ability when API parameters changed

func (DeleteDeadLettersRequest) GetRegionId 

func (r DeleteDeadLettersRequest) GetRegionId() string

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

func (*DeleteDeadLettersRequest) SetConsumerGroupId 

func (r *DeleteDeadLettersRequest) SetConsumerGroupId(consumerGroupId string)

param consumerGroupId: consumerGroupId(Required)

func (*DeleteDeadLettersRequest) SetMessageIds 

func (r *DeleteDeadLettersRequest) SetMessageIds(messageIds string)

param messageIds: messageIds,多个逗号隔开，不传该值就是删除所有的死信(Optional)

func (*DeleteDeadLettersRequest) SetRegionId 

func (r *DeleteDeadLettersRequest) SetRegionId(regionId string)

param regionId: 所在区域的Region ID(Required)

func (*DeleteDeadLettersRequest) SetTopicName 

func (r *DeleteDeadLettersRequest) SetTopicName(topicName string)

param topicName: topic 名称(Required)

type DeleteDeadLettersResponse 

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

type DeleteDeadLettersResult 

type DeleteDeadLettersResult struct {
	MessageIds []string `json:"messageIds"`
}

type DeleteSubscriptionRequest 

type DeleteSubscriptionRequest struct {
	core.JDCloudRequest

	/* 所在区域的Region ID  */
	RegionId string `json:"regionId"`

	/* topic 名称  */
	TopicName string `json:"topicName"`

	/* consumerGroupId  */
	ConsumerGroupId string `json:"consumerGroupId"`
}

func NewDeleteSubscriptionRequest 

func NewDeleteSubscriptionRequest(
	regionId string,
	topicName string,
	consumerGroupId string,
) *DeleteSubscriptionRequest

* param regionId: 所在区域的Region ID (Required) * param topicName: topic 名称 (Required) * param consumerGroupId: consumerGroupId (Required) * * @Deprecated, not compatible when mandatory parameters changed

func NewDeleteSubscriptionRequestWithAllParams 

func NewDeleteSubscriptionRequestWithAllParams(
	regionId string,
	topicName string,
	consumerGroupId string,
) *DeleteSubscriptionRequest

* param regionId: 所在区域的Region ID (Required) * param topicName: topic 名称 (Required) * param consumerGroupId: consumerGroupId (Required)

func NewDeleteSubscriptionRequestWithoutParam 

func NewDeleteSubscriptionRequestWithoutParam() *DeleteSubscriptionRequest

This constructor has better compatible ability when API parameters changed

func (DeleteSubscriptionRequest) GetRegionId 

func (r DeleteSubscriptionRequest) GetRegionId() string

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

func (*DeleteSubscriptionRequest) SetConsumerGroupId 

func (r *DeleteSubscriptionRequest) SetConsumerGroupId(consumerGroupId string)

param consumerGroupId: consumerGroupId(Required)

func (*DeleteSubscriptionRequest) SetRegionId 

func (r *DeleteSubscriptionRequest) SetRegionId(regionId string)

param regionId: 所在区域的Region ID(Required)

func (*DeleteSubscriptionRequest) SetTopicName 

func (r *DeleteSubscriptionRequest) SetTopicName(topicName string)

param topicName: topic 名称(Required)

type DeleteSubscriptionResponse 

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

type DeleteSubscriptionResult 

type DeleteSubscriptionResult struct {
}

type DeleteTopicRequest 

type DeleteTopicRequest struct {
	core.JDCloudRequest

	/* 所在区域的Region ID  */
	RegionId string `json:"regionId"`

	/* topic 名称  */
	TopicName string `json:"topicName"`
}

func NewDeleteTopicRequest 

func NewDeleteTopicRequest(
	regionId string,
	topicName string,
) *DeleteTopicRequest

* param regionId: 所在区域的Region ID (Required) * param topicName: topic 名称 (Required) * * @Deprecated, not compatible when mandatory parameters changed

func NewDeleteTopicRequestWithAllParams 

func NewDeleteTopicRequestWithAllParams(
	regionId string,
	topicName string,
) *DeleteTopicRequest

* param regionId: 所在区域的Region ID (Required) * param topicName: 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) SetRegionId 

func (r *DeleteTopicRequest) SetRegionId(regionId string)

param regionId: 所在区域的Region ID(Required)

func (*DeleteTopicRequest) SetTopicName 

func (r *DeleteTopicRequest) SetTopicName(topicName string)

param topicName: 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 {
}

type DescribeAccessPointRequest 

type DescribeAccessPointRequest struct {
	core.JDCloudRequest

	/* 所在区域的Region ID  */
	RegionId string `json:"regionId"`

	/* topic 名称  */
	TopicName string `json:"topicName"`
}

func NewDescribeAccessPointRequest 

func NewDescribeAccessPointRequest(
	regionId string,
	topicName string,
) *DescribeAccessPointRequest

* param regionId: 所在区域的Region ID (Required) * param topicName: topic 名称 (Required) * * @Deprecated, not compatible when mandatory parameters changed

func NewDescribeAccessPointRequestWithAllParams 

func NewDescribeAccessPointRequestWithAllParams(
	regionId string,
	topicName string,
) *DescribeAccessPointRequest

* param regionId: 所在区域的Region ID (Required) * param topicName: topic 名称 (Required)

func NewDescribeAccessPointRequestWithoutParam 

func NewDescribeAccessPointRequestWithoutParam() *DescribeAccessPointRequest

This constructor has better compatible ability when API parameters changed

func (DescribeAccessPointRequest) GetRegionId 

func (r DescribeAccessPointRequest) GetRegionId() string

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

func (*DescribeAccessPointRequest) SetRegionId 

func (r *DescribeAccessPointRequest) SetRegionId(regionId string)

param regionId: 所在区域的Region ID(Required)

func (*DescribeAccessPointRequest) SetTopicName 

func (r *DescribeAccessPointRequest) SetTopicName(topicName string)

param topicName: topic 名称(Required)

type DescribeAccessPointResponse 

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

type DescribeAccessPointResult 

type DescribeAccessPointResult struct {
	AccessPoint jcq.AccessPoint `json:"accessPoint"`
}

type DescribeConsumerGroupIdsRequest 

type DescribeConsumerGroupIdsRequest struct {
	core.JDCloudRequest

	/* 所在区域的Region ID  */
	RegionId string `json:"regionId"`
}

func NewDescribeConsumerGroupIdsRequest 

func NewDescribeConsumerGroupIdsRequest(
	regionId string,
) *DescribeConsumerGroupIdsRequest

* param regionId: 所在区域的Region ID (Required) * * @Deprecated, not compatible when mandatory parameters changed

func NewDescribeConsumerGroupIdsRequestWithAllParams 

func NewDescribeConsumerGroupIdsRequestWithAllParams(
	regionId string,
) *DescribeConsumerGroupIdsRequest

* param regionId: 所在区域的Region ID (Required)

func NewDescribeConsumerGroupIdsRequestWithoutParam 

func NewDescribeConsumerGroupIdsRequestWithoutParam() *DescribeConsumerGroupIdsRequest

This constructor has better compatible ability when API parameters changed

func (DescribeConsumerGroupIdsRequest) GetRegionId 

func (r DescribeConsumerGroupIdsRequest) GetRegionId() string

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

func (*DescribeConsumerGroupIdsRequest) SetRegionId 

func (r *DescribeConsumerGroupIdsRequest) SetRegionId(regionId string)

param regionId: 所在区域的Region ID(Required)

type DescribeConsumerGroupIdsResponse 

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

type DescribeConsumerGroupIdsResult 

type DescribeConsumerGroupIdsResult struct {
	ConsumerGroupIds []string `json:"consumerGroupIds"`
}

type DescribeDeadLetterNumbersRequest 

type DescribeDeadLetterNumbersRequest struct {
	core.JDCloudRequest

	/* 所在区域的Region ID  */
	RegionId string `json:"regionId"`

	/* consumerGroupId为空则显示该用户所有订阅关系里的死信数量 (Optional) */
	ConsumerGroupId *string `json:"consumerGroupId"`

	/* 页码 (Optional) */
	PageNumber *int `json:"pageNumber"`

	/* 每页数 (Optional) */
	PageSize *int `json:"pageSize"`
}

func NewDescribeDeadLetterNumbersRequest 

func NewDescribeDeadLetterNumbersRequest(
	regionId string,
) *DescribeDeadLetterNumbersRequest

* param regionId: 所在区域的Region ID (Required) * * @Deprecated, not compatible when mandatory parameters changed

func NewDescribeDeadLetterNumbersRequestWithAllParams 

func NewDescribeDeadLetterNumbersRequestWithAllParams(
	regionId string,
	consumerGroupId *string,
	pageNumber *int,
	pageSize *int,
) *DescribeDeadLetterNumbersRequest

* param regionId: 所在区域的Region ID (Required) * param consumerGroupId: consumerGroupId为空则显示该用户所有订阅关系里的死信数量 (Optional) * param pageNumber: 页码 (Optional) * param pageSize: 每页数 (Optional)

func NewDescribeDeadLetterNumbersRequestWithoutParam 

func NewDescribeDeadLetterNumbersRequestWithoutParam() *DescribeDeadLetterNumbersRequest

This constructor has better compatible ability when API parameters changed

func (DescribeDeadLetterNumbersRequest) GetRegionId 

func (r DescribeDeadLetterNumbersRequest) GetRegionId() string

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

func (*DescribeDeadLetterNumbersRequest) SetConsumerGroupId 

func (r *DescribeDeadLetterNumbersRequest) SetConsumerGroupId(consumerGroupId string)

param consumerGroupId: consumerGroupId为空则显示该用户所有订阅关系里的死信数量(Optional)

func (*DescribeDeadLetterNumbersRequest) SetPageNumber 

func (r *DescribeDeadLetterNumbersRequest) SetPageNumber(pageNumber int)

param pageNumber: 页码(Optional)

func (*DescribeDeadLetterNumbersRequest) SetPageSize 

func (r *DescribeDeadLetterNumbersRequest) SetPageSize(pageSize int)

param pageSize: 每页数(Optional)

func (*DescribeDeadLetterNumbersRequest) SetRegionId 

func (r *DescribeDeadLetterNumbersRequest) SetRegionId(regionId string)

param regionId: 所在区域的Region ID(Required)

type DescribeDeadLetterNumbersResponse 

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

type DescribeDeadLetterNumbersResult 

type DescribeDeadLetterNumbersResult struct {
	DeadLetterNumbers []jcq.DeadLetterNumber `json:"deadLetterNumbers"`
	TotalCount        int                    `json:"totalCount"`
}

type DescribeDeadLetterNumbersWithTopicRequest 

type DescribeDeadLetterNumbersWithTopicRequest struct {
	core.JDCloudRequest

	/* 所在区域的Region ID  */
	RegionId string `json:"regionId"`

	/* topic 名称  */
	TopicName string `json:"topicName"`

	/* consumerGroupId为空则显示该Topic下所有订阅关系里的死信数量 (Optional) */
	ConsumerGroupId *string `json:"consumerGroupId"`

	/* 页码 (Optional) */
	PageNumber *int `json:"pageNumber"`

	/* 每页数 (Optional) */
	PageSize *int `json:"pageSize"`
}

func NewDescribeDeadLetterNumbersWithTopicRequest 

func NewDescribeDeadLetterNumbersWithTopicRequest(
	regionId string,
	topicName string,
) *DescribeDeadLetterNumbersWithTopicRequest

* param regionId: 所在区域的Region ID (Required) * param topicName: topic 名称 (Required) * * @Deprecated, not compatible when mandatory parameters changed

func NewDescribeDeadLetterNumbersWithTopicRequestWithAllParams 

func NewDescribeDeadLetterNumbersWithTopicRequestWithAllParams(
	regionId string,
	topicName string,
	consumerGroupId *string,
	pageNumber *int,
	pageSize *int,
) *DescribeDeadLetterNumbersWithTopicRequest

* param regionId: 所在区域的Region ID (Required) * param topicName: topic 名称 (Required) * param consumerGroupId: consumerGroupId为空则显示该Topic下所有订阅关系里的死信数量 (Optional) * param pageNumber: 页码 (Optional) * param pageSize: 每页数 (Optional)

func NewDescribeDeadLetterNumbersWithTopicRequestWithoutParam 

func NewDescribeDeadLetterNumbersWithTopicRequestWithoutParam() *DescribeDeadLetterNumbersWithTopicRequest

This constructor has better compatible ability when API parameters changed

func (DescribeDeadLetterNumbersWithTopicRequest) GetRegionId 

func (r DescribeDeadLetterNumbersWithTopicRequest) GetRegionId() string

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

func (*DescribeDeadLetterNumbersWithTopicRequest) SetConsumerGroupId 

func (r *DescribeDeadLetterNumbersWithTopicRequest) SetConsumerGroupId(consumerGroupId string)

param consumerGroupId: consumerGroupId为空则显示该Topic下所有订阅关系里的死信数量(Optional)

func (*DescribeDeadLetterNumbersWithTopicRequest) SetPageNumber 

func (r *DescribeDeadLetterNumbersWithTopicRequest) SetPageNumber(pageNumber int)

param pageNumber: 页码(Optional)

func (*DescribeDeadLetterNumbersWithTopicRequest) SetPageSize 

func (r *DescribeDeadLetterNumbersWithTopicRequest) SetPageSize(pageSize int)

param pageSize: 每页数(Optional)

func (*DescribeDeadLetterNumbersWithTopicRequest) SetRegionId 

func (r *DescribeDeadLetterNumbersWithTopicRequest) SetRegionId(regionId string)

param regionId: 所在区域的Region ID(Required)

func (*DescribeDeadLetterNumbersWithTopicRequest) SetTopicName 

func (r *DescribeDeadLetterNumbersWithTopicRequest) SetTopicName(topicName string)

param topicName: topic 名称(Required)

type DescribeDeadLetterNumbersWithTopicResponse 

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

type DescribeDeadLetterNumbersWithTopicResult 

type DescribeDeadLetterNumbersWithTopicResult struct {
	DeadLetterNumbers []jcq.DeadLetterNumber `json:"deadLetterNumbers"`
	TotalCount        int                    `json:"totalCount"`
}

type DescribeMessageRequest 

type DescribeMessageRequest struct {
	core.JDCloudRequest

	/* 所在区域的Region ID  */
	RegionId string `json:"regionId"`

	/* topic 名称  */
	TopicName string `json:"topicName"`

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

func NewDescribeMessageRequest 

func NewDescribeMessageRequest(
	regionId string,
	topicName string,
	messageId string,
) *DescribeMessageRequest

* param regionId: 所在区域的Region ID (Required) * param topicName: topic 名称 (Required) * param messageId: message Id (Required) * * @Deprecated, not compatible when mandatory parameters changed

func NewDescribeMessageRequestWithAllParams 

func NewDescribeMessageRequestWithAllParams(
	regionId string,
	topicName string,
	messageId string,
) *DescribeMessageRequest

* param regionId: 所在区域的Region ID (Required) * param topicName: topic 名称 (Required) * param messageId: message Id (Required)

func NewDescribeMessageRequestWithoutParam 

func NewDescribeMessageRequestWithoutParam() *DescribeMessageRequest

This constructor has better compatible ability when API parameters changed

func (DescribeMessageRequest) GetRegionId 

func (r DescribeMessageRequest) GetRegionId() string

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

func (*DescribeMessageRequest) SetMessageId 

func (r *DescribeMessageRequest) SetMessageId(messageId string)

param messageId: message Id(Required)

func (*DescribeMessageRequest) SetRegionId 

func (r *DescribeMessageRequest) SetRegionId(regionId string)

param regionId: 所在区域的Region ID(Required)

func (*DescribeMessageRequest) SetTopicName 

func (r *DescribeMessageRequest) SetTopicName(topicName string)

param topicName: topic 名称(Required)

type DescribeMessageResponse 

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

type DescribeMessageResult 

type DescribeMessageResult struct {
	Message jcq.Message `json:"message"`
}

type DescribeMessagesRequest 

type DescribeMessagesRequest struct {
	core.JDCloudRequest

	/* 所在区域的Region ID  */
	RegionId string `json:"regionId"`

	/* topic 名称  */
	TopicName string `json:"topicName"`

	/* 开始时间  */
	StartTime string `json:"startTime"`

	/* 结束时间  */
	EndTime string `json:"endTime"`
}

func NewDescribeMessagesRequest 

func NewDescribeMessagesRequest(
	regionId string,
	topicName string,
	startTime string,
	endTime string,
) *DescribeMessagesRequest

* param regionId: 所在区域的Region ID (Required) * param topicName: topic 名称 (Required) * param startTime: 开始时间 (Required) * param endTime: 结束时间 (Required) * * @Deprecated, not compatible when mandatory parameters changed

func NewDescribeMessagesRequestWithAllParams 

func NewDescribeMessagesRequestWithAllParams(
	regionId string,
	topicName string,
	startTime string,
	endTime string,
) *DescribeMessagesRequest

* param regionId: 所在区域的Region ID (Required) * param topicName: topic 名称 (Required) * param startTime: 开始时间 (Required) * param endTime: 结束时间 (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) SetEndTime 

func (r *DescribeMessagesRequest) SetEndTime(endTime string)

param endTime: 结束时间(Required)

func (*DescribeMessagesRequest) SetRegionId 

func (r *DescribeMessagesRequest) SetRegionId(regionId string)

param regionId: 所在区域的Region ID(Required)

func (*DescribeMessagesRequest) SetStartTime 

func (r *DescribeMessagesRequest) SetStartTime(startTime string)

param startTime: 开始时间(Required)

func (*DescribeMessagesRequest) SetTopicName 

func (r *DescribeMessagesRequest) SetTopicName(topicName string)

param topicName: 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 {
	Messages []jcq.Message `json:"messages"`
}

type DescribePermissionRequest 

type DescribePermissionRequest struct {
	core.JDCloudRequest

	/* 所在区域的Region ID  */
	RegionId string `json:"regionId"`

	/* topic 名称  */
	TopicName string `json:"topicName"`
}

func NewDescribePermissionRequest 

func NewDescribePermissionRequest(
	regionId string,
	topicName string,
) *DescribePermissionRequest

* param regionId: 所在区域的Region ID (Required) * param topicName: topic 名称 (Required) * * @Deprecated, not compatible when mandatory parameters changed

func NewDescribePermissionRequestWithAllParams 

func NewDescribePermissionRequestWithAllParams(
	regionId string,
	topicName string,
) *DescribePermissionRequest

* param regionId: 所在区域的Region ID (Required) * param topicName: topic 名称 (Required)

func NewDescribePermissionRequestWithoutParam 

func NewDescribePermissionRequestWithoutParam() *DescribePermissionRequest

This constructor has better compatible ability when API parameters changed

func (DescribePermissionRequest) GetRegionId 

func (r DescribePermissionRequest) GetRegionId() string

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

func (*DescribePermissionRequest) SetRegionId 

func (r *DescribePermissionRequest) SetRegionId(regionId string)

param regionId: 所在区域的Region ID(Required)

func (*DescribePermissionRequest) SetTopicName 

func (r *DescribePermissionRequest) SetTopicName(topicName string)

param topicName: topic 名称(Required)

type DescribePermissionResponse 

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

type DescribePermissionResult 

type DescribePermissionResult struct {
	Permissions []jcq.Permission `json:"permissions"`
}

type DescribeSubscriptionRequest 

type DescribeSubscriptionRequest struct {
	core.JDCloudRequest

	/* 所在区域的Region ID  */
	RegionId string `json:"regionId"`

	/* topic 名称  */
	TopicName string `json:"topicName"`

	/* consumerGroupId  */
	ConsumerGroupId string `json:"consumerGroupId"`
}

func NewDescribeSubscriptionRequest 

func NewDescribeSubscriptionRequest(
	regionId string,
	topicName string,
	consumerGroupId string,
) *DescribeSubscriptionRequest

* param regionId: 所在区域的Region ID (Required) * param topicName: topic 名称 (Required) * param consumerGroupId: consumerGroupId (Required) * * @Deprecated, not compatible when mandatory parameters changed

func NewDescribeSubscriptionRequestWithAllParams 

func NewDescribeSubscriptionRequestWithAllParams(
	regionId string,
	topicName string,
	consumerGroupId string,
) *DescribeSubscriptionRequest

* param regionId: 所在区域的Region ID (Required) * param topicName: topic 名称 (Required) * param consumerGroupId: consumerGroupId (Required)

func NewDescribeSubscriptionRequestWithoutParam 

func NewDescribeSubscriptionRequestWithoutParam() *DescribeSubscriptionRequest

This constructor has better compatible ability when API parameters changed

func (DescribeSubscriptionRequest) GetRegionId 

func (r DescribeSubscriptionRequest) GetRegionId() string

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

func (*DescribeSubscriptionRequest) SetConsumerGroupId 

func (r *DescribeSubscriptionRequest) SetConsumerGroupId(consumerGroupId string)

param consumerGroupId: consumerGroupId(Required)

func (*DescribeSubscriptionRequest) SetRegionId 

func (r *DescribeSubscriptionRequest) SetRegionId(regionId string)

param regionId: 所在区域的Region ID(Required)

func (*DescribeSubscriptionRequest) SetTopicName 

func (r *DescribeSubscriptionRequest) SetTopicName(topicName string)

param topicName: topic 名称(Required)

type DescribeSubscriptionResponse 

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

type DescribeSubscriptionResult 

type DescribeSubscriptionResult struct {
	Subscription jcq.Subscription `json:"subscription"`
}

type DescribeSubscriptionsRequest 

type DescribeSubscriptionsRequest struct {
	core.JDCloudRequest

	/* 所在区域的Region ID  */
	RegionId string `json:"regionId"`

	/* topic 名称  */
	TopicName string `json:"topicName"`

	/* consumerGroupFilter，consumerGroupId的过滤条件 (Optional) */
	ConsumerGroupFilter *string `json:"consumerGroupFilter"`

	/* 分页之中的每页大小 (Optional) */
	PageSize *int `json:"pageSize"`

	/* 分页之中的页码 (Optional) */
	PageNumber *int `json:"pageNumber"`
}

func NewDescribeSubscriptionsRequest 

func NewDescribeSubscriptionsRequest(
	regionId string,
	topicName string,
) *DescribeSubscriptionsRequest

* param regionId: 所在区域的Region ID (Required) * param topicName: topic 名称 (Required) * * @Deprecated, not compatible when mandatory parameters changed

func NewDescribeSubscriptionsRequestWithAllParams 

func NewDescribeSubscriptionsRequestWithAllParams(
	regionId string,
	topicName string,
	consumerGroupFilter *string,
	pageSize *int,
	pageNumber *int,
) *DescribeSubscriptionsRequest

* param regionId: 所在区域的Region ID (Required) * param topicName: topic 名称 (Required) * param consumerGroupFilter: consumerGroupFilter，consumerGroupId的过滤条件 (Optional) * param pageSize: 分页之中的每页大小 (Optional) * param pageNumber: 分页之中的页码 (Optional)

func NewDescribeSubscriptionsRequestWithoutParam 

func NewDescribeSubscriptionsRequestWithoutParam() *DescribeSubscriptionsRequest

This constructor has better compatible ability when API parameters changed

func (DescribeSubscriptionsRequest) GetRegionId 

func (r DescribeSubscriptionsRequest) GetRegionId() string

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

func (*DescribeSubscriptionsRequest) SetConsumerGroupFilter 

func (r *DescribeSubscriptionsRequest) SetConsumerGroupFilter(consumerGroupFilter string)

param consumerGroupFilter: consumerGroupFilter，consumerGroupId的过滤条件(Optional)

func (*DescribeSubscriptionsRequest) SetPageNumber 

func (r *DescribeSubscriptionsRequest) SetPageNumber(pageNumber int)

param pageNumber: 分页之中的页码(Optional)

func (*DescribeSubscriptionsRequest) SetPageSize 

func (r *DescribeSubscriptionsRequest) SetPageSize(pageSize int)

param pageSize: 分页之中的每页大小(Optional)

func (*DescribeSubscriptionsRequest) SetRegionId 

func (r *DescribeSubscriptionsRequest) SetRegionId(regionId string)

param regionId: 所在区域的Region ID(Required)

func (*DescribeSubscriptionsRequest) SetTopicName 

func (r *DescribeSubscriptionsRequest) SetTopicName(topicName string)

param topicName: topic 名称(Required)

type DescribeSubscriptionsResponse 

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

type DescribeSubscriptionsResult 

type DescribeSubscriptionsResult struct {
	Subscriptions []jcq.Subscription `json:"subscriptions"`
	TotalCount    int                `json:"totalCount"`
}

type DescribeTopicRequest 

type DescribeTopicRequest struct {
	core.JDCloudRequest

	/* 所在区域的Region ID  */
	RegionId string `json:"regionId"`

	/* topic 名称  */
	TopicName string `json:"topicName"`
}

func NewDescribeTopicRequest 

func NewDescribeTopicRequest(
	regionId string,
	topicName string,
) *DescribeTopicRequest

* param regionId: 所在区域的Region ID (Required) * param topicName: topic 名称 (Required) * * @Deprecated, not compatible when mandatory parameters changed

func NewDescribeTopicRequestWithAllParams 

func NewDescribeTopicRequestWithAllParams(
	regionId string,
	topicName string,
) *DescribeTopicRequest

* param regionId: 所在区域的Region ID (Required) * param topicName: 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) SetRegionId 

func (r *DescribeTopicRequest) SetRegionId(regionId string)

param regionId: 所在区域的Region ID(Required)

func (*DescribeTopicRequest) SetTopicName 

func (r *DescribeTopicRequest) SetTopicName(topicName string)

param topicName: 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 jcq.Topic `json:"topic"`
}

type DescribeTopicsRequest 

type DescribeTopicsRequest struct {
	core.JDCloudRequest

	/* 所在区域的Region ID  */
	RegionId string `json:"regionId"`

	/* 分页之中的每页大小 (Optional) */
	PageSize *int `json:"pageSize"`

	/* 分页之中的页码 (Optional) */
	PageNumber *int `json:"pageNumber"`

	/* topic名称的过滤条件，大小写不敏感 (Optional) */
	TopicFilter *string `json:"topicFilter"`

	/* 标签过滤条件 (Optional) */
	TagFilters []common.TagFilter `json:"tagFilters"`
}

func NewDescribeTopicsRequest 

func NewDescribeTopicsRequest(
	regionId string,
) *DescribeTopicsRequest

* param regionId: 所在区域的Region ID (Required) * * @Deprecated, not compatible when mandatory parameters changed

func NewDescribeTopicsRequestWithAllParams 

func NewDescribeTopicsRequestWithAllParams(
	regionId string,
	pageSize *int,
	pageNumber *int,
	topicFilter *string,
	tagFilters []common.TagFilter,
) *DescribeTopicsRequest

* param regionId: 所在区域的Region ID (Required) * param pageSize: 分页之中的每页大小 (Optional) * param pageNumber: 分页之中的页码 (Optional) * param topicFilter: topic名称的过滤条件，大小写不敏感 (Optional) * param tagFilters: 标签过滤条件 (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) SetPageNumber 

func (r *DescribeTopicsRequest) SetPageNumber(pageNumber int)

param pageNumber: 分页之中的页码(Optional)

func (*DescribeTopicsRequest) SetPageSize 

func (r *DescribeTopicsRequest) SetPageSize(pageSize int)

param pageSize: 分页之中的每页大小(Optional)

func (*DescribeTopicsRequest) SetRegionId 

func (r *DescribeTopicsRequest) SetRegionId(regionId string)

param regionId: 所在区域的Region ID(Required)

func (*DescribeTopicsRequest) SetTagFilters 

func (r *DescribeTopicsRequest) SetTagFilters(tagFilters []common.TagFilter)

param tagFilters: 标签过滤条件(Optional)

func (*DescribeTopicsRequest) SetTopicFilter 

func (r *DescribeTopicsRequest) SetTopicFilter(topicFilter string)

param topicFilter: 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 {
	Topics     []jcq.Topic `json:"topics"`
	TotalCount int         `json:"totalCount"`
}

type ListDeadLettersRequest 

type ListDeadLettersRequest struct {
	core.JDCloudRequest

	/* 所在区域的Region ID  */
	RegionId string `json:"regionId"`

	/* topic 名称  */
	TopicName string `json:"topicName"`

	/* consumerGroupId  */
	ConsumerGroupId string `json:"consumerGroupId"`

	/* 页码；默认为1 (Optional) */
	PageNumber *int `json:"pageNumber"`

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

	/* 开始时间  */
	StartTime string `json:"startTime"`

	/* 结束时间  */
	EndTime string `json:"endTime"`
}

func NewListDeadLettersRequest 

func NewListDeadLettersRequest(
	regionId string,
	topicName string,
	consumerGroupId string,
	startTime string,
	endTime string,
) *ListDeadLettersRequest

* param regionId: 所在区域的Region ID (Required) * param topicName: topic 名称 (Required) * param consumerGroupId: consumerGroupId (Required) * param startTime: 开始时间 (Required) * param endTime: 结束时间 (Required) * * @Deprecated, not compatible when mandatory parameters changed

func NewListDeadLettersRequestWithAllParams 

func NewListDeadLettersRequestWithAllParams(
	regionId string,
	topicName string,
	consumerGroupId string,
	pageNumber *int,
	pageSize *int,
	startTime string,
	endTime string,
) *ListDeadLettersRequest

* param regionId: 所在区域的Region ID (Required) * param topicName: topic 名称 (Required) * param consumerGroupId: consumerGroupId (Required) * param pageNumber: 页码；默认为1 (Optional) * param pageSize: 分页大小；默认为20；取值范围[10, 100] (Optional) * param startTime: 开始时间 (Required) * param endTime: 结束时间 (Required)

func NewListDeadLettersRequestWithoutParam 

func NewListDeadLettersRequestWithoutParam() *ListDeadLettersRequest

This constructor has better compatible ability when API parameters changed

func (ListDeadLettersRequest) GetRegionId 

func (r ListDeadLettersRequest) GetRegionId() string

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

func (*ListDeadLettersRequest) SetConsumerGroupId 

func (r *ListDeadLettersRequest) SetConsumerGroupId(consumerGroupId string)

param consumerGroupId: consumerGroupId(Required)

func (*ListDeadLettersRequest) SetEndTime 

func (r *ListDeadLettersRequest) SetEndTime(endTime string)

param endTime: 结束时间(Required)

func (*ListDeadLettersRequest) SetPageNumber 

func (r *ListDeadLettersRequest) SetPageNumber(pageNumber int)

param pageNumber: 页码；默认为1(Optional)

func (*ListDeadLettersRequest) SetPageSize 

func (r *ListDeadLettersRequest) SetPageSize(pageSize int)

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

func (*ListDeadLettersRequest) SetRegionId 

func (r *ListDeadLettersRequest) SetRegionId(regionId string)

param regionId: 所在区域的Region ID(Required)

func (*ListDeadLettersRequest) SetStartTime 

func (r *ListDeadLettersRequest) SetStartTime(startTime string)

param startTime: 开始时间(Required)

func (*ListDeadLettersRequest) SetTopicName 

func (r *ListDeadLettersRequest) SetTopicName(topicName string)

param topicName: topic 名称(Required)

type ListDeadLettersResponse 

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

type ListDeadLettersResult 

type ListDeadLettersResult struct {
	DeadLetters []jcq.DeadLetter `json:"deadLetters"`
	TotalCount  int              `json:"totalCount"`
}

type RemovePermissionRequest 

type RemovePermissionRequest struct {
	core.JDCloudRequest

	/* 所在区域的Region ID  */
	RegionId string `json:"regionId"`

	/* topic 名称  */
	TopicName string `json:"topicName"`

	/* 权限类型, [PUB, SUB, PUBSUB]  */
	Permission string `json:"permission"`

	/* 目标用户UserId  */
	TargetUserId string `json:"targetUserId"`
}

func NewRemovePermissionRequest 

func NewRemovePermissionRequest(
	regionId string,
	topicName string,
	permission string,
	targetUserId string,
) *RemovePermissionRequest

* param regionId: 所在区域的Region ID (Required) * param topicName: topic 名称 (Required) * param permission: 权限类型, [PUB, SUB, PUBSUB] (Required) * param targetUserId: 目标用户UserId (Required) * * @Deprecated, not compatible when mandatory parameters changed

func NewRemovePermissionRequestWithAllParams 

func NewRemovePermissionRequestWithAllParams(
	regionId string,
	topicName string,
	permission string,
	targetUserId string,
) *RemovePermissionRequest

* param regionId: 所在区域的Region ID (Required) * param topicName: topic 名称 (Required) * param permission: 权限类型, [PUB, SUB, PUBSUB] (Required) * param targetUserId: 目标用户UserId (Required)

func NewRemovePermissionRequestWithoutParam 

func NewRemovePermissionRequestWithoutParam() *RemovePermissionRequest

This constructor has better compatible ability when API parameters changed

func (RemovePermissionRequest) GetRegionId 

func (r RemovePermissionRequest) GetRegionId() string

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

func (*RemovePermissionRequest) SetPermission 

func (r *RemovePermissionRequest) SetPermission(permission string)

param permission: 权限类型, [PUB, SUB, PUBSUB](Required)

func (*RemovePermissionRequest) SetRegionId 

func (r *RemovePermissionRequest) SetRegionId(regionId string)

param regionId: 所在区域的Region ID(Required)

func (*RemovePermissionRequest) SetTargetUserId 

func (r *RemovePermissionRequest) SetTargetUserId(targetUserId string)

param targetUserId: 目标用户UserId(Required)

func (*RemovePermissionRequest) SetTopicName 

func (r *RemovePermissionRequest) SetTopicName(topicName string)

param topicName: topic 名称(Required)

type RemovePermissionResponse 

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

type RemovePermissionResult 

type RemovePermissionResult struct {
}

type ResendDeadLettersRequest 

type ResendDeadLettersRequest struct {
	core.JDCloudRequest

	/* 所在区域的Region ID  */
	RegionId string `json:"regionId"`

	/* topic 名称  */
	TopicName string `json:"topicName"`

	/* consumerGroupId  */
	ConsumerGroupId string `json:"consumerGroupId"`

	/* messageIds,多个逗号隔开，不传该值就是重发所有死信 (Optional) */
	MessageIds *string `json:"messageIds"`
}

func NewResendDeadLettersRequest 

func NewResendDeadLettersRequest(
	regionId string,
	topicName string,
	consumerGroupId string,
) *ResendDeadLettersRequest

* param regionId: 所在区域的Region ID (Required) * param topicName: topic 名称 (Required) * param consumerGroupId: consumerGroupId (Required) * * @Deprecated, not compatible when mandatory parameters changed

func NewResendDeadLettersRequestWithAllParams 

func NewResendDeadLettersRequestWithAllParams(
	regionId string,
	topicName string,
	consumerGroupId string,
	messageIds *string,
) *ResendDeadLettersRequest

* param regionId: 所在区域的Region ID (Required) * param topicName: topic 名称 (Required) * param consumerGroupId: consumerGroupId (Required) * param messageIds: messageIds,多个逗号隔开，不传该值就是重发所有死信 (Optional)

func NewResendDeadLettersRequestWithoutParam 

func NewResendDeadLettersRequestWithoutParam() *ResendDeadLettersRequest

This constructor has better compatible ability when API parameters changed

func (ResendDeadLettersRequest) GetRegionId 

func (r ResendDeadLettersRequest) GetRegionId() string

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

func (*ResendDeadLettersRequest) SetConsumerGroupId 

func (r *ResendDeadLettersRequest) SetConsumerGroupId(consumerGroupId string)

param consumerGroupId: consumerGroupId(Required)

func (*ResendDeadLettersRequest) SetMessageIds 

func (r *ResendDeadLettersRequest) SetMessageIds(messageIds string)

param messageIds: messageIds,多个逗号隔开，不传该值就是重发所有死信(Optional)

func (*ResendDeadLettersRequest) SetRegionId 

func (r *ResendDeadLettersRequest) SetRegionId(regionId string)

param regionId: 所在区域的Region ID(Required)

func (*ResendDeadLettersRequest) SetTopicName 

func (r *ResendDeadLettersRequest) SetTopicName(topicName string)

param topicName: topic 名称(Required)

type ResendDeadLettersResponse 

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

type ResendDeadLettersResult 

type ResendDeadLettersResult struct {
	MessageIds []string `json:"messageIds"`
}

type ResetConsumeOffsetRequest 

type ResetConsumeOffsetRequest struct {
	core.JDCloudRequest

	/* 所在区域的Region ID  */
	RegionId string `json:"regionId"`

	/* topic 名称  */
	TopicName string `json:"topicName"`

	/* consumerGroupId  */
	ConsumerGroupId string `json:"consumerGroupId"`

	/* 时间  */
	Time string `json:"time"`
}

func NewResetConsumeOffsetRequest 

func NewResetConsumeOffsetRequest(
	regionId string,
	topicName string,
	consumerGroupId string,
	time string,
) *ResetConsumeOffsetRequest

* param regionId: 所在区域的Region ID (Required) * param topicName: topic 名称 (Required) * param consumerGroupId: consumerGroupId (Required) * param time: 时间 (Required) * * @Deprecated, not compatible when mandatory parameters changed

func NewResetConsumeOffsetRequestWithAllParams 

func NewResetConsumeOffsetRequestWithAllParams(
	regionId string,
	topicName string,
	consumerGroupId string,
	time string,
) *ResetConsumeOffsetRequest

* param regionId: 所在区域的Region ID (Required) * param topicName: topic 名称 (Required) * param consumerGroupId: consumerGroupId (Required) * param time: 时间 (Required)

func NewResetConsumeOffsetRequestWithoutParam 

func NewResetConsumeOffsetRequestWithoutParam() *ResetConsumeOffsetRequest

This constructor has better compatible ability when API parameters changed

func (ResetConsumeOffsetRequest) GetRegionId 

func (r ResetConsumeOffsetRequest) GetRegionId() string

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

func (*ResetConsumeOffsetRequest) SetConsumerGroupId 

func (r *ResetConsumeOffsetRequest) SetConsumerGroupId(consumerGroupId string)

param consumerGroupId: consumerGroupId(Required)

func (*ResetConsumeOffsetRequest) SetRegionId 

func (r *ResetConsumeOffsetRequest) SetRegionId(regionId string)

param regionId: 所在区域的Region ID(Required)

func (*ResetConsumeOffsetRequest) SetTime 

func (r *ResetConsumeOffsetRequest) SetTime(time string)

param time: 时间(Required)

func (*ResetConsumeOffsetRequest) SetTopicName 

func (r *ResetConsumeOffsetRequest) SetTopicName(topicName string)

param topicName: topic 名称(Required)

type ResetConsumeOffsetResponse 

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

type ResetConsumeOffsetResult 

type ResetConsumeOffsetResult struct {
}

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.