v2

package
v0.1.3 Latest Latest
Warning

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

 Go to latest Published: Sep 22, 2022 License: Apache-2.0, BSD-2-Clause, BSD-3-Clause Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func DmsClientBuilder 

func DmsClientBuilder() *http_client.HcHttpClientBuilder

func GenReqDefForBatchCreateOrDeleteQueueTag 

func GenReqDefForBatchCreateOrDeleteQueueTag() *def.HttpRequestDef

func GenReqDefForConfirmConsumptionMessages 

func GenReqDefForConfirmConsumptionMessages() *def.HttpRequestDef

func GenReqDefForConfirmDeadLettersMessages 

func GenReqDefForConfirmDeadLettersMessages() *def.HttpRequestDef

func GenReqDefForConsumeDeadlettersMessage 

func GenReqDefForConsumeDeadlettersMessage() *def.HttpRequestDef

func GenReqDefForConsumeMessages 

func GenReqDefForConsumeMessages() *def.HttpRequestDef

func GenReqDefForCreateConsumerGroup 

func GenReqDefForCreateConsumerGroup() *def.HttpRequestDef

func GenReqDefForCreateQueue 

func GenReqDefForCreateQueue() *def.HttpRequestDef

func GenReqDefForDeleteQueue 

func GenReqDefForDeleteQueue() *def.HttpRequestDef

func GenReqDefForDeleteSpecifiedConsumerGroup 

func GenReqDefForDeleteSpecifiedConsumerGroup() *def.HttpRequestDef

func GenReqDefForListConsumerGroups 

func GenReqDefForListConsumerGroups() *def.HttpRequestDef

func GenReqDefForListQueues 

func GenReqDefForListQueues() *def.HttpRequestDef

func GenReqDefForSendMessages 

func GenReqDefForSendMessages() *def.HttpRequestDef

func GenReqDefForShowQueue 

func GenReqDefForShowQueue() *def.HttpRequestDef

func GenReqDefForShowQueueProjectTags 

func GenReqDefForShowQueueProjectTags() *def.HttpRequestDef

func GenReqDefForShowQueueTags 

func GenReqDefForShowQueueTags() *def.HttpRequestDef

func GenReqDefForShowQuotas 

func GenReqDefForShowQuotas() *def.HttpRequestDef

Types

type BatchCreateOrDeleteQueueTagInvoker added in v0.0.90 

type BatchCreateOrDeleteQueueTagInvoker struct {
	*invoker.BaseInvoker
}

func (*BatchCreateOrDeleteQueueTagInvoker) Invoke added in v0.0.90 

func (i *BatchCreateOrDeleteQueueTagInvoker) Invoke() (*model.BatchCreateOrDeleteQueueTagResponse, error)

type ConfirmConsumptionMessagesInvoker added in v0.0.90 

type ConfirmConsumptionMessagesInvoker struct {
	*invoker.BaseInvoker
}

func (*ConfirmConsumptionMessagesInvoker) Invoke added in v0.0.90 

func (i *ConfirmConsumptionMessagesInvoker) Invoke() (*model.ConfirmConsumptionMessagesResponse, error)

type ConfirmDeadLettersMessagesInvoker added in v0.0.90 

type ConfirmDeadLettersMessagesInvoker struct {
	*invoker.BaseInvoker
}

func (*ConfirmDeadLettersMessagesInvoker) Invoke added in v0.0.90 

func (i *ConfirmDeadLettersMessagesInvoker) Invoke() (*model.ConfirmDeadLettersMessagesResponse, error)

type ConsumeDeadlettersMessageInvoker added in v0.0.90 

type ConsumeDeadlettersMessageInvoker struct {
	*invoker.BaseInvoker
}

func (*ConsumeDeadlettersMessageInvoker) Invoke added in v0.0.90 

func (i *ConsumeDeadlettersMessageInvoker) Invoke() (*model.ConsumeDeadlettersMessageResponse, error)

type ConsumeMessagesInvoker added in v0.0.90 

type ConsumeMessagesInvoker struct {
	*invoker.BaseInvoker
}

func (*ConsumeMessagesInvoker) Invoke added in v0.0.90 

func (i *ConsumeMessagesInvoker) Invoke() (*model.ConsumeMessagesResponse, error)

type CreateConsumerGroupInvoker added in v0.0.90 

type CreateConsumerGroupInvoker struct {
	*invoker.BaseInvoker
}

func (*CreateConsumerGroupInvoker) Invoke added in v0.0.90 

func (i *CreateConsumerGroupInvoker) Invoke() (*model.CreateConsumerGroupResponse, error)

type CreateQueueInvoker added in v0.0.90 

type CreateQueueInvoker struct {
	*invoker.BaseInvoker
}

func (*CreateQueueInvoker) Invoke added in v0.0.90 

func (i *CreateQueueInvoker) Invoke() (*model.CreateQueueResponse, error)

type DeleteQueueInvoker added in v0.0.90 

type DeleteQueueInvoker struct {
	*invoker.BaseInvoker
}

func (*DeleteQueueInvoker) Invoke added in v0.0.90 

func (i *DeleteQueueInvoker) Invoke() (*model.DeleteQueueResponse, error)

type DeleteSpecifiedConsumerGroupInvoker added in v0.0.90 

type DeleteSpecifiedConsumerGroupInvoker struct {
	*invoker.BaseInvoker
}

func (*DeleteSpecifiedConsumerGroupInvoker) Invoke added in v0.0.90 

func (i *DeleteSpecifiedConsumerGroupInvoker) Invoke() (*model.DeleteSpecifiedConsumerGroupResponse, error)

type DmsClient 

type DmsClient struct {
	HcClient *http_client.HcHttpClient
}

func NewDmsClient 

func NewDmsClient(hcClient *http_client.HcHttpClient) *DmsClient

func (*DmsClient) BatchCreateOrDeleteQueueTag 

func (c *DmsClient) BatchCreateOrDeleteQueueTag(request *model.BatchCreateOrDeleteQueueTagRequest) (*model.BatchCreateOrDeleteQueueTagResponse, error)

BatchCreateOrDeleteQueueTag 批量添加或删除队列标签

批量添加或删除队列标签。

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*DmsClient) BatchCreateOrDeleteQueueTagInvoker added in v0.0.90 

func (c *DmsClient) BatchCreateOrDeleteQueueTagInvoker(request *model.BatchCreateOrDeleteQueueTagRequest) *BatchCreateOrDeleteQueueTagInvoker

BatchCreateOrDeleteQueueTagInvoker 批量添加或删除队列标签

func (*DmsClient) ConfirmConsumptionMessages 

func (c *DmsClient) ConfirmConsumptionMessages(request *model.ConfirmConsumptionMessagesRequest) (*model.ConfirmConsumptionMessagesResponse, error)

ConfirmConsumptionMessages 确认已消费指定消息

确认已经消费指定消息。

在消费者消费消息期间，消息仍然停留在队列中，但消息从被消费开始的30秒内不能被该消费组再次消费，若在这30秒内没有被消费者确认消费，则DMS认为消息未消费成功，将可以被继续消费。

如果消息被确认消费成功，消息将不能被该消费组再次消费，但是消息仍然保持在队列中，并且可以被其它消费组消费，消息在队列中的保留时间默认为72小时（除非队列被删除），72小时后会被删除。

消息批量消费确认时，必须严格按照消息消费的顺序提交确认，DMS按顺序判定消息是否消费成功，如果某条消息未确认或消费失败，则不再继续检测，默认后续消息全部消费失败。建议当对某一条消息处理失败时，不再需要继续处理本批消息中的后续消息，直接对已正确处理的消息进行确认。

确认消费失败后，可以再次重新消费和确认。当开启死信时，消息进行多次重复消费仍然失败后，DMS会将该条消息转存到死信队列中，有效期为72小时，用户可以根据需要对死信消息进行重新消费。

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*DmsClient) ConfirmConsumptionMessagesInvoker added in v0.0.90 

func (c *DmsClient) ConfirmConsumptionMessagesInvoker(request *model.ConfirmConsumptionMessagesRequest) *ConfirmConsumptionMessagesInvoker

ConfirmConsumptionMessagesInvoker 确认已消费指定消息

func (*DmsClient) ConfirmDeadLettersMessages 

func (c *DmsClient) ConfirmDeadLettersMessages(request *model.ConfirmDeadLettersMessagesRequest) (*model.ConfirmDeadLettersMessagesResponse, error)

ConfirmDeadLettersMessages 确认已消费死信消息

确认已经消费指定的死信消息。

在消费者消费死信消息期间，死信消息仍然停留在队列中，但死信消息从被消费开始的30秒内不能被该消费组再次消费，若在这30秒内没有被消费者确认消费，则DMS认为死信消息未消费成功，将可以被继续消费。

如果死信消息被确认消费成功，该死信消息将不能被该消费组再次消费，死信消息的保留时间为72小时（除非消费组被删除），72小时后会被删除。

消息批量消费确认时，必须严格按照消息消费的顺序提交确认，DMS按顺序判定消息是否消费成功，如果某条消息未确认或消费失败，则不再继续检测，默认后续消息全部消费失败。建议当对某一条消息处理失败时，不再需要继续处理本批消息中的后续消息，直接对已正确处理的消息进行确认。

仅NORMAL队列和FIFO队列可以开启死信消息，因为只有NORMAL队列和FIFO队列可消费死信消息。

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*DmsClient) ConfirmDeadLettersMessagesInvoker added in v0.0.90 

func (c *DmsClient) ConfirmDeadLettersMessagesInvoker(request *model.ConfirmDeadLettersMessagesRequest) *ConfirmDeadLettersMessagesInvoker

ConfirmDeadLettersMessagesInvoker 确认已消费死信消息

func (*DmsClient) ConsumeDeadlettersMessage 

func (c *DmsClient) ConsumeDeadlettersMessage(request *model.ConsumeDeadlettersMessageRequest) (*model.ConsumeDeadlettersMessageResponse, error)

ConsumeDeadlettersMessage 消费死信消息

消费指定消费组产生的死信消息。可同时消费多条消息，每次消费的消息负载不超过512KB。

仅NORMAL队列和FIFO队列可以开启死信消息，因为只有NORMAL队列和FIFO队列可消费死信消息。

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*DmsClient) ConsumeDeadlettersMessageInvoker added in v0.0.90 

func (c *DmsClient) ConsumeDeadlettersMessageInvoker(request *model.ConsumeDeadlettersMessageRequest) *ConsumeDeadlettersMessageInvoker

ConsumeDeadlettersMessageInvoker 消费死信消息

func (*DmsClient) ConsumeMessages 

func (c *DmsClient) ConsumeMessages(request *model.ConsumeMessagesRequest) (*model.ConsumeMessagesResponse, error)

ConsumeMessages 消费消息

消费指定队列中的消息。可同时消费多条消息，每次消费的消息负载不超过512KB。

当队列中消息较少时，单次消费返回的消息数量可能会少于指定条数，但多次消费最终可获取全部消息，当队列为空时，返回为空。

每个消费组只支持一种Label规则，如果第二次消费更换了Label规则，则消费失败。

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*DmsClient) ConsumeMessagesInvoker added in v0.0.90 

func (c *DmsClient) ConsumeMessagesInvoker(request *model.ConsumeMessagesRequest) *ConsumeMessagesInvoker

ConsumeMessagesInvoker 消费消息

func (*DmsClient) CreateConsumerGroup 

func (c *DmsClient) CreateConsumerGroup(request *model.CreateConsumerGroupRequest) (*model.CreateConsumerGroupResponse, error)

CreateConsumerGroup 创建消费组

创建消费组。

可同时为指定队列创建多个消费组。

> 创建消费组后系统内部完成初始化需要1-3秒，如果创建消费组后立即进行操作，可能会导致消费失败。建议3秒后再操作该队列。

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*DmsClient) CreateConsumerGroupInvoker added in v0.0.90 

func (c *DmsClient) CreateConsumerGroupInvoker(request *model.CreateConsumerGroupRequest) *CreateConsumerGroupInvoker

CreateConsumerGroupInvoker 创建消费组

func (*DmsClient) CreateQueue 

func (c *DmsClient) CreateQueue(request *model.CreateQueueRequest) (*model.CreateQueueResponse, error)

CreateQueue 创建队列

每个project_id默认只能创建30个队列。 > 创建队列时系统内部完成初始化需要1-3秒，如果创建队列后立即进行操作，可能会导致生产消息、消费消息、查询队列详情、创建消费组和删除队列等操作失败。建议3秒后再操作该队列。

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*DmsClient) CreateQueueInvoker added in v0.0.90 

func (c *DmsClient) CreateQueueInvoker(request *model.CreateQueueRequest) *CreateQueueInvoker

CreateQueueInvoker 创建队列

func (*DmsClient) DeleteQueue 

func (c *DmsClient) DeleteQueue(request *model.DeleteQueueRequest) (*model.DeleteQueueResponse, error)

DeleteQueue 删除指定队列

删除指定的队列。

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*DmsClient) DeleteQueueInvoker added in v0.0.90 

func (c *DmsClient) DeleteQueueInvoker(request *model.DeleteQueueRequest) *DeleteQueueInvoker

DeleteQueueInvoker 删除指定队列

func (*DmsClient) DeleteSpecifiedConsumerGroup 

func (c *DmsClient) DeleteSpecifiedConsumerGroup(request *model.DeleteSpecifiedConsumerGroupRequest) (*model.DeleteSpecifiedConsumerGroupResponse, error)

DeleteSpecifiedConsumerGroup 删除指定消费组

删除指定消费组。

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*DmsClient) DeleteSpecifiedConsumerGroupInvoker added in v0.0.90 

func (c *DmsClient) DeleteSpecifiedConsumerGroupInvoker(request *model.DeleteSpecifiedConsumerGroupRequest) *DeleteSpecifiedConsumerGroupInvoker

DeleteSpecifiedConsumerGroupInvoker 删除指定消费组

func (*DmsClient) ListConsumerGroups 

func (c *DmsClient) ListConsumerGroups(request *model.ListConsumerGroupsRequest) (*model.ListConsumerGroupsResponse, error)

ListConsumerGroups 查看指定队列的所有消费组

获取指定队列的所有消费组。

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*DmsClient) ListConsumerGroupsInvoker added in v0.0.90 

func (c *DmsClient) ListConsumerGroupsInvoker(request *model.ListConsumerGroupsRequest) *ListConsumerGroupsInvoker

ListConsumerGroupsInvoker 查看指定队列的所有消费组

func (*DmsClient) ListQueues 

func (c *DmsClient) ListQueues(request *model.ListQueuesRequest) (*model.ListQueuesResponse, error)

ListQueues 查看所有队列

查看所有队列。

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*DmsClient) ListQueuesInvoker added in v0.0.90 

func (c *DmsClient) ListQueuesInvoker(request *model.ListQueuesRequest) *ListQueuesInvoker

ListQueuesInvoker 查看所有队列

func (*DmsClient) SendMessages 

func (c *DmsClient) SendMessages(request *model.SendMessagesRequest) (*model.SendMessagesResponse, error)

SendMessages 向指定队列发送消息

向指定队列发送消息，可同时发送多条消息。

- 每次最多发送10条。 - 每次发送的消息总负载不超过512KB。 - Kafka队列的消息保存时间在创建队列时可以设置，可设置范围为1~72小时。其他队列的消息最大保存时长为72小时。

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*DmsClient) SendMessagesInvoker added in v0.0.90 

func (c *DmsClient) SendMessagesInvoker(request *model.SendMessagesRequest) *SendMessagesInvoker

SendMessagesInvoker 向指定队列发送消息

func (*DmsClient) ShowQueue 

func (c *DmsClient) ShowQueue(request *model.ShowQueueRequest) (*model.ShowQueueResponse, error)

ShowQueue 查看指定队列

查看指定的队列。

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*DmsClient) ShowQueueInvoker added in v0.0.90 

func (c *DmsClient) ShowQueueInvoker(request *model.ShowQueueRequest) *ShowQueueInvoker

ShowQueueInvoker 查看指定队列

func (*DmsClient) ShowQueueProjectTags 

func (c *DmsClient) ShowQueueProjectTags(request *model.ShowQueueProjectTagsRequest) (*model.ShowQueueProjectTagsResponse, error)

ShowQueueProjectTags 查询项目标签

查询项目标签。

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*DmsClient) ShowQueueProjectTagsInvoker added in v0.0.90 

func (c *DmsClient) ShowQueueProjectTagsInvoker(request *model.ShowQueueProjectTagsRequest) *ShowQueueProjectTagsInvoker

ShowQueueProjectTagsInvoker 查询项目标签

func (*DmsClient) ShowQueueTags 

func (c *DmsClient) ShowQueueTags(request *model.ShowQueueTagsRequest) (*model.ShowQueueTagsResponse, error)

ShowQueueTags 查询队列标签

查询队列标签。

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*DmsClient) ShowQueueTagsInvoker added in v0.0.90 

func (c *DmsClient) ShowQueueTagsInvoker(request *model.ShowQueueTagsRequest) *ShowQueueTagsInvoker

ShowQueueTagsInvoker 查询队列标签

func (*DmsClient) ShowQuotas 

func (c *DmsClient) ShowQuotas(request *model.ShowQuotasRequest) (*model.ShowQuotasResponse, error)

ShowQuotas 查看租户配额

查看当前项目的配额。

详细说明请参考华为云API Explorer。 Please refer to Huawei cloud API Explorer for details.

func (*DmsClient) ShowQuotasInvoker added in v0.0.90 

func (c *DmsClient) ShowQuotasInvoker(request *model.ShowQuotasRequest) *ShowQuotasInvoker

ShowQuotasInvoker 查看租户配额

type ListConsumerGroupsInvoker added in v0.0.90 

type ListConsumerGroupsInvoker struct {
	*invoker.BaseInvoker
}

func (*ListConsumerGroupsInvoker) Invoke added in v0.0.90 

func (i *ListConsumerGroupsInvoker) Invoke() (*model.ListConsumerGroupsResponse, error)

type ListQueuesInvoker added in v0.0.90 

type ListQueuesInvoker struct {
	*invoker.BaseInvoker
}

func (*ListQueuesInvoker) Invoke added in v0.0.90 

func (i *ListQueuesInvoker) Invoke() (*model.ListQueuesResponse, error)

type SendMessagesInvoker added in v0.0.90 

type SendMessagesInvoker struct {
	*invoker.BaseInvoker
}

func (*SendMessagesInvoker) Invoke added in v0.0.90 

func (i *SendMessagesInvoker) Invoke() (*model.SendMessagesResponse, error)

type ShowQueueInvoker added in v0.0.90 

type ShowQueueInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowQueueInvoker) Invoke added in v0.0.90 

func (i *ShowQueueInvoker) Invoke() (*model.ShowQueueResponse, error)

type ShowQueueProjectTagsInvoker added in v0.0.90 

type ShowQueueProjectTagsInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowQueueProjectTagsInvoker) Invoke added in v0.0.90 

func (i *ShowQueueProjectTagsInvoker) Invoke() (*model.ShowQueueProjectTagsResponse, error)

type ShowQueueTagsInvoker added in v0.0.90 

type ShowQueueTagsInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowQueueTagsInvoker) Invoke added in v0.0.90 

func (i *ShowQueueTagsInvoker) Invoke() (*model.ShowQueueTagsResponse, error)

type ShowQuotasInvoker added in v0.0.90 

type ShowQuotasInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowQuotasInvoker) Invoke added in v0.0.90 

func (i *ShowQuotasInvoker) Invoke() (*model.ShowQuotasResponse, error)

Source Files

View all Source files

Directories

Path Synopsis

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.