v2

package
v0.1.24 Latest Latest
Warning

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

 Go to latest Published: Feb 2, 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 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 GenReqDefForListRocketInstanceTopics added in v0.1.22 

func GenReqDefForListRocketInstanceTopics() *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 BatchDeleteInstancesInvoker added in v0.0.90 

type BatchDeleteInstancesInvoker struct {
	*invoker.BaseInvoker
}

func (*BatchDeleteInstancesInvoker) Invoke added in v0.0.90 

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

type BatchUpdateConsumerGroupInvoker added in v0.0.90 

type BatchUpdateConsumerGroupInvoker struct {
	*invoker.BaseInvoker
}

func (*BatchUpdateConsumerGroupInvoker) Invoke added in v0.0.90 

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

type CreateConsumerGroupOrBatchDeleteConsumerGroupInvoker added in v0.0.90 

type CreateConsumerGroupOrBatchDeleteConsumerGroupInvoker struct {
	*invoker.BaseInvoker
}

func (*CreateConsumerGroupOrBatchDeleteConsumerGroupInvoker) Invoke added in v0.0.90 

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

type CreatePostPaidInstanceInvoker added in v0.0.90 

type CreatePostPaidInstanceInvoker struct {
	*invoker.BaseInvoker
}

func (*CreatePostPaidInstanceInvoker) Invoke added in v0.0.90 

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

type CreateTopicOrBatchDeleteTopicInvoker added in v0.0.90 

type CreateTopicOrBatchDeleteTopicInvoker struct {
	*invoker.BaseInvoker
}

func (*CreateTopicOrBatchDeleteTopicInvoker) Invoke added in v0.0.90 

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

type CreateUserInvoker added in v0.0.90 

type CreateUserInvoker struct {
	*invoker.BaseInvoker
}

func (*CreateUserInvoker) Invoke added in v0.0.90 

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

type DeleteConsumerGroupInvoker added in v0.0.90 

type DeleteConsumerGroupInvoker struct {
	*invoker.BaseInvoker
}

func (*DeleteConsumerGroupInvoker) Invoke added in v0.0.90 

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

type DeleteInstanceInvoker added in v0.0.90 

type DeleteInstanceInvoker struct {
	*invoker.BaseInvoker
}

func (*DeleteInstanceInvoker) Invoke added in v0.0.90 

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

type DeleteTopicInvoker added in v0.0.90 

type DeleteTopicInvoker struct {
	*invoker.BaseInvoker
}

func (*DeleteTopicInvoker) Invoke added in v0.0.90 

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

type DeleteUserInvoker added in v0.0.90 

type DeleteUserInvoker struct {
	*invoker.BaseInvoker
}

func (*DeleteUserInvoker) Invoke added in v0.0.90 

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

type ExportDlqMessageInvoker added in v0.0.90 

type ExportDlqMessageInvoker struct {
	*invoker.BaseInvoker
}

func (*ExportDlqMessageInvoker) Invoke added in v0.0.90 

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

type ListAvailableZonesInvoker added in v0.0.90 

type ListAvailableZonesInvoker struct {
	*invoker.BaseInvoker
}

func (*ListAvailableZonesInvoker) Invoke added in v0.0.90 

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

type ListBrokersInvoker added in v0.0.90 

type ListBrokersInvoker struct {
	*invoker.BaseInvoker
}

func (*ListBrokersInvoker) Invoke added in v0.0.90 

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

type ListConsumeGroupAccessPolicyInvoker added in v0.0.90 

type ListConsumeGroupAccessPolicyInvoker struct {
	*invoker.BaseInvoker
}

func (*ListConsumeGroupAccessPolicyInvoker) Invoke added in v0.0.90 

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

type ListConsumerGroupOfTopicInvoker added in v0.0.90 

type ListConsumerGroupOfTopicInvoker struct {
	*invoker.BaseInvoker
}

func (*ListConsumerGroupOfTopicInvoker) Invoke added in v0.0.90 

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

type ListInstanceConsumerGroupsInvoker added in v0.0.90 

type ListInstanceConsumerGroupsInvoker struct {
	*invoker.BaseInvoker
}

func (*ListInstanceConsumerGroupsInvoker) Invoke added in v0.0.90 

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

type ListInstancesInvoker added in v0.0.90 

type ListInstancesInvoker struct {
	*invoker.BaseInvoker
}

func (*ListInstancesInvoker) Invoke added in v0.0.90 

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

type ListMessageTraceInvoker added in v0.0.90 

type ListMessageTraceInvoker struct {
	*invoker.BaseInvoker
}

func (*ListMessageTraceInvoker) Invoke added in v0.0.90 

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

type ListMessagesInvoker added in v0.0.90 

type ListMessagesInvoker struct {
	*invoker.BaseInvoker
}

func (*ListMessagesInvoker) Invoke added in v0.0.90 

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

type ListRocketInstanceTopicsInvoker added in v0.1.22 

type ListRocketInstanceTopicsInvoker struct {
	*invoker.BaseInvoker
}

func (*ListRocketInstanceTopicsInvoker) Invoke added in v0.1.22 

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

type ListTopicAccessPolicyInvoker added in v0.0.90 

type ListTopicAccessPolicyInvoker struct {
	*invoker.BaseInvoker
}

func (*ListTopicAccessPolicyInvoker) Invoke added in v0.0.90 

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

type ListUserInvoker added in v0.0.90 

type ListUserInvoker struct {
	*invoker.BaseInvoker
}

func (*ListUserInvoker) Invoke added in v0.0.90 

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

type ResetConsumeOffsetInvoker added in v0.0.90 

type ResetConsumeOffsetInvoker struct {
	*invoker.BaseInvoker
}

func (*ResetConsumeOffsetInvoker) Invoke added in v0.0.90 

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) BatchDeleteInstances 

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

BatchDeleteInstances 批量删除实例

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

Please refer to HUAWEI cloud API Explorer for details.

func (*RocketMQClient) BatchDeleteInstancesInvoker added in v0.0.90 

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 added in v0.0.90 

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 added in v0.0.90 

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

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

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 added in v0.0.90 

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

CreatePostPaidInstanceInvoker 创建实例（按需）

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 added in v0.0.90 

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 added in v0.0.90 

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 added in v0.0.90 

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 added in v0.0.90 

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

DeleteInstanceInvoker 删除指定的实例

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 added in v0.0.90 

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 added in v0.0.90 

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 added in v0.0.90 

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 added in v0.0.90 

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 added in v0.0.90 

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 added in v0.0.90 

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 added in v0.0.90 

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 added in v0.0.90 

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 added in v0.0.90 

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 added in v0.0.90 

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 added in v0.0.90 

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

ListMessagesInvoker 查询消息

func (*RocketMQClient) ListRocketInstanceTopics added in v0.1.22 

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 added in v0.1.22 

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

ListRocketInstanceTopicsInvoker 查询主题列表

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 added in v0.0.90 

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 added in v0.0.90 

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 added in v0.0.90 

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

ResetConsumeOffsetInvoker 重置消费进度

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 added in v0.0.90 

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 added in v0.0.90 

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 added in v0.0.90 

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 added in v0.0.90 

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

ShowOneTopicInvoker 查询单个主题

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 added in v0.0.90 

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 added in v0.0.90 

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 added in v0.0.90 

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 added in v0.0.90 

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 added in v0.0.90 

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 added in v0.0.90 

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

UpdateUserInvoker 修改用户参数

type ShowConsumerListOrDetailsInvoker added in v0.0.90 

type ShowConsumerListOrDetailsInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowConsumerListOrDetailsInvoker) Invoke added in v0.0.90 

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

type ShowGroupInvoker added in v0.0.90 

type ShowGroupInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowGroupInvoker) Invoke added in v0.0.90 

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

type ShowInstanceInvoker added in v0.0.90 

type ShowInstanceInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowInstanceInvoker) Invoke added in v0.0.90 

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

type ShowOneTopicInvoker added in v0.0.90 

type ShowOneTopicInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowOneTopicInvoker) Invoke added in v0.0.90 

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

type ShowTopicStatusInvoker added in v0.0.90 

type ShowTopicStatusInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowTopicStatusInvoker) Invoke added in v0.0.90 

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

type ShowUserInvoker added in v0.0.90 

type ShowUserInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowUserInvoker) Invoke added in v0.0.90 

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

type UpdateConsumerGroupInvoker added in v0.0.90 

type UpdateConsumerGroupInvoker struct {
	*invoker.BaseInvoker
}

func (*UpdateConsumerGroupInvoker) Invoke added in v0.0.90 

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

type UpdateInstanceInvoker added in v0.0.90 

type UpdateInstanceInvoker struct {
	*invoker.BaseInvoker
}

func (*UpdateInstanceInvoker) Invoke added in v0.0.90 

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

type UpdateTopicInvoker added in v0.0.90 

type UpdateTopicInvoker struct {
	*invoker.BaseInvoker
}

func (*UpdateTopicInvoker) Invoke added in v0.0.90 

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

type UpdateUserInvoker added in v0.0.90 

type UpdateUserInvoker struct {
	*invoker.BaseInvoker
}

func (*UpdateUserInvoker) Invoke added in v0.0.90 

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