v2

Oct 17, 2024

Changes in this version

type BatchCreateOrDeleteRocketmqTagInvoker

+ func (i *BatchCreateOrDeleteRocketmqTagInvoker) GetBaseInvoker() *invoker.BaseInvoker

type BatchDeleteInstancesInvoker

+ func (i *BatchDeleteInstancesInvoker) GetBaseInvoker() *invoker.BaseInvoker

type BatchUpdateConsumerGroupInvoker

+ func (i *BatchUpdateConsumerGroupInvoker) GetBaseInvoker() *invoker.BaseInvoker

type CreateConsumerGroupOrBatchDeleteConsumerGroupInvoker

+ func (i *CreateConsumerGroupOrBatchDeleteConsumerGroupInvoker) GetBaseInvoker() *invoker.BaseInvoker

type CreateInstanceByEngineInvoker

+ func (i *CreateInstanceByEngineInvoker) GetBaseInvoker() *invoker.BaseInvoker

type CreatePostPaidInstanceInvoker

+ func (i *CreatePostPaidInstanceInvoker) GetBaseInvoker() *invoker.BaseInvoker

type CreateRocketMqMigrationTaskInvoker

+ func (i *CreateRocketMqMigrationTaskInvoker) GetBaseInvoker() *invoker.BaseInvoker

type CreateTopicOrBatchDeleteTopicInvoker

+ func (i *CreateTopicOrBatchDeleteTopicInvoker) GetBaseInvoker() *invoker.BaseInvoker

type CreateUserInvoker

+ func (i *CreateUserInvoker) GetBaseInvoker() *invoker.BaseInvoker

type DeleteConsumerGroupInvoker

+ func (i *DeleteConsumerGroupInvoker) GetBaseInvoker() *invoker.BaseInvoker

type DeleteInstanceInvoker

+ func (i *DeleteInstanceInvoker) GetBaseInvoker() *invoker.BaseInvoker

type DeleteRocketMqMigrationTaskInvoker

+ func (i *DeleteRocketMqMigrationTaskInvoker) GetBaseInvoker() *invoker.BaseInvoker

type DeleteTopicInvoker

+ func (i *DeleteTopicInvoker) GetBaseInvoker() *invoker.BaseInvoker

type DeleteUserInvoker

+ func (i *DeleteUserInvoker) GetBaseInvoker() *invoker.BaseInvoker

type ExportDlqMessageInvoker

+ func (i *ExportDlqMessageInvoker) GetBaseInvoker() *invoker.BaseInvoker

type ListAvailableZonesInvoker

+ func (i *ListAvailableZonesInvoker) GetBaseInvoker() *invoker.BaseInvoker

type ListBrokersInvoker

+ func (i *ListBrokersInvoker) GetBaseInvoker() *invoker.BaseInvoker

type ListConsumeGroupAccessPolicyInvoker

+ func (i *ListConsumeGroupAccessPolicyInvoker) GetBaseInvoker() *invoker.BaseInvoker

type ListConsumerGroupOfTopicInvoker

+ func (i *ListConsumerGroupOfTopicInvoker) GetBaseInvoker() *invoker.BaseInvoker

type ListInstanceConsumerGroupsInvoker

+ func (i *ListInstanceConsumerGroupsInvoker) GetBaseInvoker() *invoker.BaseInvoker

type ListInstancesInvoker

+ func (i *ListInstancesInvoker) GetBaseInvoker() *invoker.BaseInvoker

type ListMessageTraceInvoker

+ func (i *ListMessageTraceInvoker) GetBaseInvoker() *invoker.BaseInvoker

type ListMessagesInvoker

+ func (i *ListMessagesInvoker) GetBaseInvoker() *invoker.BaseInvoker

type ListRocketInstanceTopicsInvoker

+ func (i *ListRocketInstanceTopicsInvoker) GetBaseInvoker() *invoker.BaseInvoker

type ListRocketMqMigrationTaskInvoker

+ func (i *ListRocketMqMigrationTaskInvoker) GetBaseInvoker() *invoker.BaseInvoker

type ListTopicAccessPolicyInvoker

+ func (i *ListTopicAccessPolicyInvoker) GetBaseInvoker() *invoker.BaseInvoker

type ListUserInvoker

+ func (i *ListUserInvoker) GetBaseInvoker() *invoker.BaseInvoker

type ResetConsumeOffsetInvoker

+ func (i *ResetConsumeOffsetInvoker) GetBaseInvoker() *invoker.BaseInvoker

type ResizeInstanceInvoker

+ func (i *ResizeInstanceInvoker) GetBaseInvoker() *invoker.BaseInvoker

type SendDlqMessageInvoker

+ func (i *SendDlqMessageInvoker) GetBaseInvoker() *invoker.BaseInvoker

type ShowConsumerConnectionsInvoker

+ func (i *ShowConsumerConnectionsInvoker) GetBaseInvoker() *invoker.BaseInvoker

type ShowConsumerListOrDetailsInvoker

+ func (i *ShowConsumerListOrDetailsInvoker) GetBaseInvoker() *invoker.BaseInvoker

type ShowEngineInstanceExtendProductInfoInvoker

+ func (i *ShowEngineInstanceExtendProductInfoInvoker) GetBaseInvoker() *invoker.BaseInvoker

type ShowGroupInvoker

+ func (i *ShowGroupInvoker) GetBaseInvoker() *invoker.BaseInvoker

type ShowInstanceInvoker

+ func (i *ShowInstanceInvoker) GetBaseInvoker() *invoker.BaseInvoker

type ShowOneTopicInvoker

+ func (i *ShowOneTopicInvoker) GetBaseInvoker() *invoker.BaseInvoker

type ShowRocketMqConfigsInvoker

+ func (i *ShowRocketMqConfigsInvoker) GetBaseInvoker() *invoker.BaseInvoker

type ShowRocketmqProjectTagsInvoker

+ func (i *ShowRocketmqProjectTagsInvoker) GetBaseInvoker() *invoker.BaseInvoker

type ShowRocketmqTagsInvoker

+ func (i *ShowRocketmqTagsInvoker) GetBaseInvoker() *invoker.BaseInvoker

type ShowTopicStatusInvoker

+ func (i *ShowTopicStatusInvoker) GetBaseInvoker() *invoker.BaseInvoker

type ShowUserInvoker

+ func (i *ShowUserInvoker) GetBaseInvoker() *invoker.BaseInvoker

type UpdateConsumerGroupInvoker

+ func (i *UpdateConsumerGroupInvoker) GetBaseInvoker() *invoker.BaseInvoker

type UpdateInstanceInvoker

+ func (i *UpdateInstanceInvoker) GetBaseInvoker() *invoker.BaseInvoker

type UpdateRocketMqConfigsInvoker

+ func (i *UpdateRocketMqConfigsInvoker) GetBaseInvoker() *invoker.BaseInvoker

type UpdateTopicInvoker

+ func (i *UpdateTopicInvoker) GetBaseInvoker() *invoker.BaseInvoker

type UpdateUserInvoker

+ func (i *UpdateUserInvoker) GetBaseInvoker() *invoker.BaseInvoker

type ValidateConsumedMessageInvoker

+ func (i *ValidateConsumedMessageInvoker) GetBaseInvoker() *invoker.BaseInvoker

Dec 7, 2023

Changes in this version

+ func GenReqDefForShowRocketMqConfigs() *def.HttpRequestDef

+ func GenReqDefForUpdateRocketMqConfigs() *def.HttpRequestDef

type RocketMQClient

+ func (c *RocketMQClient) ShowRocketMqConfigs(request *model.ShowRocketMqConfigsRequest) (*model.ShowRocketMqConfigsResponse, error)

+ func (c *RocketMQClient) ShowRocketMqConfigsInvoker(request *model.ShowRocketMqConfigsRequest) *ShowRocketMqConfigsInvoker

+ func (c *RocketMQClient) UpdateRocketMqConfigs(request *model.UpdateRocketMqConfigsRequest) (*model.UpdateRocketMqConfigsResponse, error)

+ func (c *RocketMQClient) UpdateRocketMqConfigsInvoker(request *model.UpdateRocketMqConfigsRequest) *UpdateRocketMqConfigsInvoker

+ type ShowRocketMqConfigsInvoker struct

+ func (i *ShowRocketMqConfigsInvoker) Invoke() (*model.ShowRocketMqConfigsResponse, error)

+ type UpdateRocketMqConfigsInvoker struct

+ func (i *UpdateRocketMqConfigsInvoker) Invoke() (*model.UpdateRocketMqConfigsResponse, error)

Nov 30, 2023

Changes in this version

+ func GenReqDefForResizeInstance() *def.HttpRequestDef

+ func GenReqDefForShowEngineInstanceExtendProductInfo() *def.HttpRequestDef

+ type ResizeInstanceInvoker struct

+ func (i *ResizeInstanceInvoker) Invoke() (*model.ResizeInstanceResponse, error)

type RocketMQClient

+ func (c *RocketMQClient) ResizeInstance(request *model.ResizeInstanceRequest) (*model.ResizeInstanceResponse, error)

+ func (c *RocketMQClient) ResizeInstanceInvoker(request *model.ResizeInstanceRequest) *ResizeInstanceInvoker

+ func (c *RocketMQClient) ShowEngineInstanceExtendProductInfo(request *model.ShowEngineInstanceExtendProductInfoRequest) (*model.ShowEngineInstanceExtendProductInfoResponse, error)

+ func (c *RocketMQClient) ShowEngineInstanceExtendProductInfoInvoker(request *model.ShowEngineInstanceExtendProductInfoRequest) *ShowEngineInstanceExtendProductInfoInvoker

+ type ShowEngineInstanceExtendProductInfoInvoker struct

+ func (i *ShowEngineInstanceExtendProductInfoInvoker) Invoke() (*model.ShowEngineInstanceExtendProductInfoResponse, error)

Jun 8, 2023

Changes in this version

+ func GenReqDefForSendDlqMessage() *def.HttpRequestDef

+ func GenReqDefForValidateConsumedMessage() *def.HttpRequestDef

type RocketMQClient

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

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

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

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

+ type SendDlqMessageInvoker struct

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

+ type ValidateConsumedMessageInvoker struct

+ func (i *ValidateConsumedMessageInvoker) Invoke() (*model.ValidateConsumedMessageResponse, error)

Jun 1, 2023

Changes in this version

+ func GenReqDefForCreateRocketMqMigrationTask() *def.HttpRequestDef

+ func GenReqDefForDeleteRocketMqMigrationTask() *def.HttpRequestDef

+ func GenReqDefForListRocketMqMigrationTask() *def.HttpRequestDef

+ func GenReqDefForSendRocketMqDlqMessage() *def.HttpRequestDef

+ func GenReqDefForValidateRocketMqConsumedMessage() *def.HttpRequestDef

+ type CreateRocketMqMigrationTaskInvoker struct

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

+ type DeleteRocketMqMigrationTaskInvoker struct

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

+ type ListRocketMqMigrationTaskInvoker struct

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

type RocketMQClient

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

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

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

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

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

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

+ func (c *RocketMQClient) SendRocketMqDlqMessage(request *model.SendRocketMqDlqMessageRequest) (*model.SendRocketMqDlqMessageResponse, error)

+ func (c *RocketMQClient) SendRocketMqDlqMessageInvoker(request *model.SendRocketMqDlqMessageRequest) *SendRocketMqDlqMessageInvoker

+ func (c *RocketMQClient) ValidateRocketMqConsumedMessage(request *model.ValidateRocketMqConsumedMessageRequest) (*model.ValidateRocketMqConsumedMessageResponse, error)

+ func (c *RocketMQClient) ValidateRocketMqConsumedMessageInvoker(request *model.ValidateRocketMqConsumedMessageRequest) *ValidateRocketMqConsumedMessageInvoker

+ type SendRocketMqDlqMessageInvoker struct

+ func (i *SendRocketMqDlqMessageInvoker) Invoke() (*model.SendRocketMqDlqMessageResponse, error)

+ type ValidateRocketMqConsumedMessageInvoker struct

+ func (i *ValidateRocketMqConsumedMessageInvoker) Invoke() (*model.ValidateRocketMqConsumedMessageResponse, error)

Apr 20, 2023

Changes in this version

+ func GenReqDefForShowConsumerConnections() *def.HttpRequestDef

type RocketMQClient

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

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

+ type ShowConsumerConnectionsInvoker struct

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

Feb 16, 2023

Changes in this version

+ func GenReqDefForBatchCreateOrDeleteRocketmqTag() *def.HttpRequestDef

+ func GenReqDefForCreateInstanceByEngine() *def.HttpRequestDef

+ func GenReqDefForShowRocketmqProjectTags() *def.HttpRequestDef

+ func GenReqDefForShowRocketmqTags() *def.HttpRequestDef

+ type BatchCreateOrDeleteRocketmqTagInvoker struct

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

+ type CreateInstanceByEngineInvoker struct

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

type RocketMQClient

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

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

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

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

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

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

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

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

+ type ShowRocketmqProjectTagsInvoker struct

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

+ type ShowRocketmqTagsInvoker struct

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

Jan 12, 2023

Changes in this version

+ func GenReqDefForListRocketInstanceTopics() *def.HttpRequestDef

+ type ListRocketInstanceTopicsInvoker struct

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

type RocketMQClient

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

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

May 26, 2022

Changes in this version

+ type BatchDeleteInstancesInvoker struct

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

+ type BatchUpdateConsumerGroupInvoker struct

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

+ type CreateConsumerGroupOrBatchDeleteConsumerGroupInvoker struct

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

+ type CreatePostPaidInstanceInvoker struct

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

+ type CreateTopicOrBatchDeleteTopicInvoker struct

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

+ type CreateUserInvoker struct

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

+ type DeleteConsumerGroupInvoker struct

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

+ type DeleteInstanceInvoker struct

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

+ type DeleteTopicInvoker struct

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

+ type DeleteUserInvoker struct

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

+ type ExportDlqMessageInvoker struct

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

+ type ListAvailableZonesInvoker struct

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

+ type ListBrokersInvoker struct

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

+ type ListConsumeGroupAccessPolicyInvoker struct

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

+ type ListConsumerGroupOfTopicInvoker struct

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

+ type ListInstanceConsumerGroupsInvoker struct

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

+ type ListInstancesInvoker struct

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

+ type ListMessageTraceInvoker struct

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

+ type ListMessagesInvoker struct

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

+ type ListTopicAccessPolicyInvoker struct

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

+ type ListUserInvoker struct

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

+ type ResetConsumeOffsetInvoker struct

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

type RocketMQClient

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ type ShowConsumerListOrDetailsInvoker struct

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

+ type ShowGroupInvoker struct

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

+ type ShowInstanceInvoker struct

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

+ type ShowOneTopicInvoker struct

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

+ type ShowTopicStatusInvoker struct

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

+ type ShowUserInvoker struct

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

+ type UpdateConsumerGroupInvoker struct

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

+ type UpdateInstanceInvoker struct

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

+ type UpdateTopicInvoker struct

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

+ type UpdateUserInvoker struct

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

May 13, 2022

Changes in this version

+ func GenReqDefForBatchDeleteInstances() *def.HttpRequestDef

+ func GenReqDefForBatchUpdateConsumerGroup() *def.HttpRequestDef

+ func GenReqDefForCreateConsumerGroupOrBatchDeleteConsumerGroup() *def.HttpRequestDef

+ func GenReqDefForCreatePostPaidInstance() *def.HttpRequestDef

+ func GenReqDefForCreateTopicOrBatchDeleteTopic() *def.HttpRequestDef

+ func GenReqDefForCreateUser() *def.HttpRequestDef

+ func GenReqDefForDeleteConsumerGroup() *def.HttpRequestDef

+ func GenReqDefForDeleteInstance() *def.HttpRequestDef

+ func GenReqDefForDeleteTopic() *def.HttpRequestDef

+ func GenReqDefForDeleteUser() *def.HttpRequestDef

+ func GenReqDefForExportDlqMessage() *def.HttpRequestDef

+ func GenReqDefForListAvailableZones() *def.HttpRequestDef

+ func GenReqDefForListBrokers() *def.HttpRequestDef

+ func GenReqDefForListConsumeGroupAccessPolicy() *def.HttpRequestDef

+ func GenReqDefForListConsumerGroupOfTopic() *def.HttpRequestDef

+ func GenReqDefForListInstanceConsumerGroups() *def.HttpRequestDef

+ func GenReqDefForListInstances() *def.HttpRequestDef

+ func GenReqDefForListMessageTrace() *def.HttpRequestDef

+ func GenReqDefForListMessages() *def.HttpRequestDef

+ func GenReqDefForListTopicAccessPolicy() *def.HttpRequestDef

+ func GenReqDefForListUser() *def.HttpRequestDef

+ func GenReqDefForResetConsumeOffset() *def.HttpRequestDef

+ func GenReqDefForShowConsumerListOrDetails() *def.HttpRequestDef

+ func GenReqDefForShowGroup() *def.HttpRequestDef

+ func GenReqDefForShowInstance() *def.HttpRequestDef

+ func GenReqDefForShowOneTopic() *def.HttpRequestDef

+ func GenReqDefForShowTopicStatus() *def.HttpRequestDef

+ func GenReqDefForShowUser() *def.HttpRequestDef

+ func GenReqDefForUpdateConsumerGroup() *def.HttpRequestDef

+ func GenReqDefForUpdateInstance() *def.HttpRequestDef

+ func GenReqDefForUpdateTopic() *def.HttpRequestDef

+ func GenReqDefForUpdateUser() *def.HttpRequestDef

+ func RocketMQClientBuilder() *http_client.HcHttpClientBuilder

+ type RocketMQClient struct

+ HcClient *http_client.HcHttpClient

+ func NewRocketMQClient(hcClient *http_client.HcHttpClient) *RocketMQClient

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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