v2

package
v0.0.4 Latest Latest
Warning

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

 Go to latest Published: Aug 15, 2023 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 GenReqDefForBatchCreateOrDeleteRocketmqTag 

func GenReqDefForBatchCreateOrDeleteRocketmqTag() *def.HttpRequestDef

func GenReqDefForBatchDeleteInstances 

func GenReqDefForBatchDeleteInstances() *def.HttpRequestDef

func GenReqDefForBatchUpdateConsumerGroup 

func GenReqDefForBatchUpdateConsumerGroup() *def.HttpRequestDef

func GenReqDefForCreateConsumerGroupOrBatchDeleteConsumerGroup 

func GenReqDefForCreateConsumerGroupOrBatchDeleteConsumerGroup() *def.HttpRequestDef

func GenReqDefForCreateInstanceByEngine 

func GenReqDefForCreateInstanceByEngine() *def.HttpRequestDef

func GenReqDefForCreatePostPaidInstance 

func GenReqDefForCreatePostPaidInstance() *def.HttpRequestDef

func GenReqDefForCreateRocketMqMigrationTask 

func GenReqDefForCreateRocketMqMigrationTask() *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 GenReqDefForDeleteRocketMqMigrationTask 

func GenReqDefForDeleteRocketMqMigrationTask() *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 GenReqDefForListRocketInstanceTopics 

func GenReqDefForListRocketInstanceTopics() *def.HttpRequestDef

func GenReqDefForListRocketMqMigrationTask 

func GenReqDefForListRocketMqMigrationTask() *def.HttpRequestDef

func GenReqDefForListTopicAccessPolicy 

func GenReqDefForListTopicAccessPolicy() *def.HttpRequestDef

func GenReqDefForListUser 

func GenReqDefForListUser() *def.HttpRequestDef

func GenReqDefForResetConsumeOffset 

func GenReqDefForResetConsumeOffset() *def.HttpRequestDef

func GenReqDefForSendDlqMessage 

func GenReqDefForSendDlqMessage() *def.HttpRequestDef

func GenReqDefForShowConsumerConnections 

func GenReqDefForShowConsumerConnections() *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 GenReqDefForShowRocketmqProjectTags 

func GenReqDefForShowRocketmqProjectTags() *def.HttpRequestDef

func GenReqDefForShowRocketmqTags 

func GenReqDefForShowRocketmqTags() *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 GenReqDefForValidateConsumedMessage 

func GenReqDefForValidateConsumedMessage() *def.HttpRequestDef

func RocketMQClientBuilder 

func RocketMQClientBuilder() *http_client.HcHttpClientBuilder

Types

type BatchCreateOrDeleteRocketmqTagInvoker 

type BatchCreateOrDeleteRocketmqTagInvoker struct {
	*invoker.BaseInvoker
}

func (*BatchCreateOrDeleteRocketmqTagInvoker) Invoke 

func (i *BatchCreateOrDeleteRocketmqTagInvoker) Invoke() (*model.BatchCreateOrDeleteRocketmqTagResponse, error)

type BatchDeleteInstancesInvoker 

type BatchDeleteInstancesInvoker struct {
	*invoker.BaseInvoker
}

func (*BatchDeleteInstancesInvoker) Invoke 

func (i *BatchDeleteInstancesInvoker) Invoke() (*model.BatchDeleteInstancesResponse, error)

type BatchUpdateConsumerGroupInvoker 

type BatchUpdateConsumerGroupInvoker struct {
	*invoker.BaseInvoker
}

func (*BatchUpdateConsumerGroupInvoker) Invoke 

func (i *BatchUpdateConsumerGroupInvoker) Invoke() (*model.BatchUpdateConsumerGroupResponse, error)

type CreateConsumerGroupOrBatchDeleteConsumerGroupInvoker 

type CreateConsumerGroupOrBatchDeleteConsumerGroupInvoker struct {
	*invoker.BaseInvoker
}

func (*CreateConsumerGroupOrBatchDeleteConsumerGroupInvoker) Invoke 

func (i *CreateConsumerGroupOrBatchDeleteConsumerGroupInvoker) Invoke() (*model.CreateConsumerGroupOrBatchDeleteConsumerGroupResponse, error)

type CreateInstanceByEngineInvoker 

type CreateInstanceByEngineInvoker struct {
	*invoker.BaseInvoker
}

func (*CreateInstanceByEngineInvoker) Invoke 

func (i *CreateInstanceByEngineInvoker) Invoke() (*model.CreateInstanceByEngineResponse, error)

type CreatePostPaidInstanceInvoker 

type CreatePostPaidInstanceInvoker struct {
	*invoker.BaseInvoker
}

func (*CreatePostPaidInstanceInvoker) Invoke 

func (i *CreatePostPaidInstanceInvoker) Invoke() (*model.CreatePostPaidInstanceResponse, error)

type CreateRocketMqMigrationTaskInvoker 

type CreateRocketMqMigrationTaskInvoker struct {
	*invoker.BaseInvoker
}

func (*CreateRocketMqMigrationTaskInvoker) Invoke 

func (i *CreateRocketMqMigrationTaskInvoker) Invoke() (*model.CreateRocketMqMigrationTaskResponse, error)

type CreateTopicOrBatchDeleteTopicInvoker 

type CreateTopicOrBatchDeleteTopicInvoker struct {
	*invoker.BaseInvoker
}

func (*CreateTopicOrBatchDeleteTopicInvoker) Invoke 

func (i *CreateTopicOrBatchDeleteTopicInvoker) Invoke() (*model.CreateTopicOrBatchDeleteTopicResponse, error)

type CreateUserInvoker 

type CreateUserInvoker struct {
	*invoker.BaseInvoker
}

func (*CreateUserInvoker) Invoke 

func (i *CreateUserInvoker) Invoke() (*model.CreateUserResponse, error)

type DeleteConsumerGroupInvoker 

type DeleteConsumerGroupInvoker struct {
	*invoker.BaseInvoker
}

func (*DeleteConsumerGroupInvoker) Invoke 

func (i *DeleteConsumerGroupInvoker) Invoke() (*model.DeleteConsumerGroupResponse, error)

type DeleteInstanceInvoker 

type DeleteInstanceInvoker struct {
	*invoker.BaseInvoker
}

func (*DeleteInstanceInvoker) Invoke 

func (i *DeleteInstanceInvoker) Invoke() (*model.DeleteInstanceResponse, error)

type DeleteRocketMqMigrationTaskInvoker 

type DeleteRocketMqMigrationTaskInvoker struct {
	*invoker.BaseInvoker
}

func (*DeleteRocketMqMigrationTaskInvoker) Invoke 

func (i *DeleteRocketMqMigrationTaskInvoker) Invoke() (*model.DeleteRocketMqMigrationTaskResponse, error)

type DeleteTopicInvoker 

type DeleteTopicInvoker struct {
	*invoker.BaseInvoker
}

func (*DeleteTopicInvoker) Invoke 

func (i *DeleteTopicInvoker) Invoke() (*model.DeleteTopicResponse, error)

type DeleteUserInvoker 

type DeleteUserInvoker struct {
	*invoker.BaseInvoker
}

func (*DeleteUserInvoker) Invoke 

func (i *DeleteUserInvoker) Invoke() (*model.DeleteUserResponse, error)

type ExportDlqMessageInvoker 

type ExportDlqMessageInvoker struct {
	*invoker.BaseInvoker
}

func (*ExportDlqMessageInvoker) Invoke 

func (i *ExportDlqMessageInvoker) Invoke() (*model.ExportDlqMessageResponse, error)

type ListAvailableZonesInvoker 

type ListAvailableZonesInvoker struct {
	*invoker.BaseInvoker
}

func (*ListAvailableZonesInvoker) Invoke 

func (i *ListAvailableZonesInvoker) Invoke() (*model.ListAvailableZonesResponse, error)

type ListBrokersInvoker 

type ListBrokersInvoker struct {
	*invoker.BaseInvoker
}

func (*ListBrokersInvoker) Invoke 

func (i *ListBrokersInvoker) Invoke() (*model.ListBrokersResponse, error)

type ListConsumeGroupAccessPolicyInvoker 

type ListConsumeGroupAccessPolicyInvoker struct {
	*invoker.BaseInvoker
}

func (*ListConsumeGroupAccessPolicyInvoker) Invoke 

func (i *ListConsumeGroupAccessPolicyInvoker) Invoke() (*model.ListConsumeGroupAccessPolicyResponse, error)

type ListConsumerGroupOfTopicInvoker 

type ListConsumerGroupOfTopicInvoker struct {
	*invoker.BaseInvoker
}

func (*ListConsumerGroupOfTopicInvoker) Invoke 

func (i *ListConsumerGroupOfTopicInvoker) Invoke() (*model.ListConsumerGroupOfTopicResponse, error)

type ListInstanceConsumerGroupsInvoker 

type ListInstanceConsumerGroupsInvoker struct {
	*invoker.BaseInvoker
}

func (*ListInstanceConsumerGroupsInvoker) Invoke 

func (i *ListInstanceConsumerGroupsInvoker) Invoke() (*model.ListInstanceConsumerGroupsResponse, error)

type ListInstancesInvoker 

type ListInstancesInvoker struct {
	*invoker.BaseInvoker
}

func (*ListInstancesInvoker) Invoke 

func (i *ListInstancesInvoker) Invoke() (*model.ListInstancesResponse, error)

type ListMessageTraceInvoker 

type ListMessageTraceInvoker struct {
	*invoker.BaseInvoker
}

func (*ListMessageTraceInvoker) Invoke 

func (i *ListMessageTraceInvoker) Invoke() (*model.ListMessageTraceResponse, error)

type ListMessagesInvoker 

type ListMessagesInvoker struct {
	*invoker.BaseInvoker
}

func (*ListMessagesInvoker) Invoke 

func (i *ListMessagesInvoker) Invoke() (*model.ListMessagesResponse, error)

type ListRocketInstanceTopicsInvoker 

type ListRocketInstanceTopicsInvoker struct {
	*invoker.BaseInvoker
}

func (*ListRocketInstanceTopicsInvoker) Invoke 

func (i *ListRocketInstanceTopicsInvoker) Invoke() (*model.ListRocketInstanceTopicsResponse, error)

type ListRocketMqMigrationTaskInvoker 

type ListRocketMqMigrationTaskInvoker struct {
	*invoker.BaseInvoker
}

func (*ListRocketMqMigrationTaskInvoker) Invoke 

func (i *ListRocketMqMigrationTaskInvoker) Invoke() (*model.ListRocketMqMigrationTaskResponse, error)

type ListTopicAccessPolicyInvoker 

type ListTopicAccessPolicyInvoker struct {
	*invoker.BaseInvoker
}

func (*ListTopicAccessPolicyInvoker) Invoke 

func (i *ListTopicAccessPolicyInvoker) Invoke() (*model.ListTopicAccessPolicyResponse, error)

type ListUserInvoker 

type ListUserInvoker struct {
	*invoker.BaseInvoker
}

func (*ListUserInvoker) Invoke 

func (i *ListUserInvoker) Invoke() (*model.ListUserResponse, error)

type ResetConsumeOffsetInvoker 

type ResetConsumeOffsetInvoker struct {
	*invoker.BaseInvoker
}

func (*ResetConsumeOffsetInvoker) Invoke 

func (i *ResetConsumeOffsetInvoker) Invoke() (*model.ResetConsumeOffsetResponse, error)

type RocketMQClient 

type RocketMQClient struct {
	HcClient *http_client.HcHttpClient
}

func NewRocketMQClient 

func NewRocketMQClient(hcClient *http_client.HcHttpClient) *RocketMQClient

func (*RocketMQClient) BatchCreateOrDeleteRocketmqTag 

func (c *RocketMQClient) BatchCreateOrDeleteRocketmqTag(request *model.BatchCreateOrDeleteRocketmqTagRequest) (*model.BatchCreateOrDeleteRocketmqTagResponse, error)

BatchCreateOrDeleteRocketmqTag 批量添加或删除实例标签

批量添加或删除实例标签。

Please refer to HUAWEI cloud API Explorer for details.

func (*RocketMQClient) BatchCreateOrDeleteRocketmqTagInvoker 

func (c *RocketMQClient) BatchCreateOrDeleteRocketmqTagInvoker(request *model.BatchCreateOrDeleteRocketmqTagRequest) *BatchCreateOrDeleteRocketmqTagInvoker

BatchCreateOrDeleteRocketmqTagInvoker 批量添加或删除实例标签

func (*RocketMQClient) BatchDeleteInstances 

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

BatchDeleteInstances 批量删除实例

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

Please refer to HUAWEI cloud API Explorer for details.

func (*RocketMQClient) BatchDeleteInstancesInvoker 

func (c *RocketMQClient) BatchDeleteInstancesInvoker(request *model.BatchDeleteInstancesRequest) *BatchDeleteInstancesInvoker

BatchDeleteInstancesInvoker 批量删除实例

func (*RocketMQClient) BatchUpdateConsumerGroup 

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

BatchUpdateConsumerGroup 批量修改消费组

批量修改消费组。

Please refer to HUAWEI cloud API Explorer for details.

func (*RocketMQClient) BatchUpdateConsumerGroupInvoker 

func (c *RocketMQClient) BatchUpdateConsumerGroupInvoker(request *model.BatchUpdateConsumerGroupRequest) *BatchUpdateConsumerGroupInvoker

BatchUpdateConsumerGroupInvoker 批量修改消费组

func (*RocketMQClient) CreateConsumerGroupOrBatchDeleteConsumerGroup 

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

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

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

Please refer to HUAWEI cloud API Explorer for details.

func (*RocketMQClient) CreateConsumerGroupOrBatchDeleteConsumerGroupInvoker 

func (c *RocketMQClient) CreateConsumerGroupOrBatchDeleteConsumerGroupInvoker(request *model.CreateConsumerGroupOrBatchDeleteConsumerGroupRequest) *CreateConsumerGroupOrBatchDeleteConsumerGroupInvoker

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

func (*RocketMQClient) CreateInstanceByEngine 

func (c *RocketMQClient) CreateInstanceByEngine(request *model.CreateInstanceByEngineRequest) (*model.CreateInstanceByEngineResponse, error)

CreateInstanceByEngine 创建实例

该接口支持创建按需和包周期两种计费方式的实例。

Please refer to HUAWEI cloud API Explorer for details.

func (*RocketMQClient) CreateInstanceByEngineInvoker 

func (c *RocketMQClient) CreateInstanceByEngineInvoker(request *model.CreateInstanceByEngineRequest) *CreateInstanceByEngineInvoker

CreateInstanceByEngineInvoker 创建实例

func (*RocketMQClient) CreatePostPaidInstance 

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

CreatePostPaidInstance 创建实例（按需）

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

Please refer to HUAWEI cloud API Explorer for details.

func (*RocketMQClient) CreatePostPaidInstanceInvoker 

func (c *RocketMQClient) CreatePostPaidInstanceInvoker(request *model.CreatePostPaidInstanceRequest) *CreatePostPaidInstanceInvoker

CreatePostPaidInstanceInvoker 创建实例（按需）

func (*RocketMQClient) CreateRocketMqMigrationTask 

func (c *RocketMQClient) CreateRocketMqMigrationTask(request *model.CreateRocketMqMigrationTaskRequest) (*model.CreateRocketMqMigrationTaskResponse, error)

CreateRocketMqMigrationTask 新建元数据迁移任务

新建元数据迁移任务。

Please refer to HUAWEI cloud API Explorer for details.

func (*RocketMQClient) CreateRocketMqMigrationTaskInvoker 

func (c *RocketMQClient) CreateRocketMqMigrationTaskInvoker(request *model.CreateRocketMqMigrationTaskRequest) *CreateRocketMqMigrationTaskInvoker

CreateRocketMqMigrationTaskInvoker 新建元数据迁移任务

func (*RocketMQClient) CreateTopicOrBatchDeleteTopic 

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

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

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

Please refer to HUAWEI cloud API Explorer for details.

func (*RocketMQClient) CreateTopicOrBatchDeleteTopicInvoker 

func (c *RocketMQClient) CreateTopicOrBatchDeleteTopicInvoker(request *model.CreateTopicOrBatchDeleteTopicRequest) *CreateTopicOrBatchDeleteTopicInvoker

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

func (*RocketMQClient) CreateUser 

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

CreateUser 创建用户

创建用户。

Please refer to HUAWEI cloud API Explorer for details.

func (*RocketMQClient) CreateUserInvoker 

func (c *RocketMQClient) CreateUserInvoker(request *model.CreateUserRequest) *CreateUserInvoker

CreateUserInvoker 创建用户

func (*RocketMQClient) DeleteConsumerGroup 

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

DeleteConsumerGroup 删除指定消费组

删除指定消费组。

Please refer to HUAWEI cloud API Explorer for details.

func (*RocketMQClient) DeleteConsumerGroupInvoker 

func (c *RocketMQClient) DeleteConsumerGroupInvoker(request *model.DeleteConsumerGroupRequest) *DeleteConsumerGroupInvoker

DeleteConsumerGroupInvoker 删除指定消费组

func (*RocketMQClient) DeleteInstance 

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

DeleteInstance 删除指定的实例

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

Please refer to HUAWEI cloud API Explorer for details.

func (*RocketMQClient) DeleteInstanceInvoker 

func (c *RocketMQClient) DeleteInstanceInvoker(request *model.DeleteInstanceRequest) *DeleteInstanceInvoker

DeleteInstanceInvoker 删除指定的实例

func (*RocketMQClient) DeleteRocketMqMigrationTask 

func (c *RocketMQClient) DeleteRocketMqMigrationTask(request *model.DeleteRocketMqMigrationTaskRequest) (*model.DeleteRocketMqMigrationTaskResponse, error)

DeleteRocketMqMigrationTask 删除元数据迁移任务

删除元数据迁移任务。

Please refer to HUAWEI cloud API Explorer for details.

func (*RocketMQClient) DeleteRocketMqMigrationTaskInvoker 

func (c *RocketMQClient) DeleteRocketMqMigrationTaskInvoker(request *model.DeleteRocketMqMigrationTaskRequest) *DeleteRocketMqMigrationTaskInvoker

DeleteRocketMqMigrationTaskInvoker 删除元数据迁移任务

func (*RocketMQClient) DeleteTopic 

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

DeleteTopic 删除指定主题

删除指定主题。

Please refer to HUAWEI cloud API Explorer for details.

func (*RocketMQClient) DeleteTopicInvoker 

func (c *RocketMQClient) DeleteTopicInvoker(request *model.DeleteTopicRequest) *DeleteTopicInvoker

DeleteTopicInvoker 删除指定主题

func (*RocketMQClient) DeleteUser 

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

DeleteUser 删除用户

删除用户。

Please refer to HUAWEI cloud API Explorer for details.

func (*RocketMQClient) DeleteUserInvoker 

func (c *RocketMQClient) DeleteUserInvoker(request *model.DeleteUserRequest) *DeleteUserInvoker

DeleteUserInvoker 删除用户

func (*RocketMQClient) ExportDlqMessage 

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

ExportDlqMessage 导出死信消息

导出死信消息。

Please refer to HUAWEI cloud API Explorer for details.

func (*RocketMQClient) ExportDlqMessageInvoker 

func (c *RocketMQClient) ExportDlqMessageInvoker(request *model.ExportDlqMessageRequest) *ExportDlqMessageInvoker

ExportDlqMessageInvoker 导出死信消息

func (*RocketMQClient) ListAvailableZones 

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

ListAvailableZones 查询可用区信息

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

Please refer to HUAWEI cloud API Explorer for details.

func (*RocketMQClient) ListAvailableZonesInvoker 

func (c *RocketMQClient) ListAvailableZonesInvoker(request *model.ListAvailableZonesRequest) *ListAvailableZonesInvoker

ListAvailableZonesInvoker 查询可用区信息

func (*RocketMQClient) ListBrokers 

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

ListBrokers 查询代理列表

查询代理列表。

Please refer to HUAWEI cloud API Explorer for details.

func (*RocketMQClient) ListBrokersInvoker 

func (c *RocketMQClient) ListBrokersInvoker(request *model.ListBrokersRequest) *ListBrokersInvoker

ListBrokersInvoker 查询代理列表

func (*RocketMQClient) ListConsumeGroupAccessPolicy 

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

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

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

Please refer to HUAWEI cloud API Explorer for details.

func (*RocketMQClient) ListConsumeGroupAccessPolicyInvoker 

func (c *RocketMQClient) ListConsumeGroupAccessPolicyInvoker(request *model.ListConsumeGroupAccessPolicyRequest) *ListConsumeGroupAccessPolicyInvoker

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

func (*RocketMQClient) ListConsumerGroupOfTopic 

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

ListConsumerGroupOfTopic 查询主题消费组列表

查询主题消费组列表。

Please refer to HUAWEI cloud API Explorer for details.

func (*RocketMQClient) ListConsumerGroupOfTopicInvoker 

func (c *RocketMQClient) ListConsumerGroupOfTopicInvoker(request *model.ListConsumerGroupOfTopicRequest) *ListConsumerGroupOfTopicInvoker

ListConsumerGroupOfTopicInvoker 查询主题消费组列表

func (*RocketMQClient) ListInstanceConsumerGroups 

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

ListInstanceConsumerGroups 查询消费组列表

查询消费组列表。

Please refer to HUAWEI cloud API Explorer for details.

func (*RocketMQClient) ListInstanceConsumerGroupsInvoker 

func (c *RocketMQClient) ListInstanceConsumerGroupsInvoker(request *model.ListInstanceConsumerGroupsRequest) *ListInstanceConsumerGroupsInvoker

ListInstanceConsumerGroupsInvoker 查询消费组列表

func (*RocketMQClient) ListInstances 

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

ListInstances 查询所有实例列表

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

Please refer to HUAWEI cloud API Explorer for details.

func (*RocketMQClient) ListInstancesInvoker 

func (c *RocketMQClient) ListInstancesInvoker(request *model.ListInstancesRequest) *ListInstancesInvoker

ListInstancesInvoker 查询所有实例列表

func (*RocketMQClient) ListMessageTrace 

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

ListMessageTrace 查询消息轨迹

查询消息轨迹。

Please refer to HUAWEI cloud API Explorer for details.

func (*RocketMQClient) ListMessageTraceInvoker 

func (c *RocketMQClient) ListMessageTraceInvoker(request *model.ListMessageTraceRequest) *ListMessageTraceInvoker

ListMessageTraceInvoker 查询消息轨迹

func (*RocketMQClient) ListMessages 

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

ListMessages 查询消息

查询消息。

Please refer to HUAWEI cloud API Explorer for details.

func (*RocketMQClient) ListMessagesInvoker 

func (c *RocketMQClient) ListMessagesInvoker(request *model.ListMessagesRequest) *ListMessagesInvoker

ListMessagesInvoker 查询消息

func (*RocketMQClient) ListRocketInstanceTopics 

func (c *RocketMQClient) ListRocketInstanceTopics(request *model.ListRocketInstanceTopicsRequest) (*model.ListRocketInstanceTopicsResponse, error)

ListRocketInstanceTopics 查询主题列表

该接口用于查询指定RocketMQ实例的Topic列表。

Please refer to HUAWEI cloud API Explorer for details.

func (*RocketMQClient) ListRocketInstanceTopicsInvoker 

func (c *RocketMQClient) ListRocketInstanceTopicsInvoker(request *model.ListRocketInstanceTopicsRequest) *ListRocketInstanceTopicsInvoker

ListRocketInstanceTopicsInvoker 查询主题列表

func (*RocketMQClient) ListRocketMqMigrationTask 

func (c *RocketMQClient) ListRocketMqMigrationTask(request *model.ListRocketMqMigrationTaskRequest) (*model.ListRocketMqMigrationTaskResponse, error)

ListRocketMqMigrationTask 查询实例下所有迁移任务或查询指定迁移任务信息

1. 查询实例下所有迁移任务 2. 查询指定迁移任务信息

Please refer to HUAWEI cloud API Explorer for details.

func (*RocketMQClient) ListRocketMqMigrationTaskInvoker 

func (c *RocketMQClient) ListRocketMqMigrationTaskInvoker(request *model.ListRocketMqMigrationTaskRequest) *ListRocketMqMigrationTaskInvoker

ListRocketMqMigrationTaskInvoker 查询实例下所有迁移任务或查询指定迁移任务信息

func (*RocketMQClient) ListTopicAccessPolicy 

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

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

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

Please refer to HUAWEI cloud API Explorer for details.

func (*RocketMQClient) ListTopicAccessPolicyInvoker 

func (c *RocketMQClient) ListTopicAccessPolicyInvoker(request *model.ListTopicAccessPolicyRequest) *ListTopicAccessPolicyInvoker

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

func (*RocketMQClient) ListUser 

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

ListUser 查询用户列表

查询用户列表。

Please refer to HUAWEI cloud API Explorer for details.

func (*RocketMQClient) ListUserInvoker 

func (c *RocketMQClient) ListUserInvoker(request *model.ListUserRequest) *ListUserInvoker

ListUserInvoker 查询用户列表

func (*RocketMQClient) ResetConsumeOffset 

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

ResetConsumeOffset 重置消费进度

重置消费进度。

Please refer to HUAWEI cloud API Explorer for details.

func (*RocketMQClient) ResetConsumeOffsetInvoker 

func (c *RocketMQClient) ResetConsumeOffsetInvoker(request *model.ResetConsumeOffsetRequest) *ResetConsumeOffsetInvoker

ResetConsumeOffsetInvoker 重置消费进度

func (*RocketMQClient) SendDlqMessage 

func (c *RocketMQClient) SendDlqMessage(request *model.SendDlqMessageRequest) (*model.SendDlqMessageResponse, error)

SendDlqMessage 重发死信消息

重发死信消息。

Please refer to HUAWEI cloud API Explorer for details.

func (*RocketMQClient) SendDlqMessageInvoker 

func (c *RocketMQClient) SendDlqMessageInvoker(request *model.SendDlqMessageRequest) *SendDlqMessageInvoker

SendDlqMessageInvoker 重发死信消息

func (*RocketMQClient) ShowConsumerConnections 

func (c *RocketMQClient) ShowConsumerConnections(request *model.ShowConsumerConnectionsRequest) (*model.ShowConsumerConnectionsResponse, error)

ShowConsumerConnections 查询消费者列表

查询消费组内消费者列表

Please refer to HUAWEI cloud API Explorer for details.

func (*RocketMQClient) ShowConsumerConnectionsInvoker 

func (c *RocketMQClient) ShowConsumerConnectionsInvoker(request *model.ShowConsumerConnectionsRequest) *ShowConsumerConnectionsInvoker

ShowConsumerConnectionsInvoker 查询消费者列表

func (*RocketMQClient) ShowConsumerListOrDetails 

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

ShowConsumerListOrDetails 查询消费列表或详情

查询消费列表或详情。

Please refer to HUAWEI cloud API Explorer for details.

func (*RocketMQClient) ShowConsumerListOrDetailsInvoker 

func (c *RocketMQClient) ShowConsumerListOrDetailsInvoker(request *model.ShowConsumerListOrDetailsRequest) *ShowConsumerListOrDetailsInvoker

ShowConsumerListOrDetailsInvoker 查询消费列表或详情

func (*RocketMQClient) ShowGroup 

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

ShowGroup 查询指定消费组

查询指定消费组详情。

Please refer to HUAWEI cloud API Explorer for details.

func (*RocketMQClient) ShowGroupInvoker 

func (c *RocketMQClient) ShowGroupInvoker(request *model.ShowGroupRequest) *ShowGroupInvoker

ShowGroupInvoker 查询指定消费组

func (*RocketMQClient) ShowInstance 

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

ShowInstance 查询指定实例

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

Please refer to HUAWEI cloud API Explorer for details.

func (*RocketMQClient) ShowInstanceInvoker 

func (c *RocketMQClient) ShowInstanceInvoker(request *model.ShowInstanceRequest) *ShowInstanceInvoker

ShowInstanceInvoker 查询指定实例

func (*RocketMQClient) ShowOneTopic 

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

ShowOneTopic 查询单个主题

查询单个主题。

Please refer to HUAWEI cloud API Explorer for details.

func (*RocketMQClient) ShowOneTopicInvoker 

func (c *RocketMQClient) ShowOneTopicInvoker(request *model.ShowOneTopicRequest) *ShowOneTopicInvoker

ShowOneTopicInvoker 查询单个主题

func (*RocketMQClient) ShowRocketmqProjectTags 

func (c *RocketMQClient) ShowRocketmqProjectTags(request *model.ShowRocketmqProjectTagsRequest) (*model.ShowRocketmqProjectTagsResponse, error)

ShowRocketmqProjectTags 查询项目标签

查询项目标签。

Please refer to HUAWEI cloud API Explorer for details.

func (*RocketMQClient) ShowRocketmqProjectTagsInvoker 

func (c *RocketMQClient) ShowRocketmqProjectTagsInvoker(request *model.ShowRocketmqProjectTagsRequest) *ShowRocketmqProjectTagsInvoker

ShowRocketmqProjectTagsInvoker 查询项目标签

func (*RocketMQClient) ShowRocketmqTags 

func (c *RocketMQClient) ShowRocketmqTags(request *model.ShowRocketmqTagsRequest) (*model.ShowRocketmqTagsResponse, error)

ShowRocketmqTags 查询实例标签

查询实例标签。

Please refer to HUAWEI cloud API Explorer for details.

func (*RocketMQClient) ShowRocketmqTagsInvoker 

func (c *RocketMQClient) ShowRocketmqTagsInvoker(request *model.ShowRocketmqTagsRequest) *ShowRocketmqTagsInvoker

ShowRocketmqTagsInvoker 查询实例标签

func (*RocketMQClient) ShowTopicStatus 

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

ShowTopicStatus 查询主题的消息数

查询主题的消息数。

Please refer to HUAWEI cloud API Explorer for details.

func (*RocketMQClient) ShowTopicStatusInvoker 

func (c *RocketMQClient) ShowTopicStatusInvoker(request *model.ShowTopicStatusRequest) *ShowTopicStatusInvoker

ShowTopicStatusInvoker 查询主题的消息数

func (*RocketMQClient) ShowUser 

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

ShowUser 查询用户详情

查询用户详情。

Please refer to HUAWEI cloud API Explorer for details.

func (*RocketMQClient) ShowUserInvoker 

func (c *RocketMQClient) ShowUserInvoker(request *model.ShowUserRequest) *ShowUserInvoker

ShowUserInvoker 查询用户详情

func (*RocketMQClient) UpdateConsumerGroup 

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

UpdateConsumerGroup 修改消费组

修改指定消费组参数。

Please refer to HUAWEI cloud API Explorer for details.

func (*RocketMQClient) UpdateConsumerGroupInvoker 

func (c *RocketMQClient) UpdateConsumerGroupInvoker(request *model.UpdateConsumerGroupRequest) *UpdateConsumerGroupInvoker

UpdateConsumerGroupInvoker 修改消费组

func (*RocketMQClient) UpdateInstance 

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

UpdateInstance 修改实例信息

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

Please refer to HUAWEI cloud API Explorer for details.

func (*RocketMQClient) UpdateInstanceInvoker 

func (c *RocketMQClient) UpdateInstanceInvoker(request *model.UpdateInstanceRequest) *UpdateInstanceInvoker

UpdateInstanceInvoker 修改实例信息

func (*RocketMQClient) UpdateTopic 

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

UpdateTopic 修改主题

修改主题。

Please refer to HUAWEI cloud API Explorer for details.

func (*RocketMQClient) UpdateTopicInvoker 

func (c *RocketMQClient) UpdateTopicInvoker(request *model.UpdateTopicRequest) *UpdateTopicInvoker

UpdateTopicInvoker 修改主题

func (*RocketMQClient) UpdateUser 

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

UpdateUser 修改用户参数

修改用户参数。

Please refer to HUAWEI cloud API Explorer for details.

func (*RocketMQClient) UpdateUserInvoker 

func (c *RocketMQClient) UpdateUserInvoker(request *model.UpdateUserRequest) *UpdateUserInvoker

UpdateUserInvoker 修改用户参数

func (*RocketMQClient) ValidateConsumedMessage 

func (c *RocketMQClient) ValidateConsumedMessage(request *model.ValidateConsumedMessageRequest) (*model.ValidateConsumedMessageResponse, error)

ValidateConsumedMessage 消费验证

消费验证。

Please refer to HUAWEI cloud API Explorer for details.

func (*RocketMQClient) ValidateConsumedMessageInvoker 

func (c *RocketMQClient) ValidateConsumedMessageInvoker(request *model.ValidateConsumedMessageRequest) *ValidateConsumedMessageInvoker

ValidateConsumedMessageInvoker 消费验证

type SendDlqMessageInvoker 

type SendDlqMessageInvoker struct {
	*invoker.BaseInvoker
}

func (*SendDlqMessageInvoker) Invoke 

func (i *SendDlqMessageInvoker) Invoke() (*model.SendDlqMessageResponse, error)

type ShowConsumerConnectionsInvoker 

type ShowConsumerConnectionsInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowConsumerConnectionsInvoker) Invoke 

func (i *ShowConsumerConnectionsInvoker) Invoke() (*model.ShowConsumerConnectionsResponse, error)

type ShowConsumerListOrDetailsInvoker 

type ShowConsumerListOrDetailsInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowConsumerListOrDetailsInvoker) Invoke 

func (i *ShowConsumerListOrDetailsInvoker) Invoke() (*model.ShowConsumerListOrDetailsResponse, error)

type ShowGroupInvoker 

type ShowGroupInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowGroupInvoker) Invoke 

func (i *ShowGroupInvoker) Invoke() (*model.ShowGroupResponse, error)

type ShowInstanceInvoker 

type ShowInstanceInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowInstanceInvoker) Invoke 

func (i *ShowInstanceInvoker) Invoke() (*model.ShowInstanceResponse, error)

type ShowOneTopicInvoker 

type ShowOneTopicInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowOneTopicInvoker) Invoke 

func (i *ShowOneTopicInvoker) Invoke() (*model.ShowOneTopicResponse, error)

type ShowRocketmqProjectTagsInvoker 

type ShowRocketmqProjectTagsInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowRocketmqProjectTagsInvoker) Invoke 

func (i *ShowRocketmqProjectTagsInvoker) Invoke() (*model.ShowRocketmqProjectTagsResponse, error)

type ShowRocketmqTagsInvoker 

type ShowRocketmqTagsInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowRocketmqTagsInvoker) Invoke 

func (i *ShowRocketmqTagsInvoker) Invoke() (*model.ShowRocketmqTagsResponse, error)

type ShowTopicStatusInvoker 

type ShowTopicStatusInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowTopicStatusInvoker) Invoke 

func (i *ShowTopicStatusInvoker) Invoke() (*model.ShowTopicStatusResponse, error)

type ShowUserInvoker 

type ShowUserInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowUserInvoker) Invoke 

func (i *ShowUserInvoker) Invoke() (*model.ShowUserResponse, error)

type UpdateConsumerGroupInvoker 

type UpdateConsumerGroupInvoker struct {
	*invoker.BaseInvoker
}

func (*UpdateConsumerGroupInvoker) Invoke 

func (i *UpdateConsumerGroupInvoker) Invoke() (*model.UpdateConsumerGroupResponse, error)

type UpdateInstanceInvoker 

type UpdateInstanceInvoker struct {
	*invoker.BaseInvoker
}

func (*UpdateInstanceInvoker) Invoke 

func (i *UpdateInstanceInvoker) Invoke() (*model.UpdateInstanceResponse, error)

type UpdateTopicInvoker 

type UpdateTopicInvoker struct {
	*invoker.BaseInvoker
}

func (*UpdateTopicInvoker) Invoke 

func (i *UpdateTopicInvoker) Invoke() (*model.UpdateTopicResponse, error)

type UpdateUserInvoker 

type UpdateUserInvoker struct {
	*invoker.BaseInvoker
}

func (*UpdateUserInvoker) Invoke 

func (i *UpdateUserInvoker) Invoke() (*model.UpdateUserResponse, error)

type ValidateConsumedMessageInvoker 

type ValidateConsumedMessageInvoker struct {
	*invoker.BaseInvoker
}

func (*ValidateConsumedMessageInvoker) Invoke 

func (i *ValidateConsumedMessageInvoker) Invoke() (*model.ValidateConsumedMessageResponse, 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.