apis

package
v1.5.0 Latest Latest
Warning

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

Go to latest
Published: Feb 14, 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

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 {
}

Jump to

Keyboard shortcuts

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