v2

package
v0.0.89 Latest Latest
Warning

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

 Go to latest Published: May 19, 2022 License: Apache-2.0, BSD-2-Clause, BSD-3-Clause Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GenReqDefForBatchDeleteInstances 

func GenReqDefForBatchDeleteInstances() *def.HttpRequestDef

func GenReqDefForBatchUpdateConsumerGroup 

func GenReqDefForBatchUpdateConsumerGroup() *def.HttpRequestDef

func GenReqDefForCreateConsumerGroupOrBatchDeleteConsumerGroup 

func GenReqDefForCreateConsumerGroupOrBatchDeleteConsumerGroup() *def.HttpRequestDef

func GenReqDefForCreatePostPaidInstance 

func GenReqDefForCreatePostPaidInstance() *def.HttpRequestDef

func GenReqDefForCreateTopicOrBatchDeleteTopic 

func GenReqDefForCreateTopicOrBatchDeleteTopic() *def.HttpRequestDef

func GenReqDefForCreateUser 

func GenReqDefForCreateUser() *def.HttpRequestDef

func GenReqDefForDeleteConsumerGroup 

func GenReqDefForDeleteConsumerGroup() *def.HttpRequestDef

func GenReqDefForDeleteInstance 

func GenReqDefForDeleteInstance() *def.HttpRequestDef

func GenReqDefForDeleteTopic 

func GenReqDefForDeleteTopic() *def.HttpRequestDef

func GenReqDefForDeleteUser 

func GenReqDefForDeleteUser() *def.HttpRequestDef

func GenReqDefForExportDlqMessage 

func GenReqDefForExportDlqMessage() *def.HttpRequestDef

func GenReqDefForListAvailableZones 

func GenReqDefForListAvailableZones() *def.HttpRequestDef

func GenReqDefForListBrokers 

func GenReqDefForListBrokers() *def.HttpRequestDef

func GenReqDefForListConsumeGroupAccessPolicy 

func GenReqDefForListConsumeGroupAccessPolicy() *def.HttpRequestDef

func GenReqDefForListConsumerGroupOfTopic 

func GenReqDefForListConsumerGroupOfTopic() *def.HttpRequestDef

func GenReqDefForListInstanceConsumerGroups 

func GenReqDefForListInstanceConsumerGroups() *def.HttpRequestDef

func GenReqDefForListInstances 

func GenReqDefForListInstances() *def.HttpRequestDef

func GenReqDefForListMessageTrace 

func GenReqDefForListMessageTrace() *def.HttpRequestDef

func GenReqDefForListMessages 

func GenReqDefForListMessages() *def.HttpRequestDef

func GenReqDefForListTopicAccessPolicy 

func GenReqDefForListTopicAccessPolicy() *def.HttpRequestDef

func GenReqDefForListUser 

func GenReqDefForListUser() *def.HttpRequestDef

func GenReqDefForResetConsumeOffset 

func GenReqDefForResetConsumeOffset() *def.HttpRequestDef

func GenReqDefForShowConsumerListOrDetails 

func GenReqDefForShowConsumerListOrDetails() *def.HttpRequestDef

func GenReqDefForShowGroup 

func GenReqDefForShowGroup() *def.HttpRequestDef

func GenReqDefForShowInstance 

func GenReqDefForShowInstance() *def.HttpRequestDef

func GenReqDefForShowOneTopic 

func GenReqDefForShowOneTopic() *def.HttpRequestDef

func GenReqDefForShowTopicStatus 

func GenReqDefForShowTopicStatus() *def.HttpRequestDef

func GenReqDefForShowUser 

func GenReqDefForShowUser() *def.HttpRequestDef

func GenReqDefForUpdateConsumerGroup 

func GenReqDefForUpdateConsumerGroup() *def.HttpRequestDef

func GenReqDefForUpdateInstance 

func GenReqDefForUpdateInstance() *def.HttpRequestDef

func GenReqDefForUpdateTopic 

func GenReqDefForUpdateTopic() *def.HttpRequestDef

func GenReqDefForUpdateUser 

func GenReqDefForUpdateUser() *def.HttpRequestDef

func RocketMQClientBuilder 

func RocketMQClientBuilder() *http_client.HcHttpClientBuilder

Types

type RocketMQClient 

type RocketMQClient struct {
	HcClient *http_client.HcHttpClient
}

func NewRocketMQClient 

func NewRocketMQClient(hcClient *http_client.HcHttpClient) *RocketMQClient

func (*RocketMQClient) BatchDeleteInstances 

func (c *RocketMQClient) BatchDeleteInstances(request *model.BatchDeleteInstancesRequest) (*model.BatchDeleteInstancesResponse, error)

批量删除实例

批量删除实例。**实例删除后，实例中原有的数据将被删除，且没有备份，请谨慎操。**

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

func (*RocketMQClient) BatchUpdateConsumerGroup 

func (c *RocketMQClient) BatchUpdateConsumerGroup(request *model.BatchUpdateConsumerGroupRequest) (*model.BatchUpdateConsumerGroupResponse, error)

批量修改消费组

批量修改消费组。

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

func (*RocketMQClient) CreateConsumerGroupOrBatchDeleteConsumerGroup 

func (c *RocketMQClient) CreateConsumerGroupOrBatchDeleteConsumerGroup(request *model.CreateConsumerGroupOrBatchDeleteConsumerGroupRequest) (*model.CreateConsumerGroupOrBatchDeleteConsumerGroupResponse, error)

创建消费组或批量删除消费组

创建消费组或批量删除消费组。

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

func (*RocketMQClient) CreatePostPaidInstance 

func (c *RocketMQClient) CreatePostPaidInstance(request *model.CreatePostPaidInstanceRequest) (*model.CreatePostPaidInstanceResponse, error)

创建实例（按需）

创建实例，该接口创建的实例为按需计费的方式。

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

func (*RocketMQClient) CreateTopicOrBatchDeleteTopic 

func (c *RocketMQClient) CreateTopicOrBatchDeleteTopic(request *model.CreateTopicOrBatchDeleteTopicRequest) (*model.CreateTopicOrBatchDeleteTopicResponse, error)

创建主题或批量删除主题

创建主题或批量删除主题。

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

func (*RocketMQClient) CreateUser 

func (c *RocketMQClient) CreateUser(request *model.CreateUserRequest) (*model.CreateUserResponse, error)

创建用户

创建用户。

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

func (*RocketMQClient) DeleteConsumerGroup 

func (c *RocketMQClient) DeleteConsumerGroup(request *model.DeleteConsumerGroupRequest) (*model.DeleteConsumerGroupResponse, error)

删除指定消费组

删除指定消费组。

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

func (*RocketMQClient) DeleteInstance 

func (c *RocketMQClient) DeleteInstance(request *model.DeleteInstanceRequest) (*model.DeleteInstanceResponse, error)

删除指定的实例

删除指定的实例，释放该实例的所有资源。

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

func (*RocketMQClient) DeleteTopic 

func (c *RocketMQClient) DeleteTopic(request *model.DeleteTopicRequest) (*model.DeleteTopicResponse, error)

删除指定主题

删除指定主题。

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

func (*RocketMQClient) DeleteUser 

func (c *RocketMQClient) DeleteUser(request *model.DeleteUserRequest) (*model.DeleteUserResponse, error)

删除用户

删除用户。

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

func (*RocketMQClient) ExportDlqMessage 

func (c *RocketMQClient) ExportDlqMessage(request *model.ExportDlqMessageRequest) (*model.ExportDlqMessageResponse, error)

导出死信消息

导出死信消息。

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

func (*RocketMQClient) ListAvailableZones 

func (c *RocketMQClient) ListAvailableZones(request *model.ListAvailableZonesRequest) (*model.ListAvailableZonesResponse, error)

查询可用区信息

在创建实例时，需要配置实例所在的可用区ID，可通过该接口查询可用区的ID。

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

func (*RocketMQClient) ListBrokers 

func (c *RocketMQClient) ListBrokers(request *model.ListBrokersRequest) (*model.ListBrokersResponse, error)

查询代理列表

查询代理列表。

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

func (*RocketMQClient) ListConsumeGroupAccessPolicy 

func (c *RocketMQClient) ListConsumeGroupAccessPolicy(request *model.ListConsumeGroupAccessPolicyRequest) (*model.ListConsumeGroupAccessPolicyResponse, error)

查询消费组的授权用户列表

查询消费组的授权用户列表。

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

func (*RocketMQClient) ListConsumerGroupOfTopic 

func (c *RocketMQClient) ListConsumerGroupOfTopic(request *model.ListConsumerGroupOfTopicRequest) (*model.ListConsumerGroupOfTopicResponse, error)

查询主题消费组列表

查询主题消费组列表。

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

func (*RocketMQClient) ListInstanceConsumerGroups 

func (c *RocketMQClient) ListInstanceConsumerGroups(request *model.ListInstanceConsumerGroupsRequest) (*model.ListInstanceConsumerGroupsResponse, error)

查询消费组列表

查询消费组列表。

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

func (*RocketMQClient) ListInstances 

func (c *RocketMQClient) ListInstances(request *model.ListInstancesRequest) (*model.ListInstancesResponse, error)

查询所有实例列表

查询租户的实例列表，支持按照条件查询。

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

func (*RocketMQClient) ListMessageTrace 

func (c *RocketMQClient) ListMessageTrace(request *model.ListMessageTraceRequest) (*model.ListMessageTraceResponse, error)

查询消息轨迹

查询消息轨迹。

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

func (*RocketMQClient) ListMessages 

func (c *RocketMQClient) ListMessages(request *model.ListMessagesRequest) (*model.ListMessagesResponse, error)

查询消息

查询消息。

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

func (*RocketMQClient) ListTopicAccessPolicy 

func (c *RocketMQClient) ListTopicAccessPolicy(request *model.ListTopicAccessPolicyRequest) (*model.ListTopicAccessPolicyResponse, error)

查询主题的授权用户列表

查询主题的授权用户列表。

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

func (*RocketMQClient) ListUser 

func (c *RocketMQClient) ListUser(request *model.ListUserRequest) (*model.ListUserResponse, error)

查询用户列表

查询用户列表。

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

func (*RocketMQClient) ResetConsumeOffset 

func (c *RocketMQClient) ResetConsumeOffset(request *model.ResetConsumeOffsetRequest) (*model.ResetConsumeOffsetResponse, error)

重置消费进度

重置消费进度。

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

func (*RocketMQClient) ShowConsumerListOrDetails 

func (c *RocketMQClient) ShowConsumerListOrDetails(request *model.ShowConsumerListOrDetailsRequest) (*model.ShowConsumerListOrDetailsResponse, error)

查询消费列表或详情

查询消费列表或详情。

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

func (*RocketMQClient) ShowGroup 

func (c *RocketMQClient) ShowGroup(request *model.ShowGroupRequest) (*model.ShowGroupResponse, error)

查询指定消费组

查询指定消费组详情。

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

func (*RocketMQClient) ShowInstance 

func (c *RocketMQClient) ShowInstance(request *model.ShowInstanceRequest) (*model.ShowInstanceResponse, error)

查询指定实例

查询指定实例的详细信息。

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

func (*RocketMQClient) ShowOneTopic 

func (c *RocketMQClient) ShowOneTopic(request *model.ShowOneTopicRequest) (*model.ShowOneTopicResponse, error)

查询单个主题

查询单个主题。

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

func (*RocketMQClient) ShowTopicStatus 

func (c *RocketMQClient) ShowTopicStatus(request *model.ShowTopicStatusRequest) (*model.ShowTopicStatusResponse, error)

查询主题的消息数

查询主题的消息数。

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

func (*RocketMQClient) ShowUser 

func (c *RocketMQClient) ShowUser(request *model.ShowUserRequest) (*model.ShowUserResponse, error)

查询用户详情

查询用户详情。

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

func (*RocketMQClient) UpdateConsumerGroup 

func (c *RocketMQClient) UpdateConsumerGroup(request *model.UpdateConsumerGroupRequest) (*model.UpdateConsumerGroupResponse, error)

修改消费组

修改指定消费组参数。

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

func (*RocketMQClient) UpdateInstance 

func (c *RocketMQClient) UpdateInstance(request *model.UpdateInstanceRequest) (*model.UpdateInstanceResponse, error)

修改实例信息

修改实例的名称和描述信息。

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

func (*RocketMQClient) UpdateTopic 

func (c *RocketMQClient) UpdateTopic(request *model.UpdateTopicRequest) (*model.UpdateTopicResponse, error)

修改主题

修改主题。

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

func (*RocketMQClient) UpdateUser 

func (c *RocketMQClient) UpdateUser(request *model.UpdateUserRequest) (*model.UpdateUserResponse, error)

修改用户参数

修改用户参数。

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

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.