v2

package
v1.0.3 Latest Latest
Warning

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

 Go to latest Published: Dec 23, 2021 License: Apache-2.0, BSD-2-Clause, BSD-3-Clause Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GenReqDefForBatchCreateOrDeleteKafkaTag 

func GenReqDefForBatchCreateOrDeleteKafkaTag() *def.HttpRequestDef

func GenReqDefForBatchDeleteInstanceTopic 

func GenReqDefForBatchDeleteInstanceTopic() *def.HttpRequestDef

func GenReqDefForBatchDeleteInstanceUsers 

func GenReqDefForBatchDeleteInstanceUsers() *def.HttpRequestDef

func GenReqDefForBatchRestartOrDeleteInstances 

func GenReqDefForBatchRestartOrDeleteInstances() *def.HttpRequestDef

func GenReqDefForCreateConnector 

func GenReqDefForCreateConnector() *def.HttpRequestDef

func GenReqDefForCreateInstanceTopic 

func GenReqDefForCreateInstanceTopic() *def.HttpRequestDef

func GenReqDefForCreateInstanceUser 

func GenReqDefForCreateInstanceUser() *def.HttpRequestDef

func GenReqDefForCreatePartition 

func GenReqDefForCreatePartition() *def.HttpRequestDef

func GenReqDefForCreatePostPaidInstance 

func GenReqDefForCreatePostPaidInstance() *def.HttpRequestDef

func GenReqDefForCreateSinkTask 

func GenReqDefForCreateSinkTask() *def.HttpRequestDef

func GenReqDefForDeleteBackgroundTask 

func GenReqDefForDeleteBackgroundTask() *def.HttpRequestDef

func GenReqDefForDeleteInstance 

func GenReqDefForDeleteInstance() *def.HttpRequestDef

func GenReqDefForDeleteSinkTask 

func GenReqDefForDeleteSinkTask() *def.HttpRequestDef

func GenReqDefForListAvailableZones 

func GenReqDefForListAvailableZones() *def.HttpRequestDef

func GenReqDefForListBackgroundTasks 

func GenReqDefForListBackgroundTasks() *def.HttpRequestDef

func GenReqDefForListInstanceTopics 

func GenReqDefForListInstanceTopics() *def.HttpRequestDef

func GenReqDefForListInstances 

func GenReqDefForListInstances() *def.HttpRequestDef

func GenReqDefForListProducts 

func GenReqDefForListProducts() *def.HttpRequestDef

func GenReqDefForListSinkTasks 

func GenReqDefForListSinkTasks() *def.HttpRequestDef

func GenReqDefForResetManagerPassword 

func GenReqDefForResetManagerPassword() *def.HttpRequestDef

func GenReqDefForResetMessageOffset 

func GenReqDefForResetMessageOffset() *def.HttpRequestDef

func GenReqDefForResetPassword 

func GenReqDefForResetPassword() *def.HttpRequestDef

func GenReqDefForResetUserPasswrod 

func GenReqDefForResetUserPasswrod() *def.HttpRequestDef

func GenReqDefForResizeInstance 

func GenReqDefForResizeInstance() *def.HttpRequestDef

func GenReqDefForRestartManager 

func GenReqDefForRestartManager() *def.HttpRequestDef

func GenReqDefForShowBackgroundTask 

func GenReqDefForShowBackgroundTask() *def.HttpRequestDef

func GenReqDefForShowCesHierarchy 

func GenReqDefForShowCesHierarchy() *def.HttpRequestDef

func GenReqDefForShowCluster 

func GenReqDefForShowCluster() *def.HttpRequestDef

func GenReqDefForShowCoordinators 

func GenReqDefForShowCoordinators() *def.HttpRequestDef

func GenReqDefForShowGroups 

func GenReqDefForShowGroups() *def.HttpRequestDef

func GenReqDefForShowInstance 

func GenReqDefForShowInstance() *def.HttpRequestDef

func GenReqDefForShowInstanceExtendProductInfo 

func GenReqDefForShowInstanceExtendProductInfo() *def.HttpRequestDef

func GenReqDefForShowInstanceMessages 

func GenReqDefForShowInstanceMessages() *def.HttpRequestDef

func GenReqDefForShowInstanceTopicDetail 

func GenReqDefForShowInstanceTopicDetail() *def.HttpRequestDef

func GenReqDefForShowInstanceUsers 

func GenReqDefForShowInstanceUsers() *def.HttpRequestDef

func GenReqDefForShowKafkaProjectTags 

func GenReqDefForShowKafkaProjectTags() *def.HttpRequestDef

func GenReqDefForShowKafkaTags 

func GenReqDefForShowKafkaTags() *def.HttpRequestDef

func GenReqDefForShowKafkaTopicPartitionDiskusage 

func GenReqDefForShowKafkaTopicPartitionDiskusage() *def.HttpRequestDef

func GenReqDefForShowMaintainWindows 

func GenReqDefForShowMaintainWindows() *def.HttpRequestDef

func GenReqDefForShowMessages 

func GenReqDefForShowMessages() *def.HttpRequestDef

func GenReqDefForShowPartitionBeginningMessage 

func GenReqDefForShowPartitionBeginningMessage() *def.HttpRequestDef

func GenReqDefForShowPartitionEndMessage 

func GenReqDefForShowPartitionEndMessage() *def.HttpRequestDef

func GenReqDefForShowPartitionMessage 

func GenReqDefForShowPartitionMessage() *def.HttpRequestDef

func GenReqDefForShowSinkTaskDetail 

func GenReqDefForShowSinkTaskDetail() *def.HttpRequestDef

func GenReqDefForShowTopicAccessPolicy 

func GenReqDefForShowTopicAccessPolicy() *def.HttpRequestDef

func GenReqDefForUpdateInstance 

func GenReqDefForUpdateInstance() *def.HttpRequestDef

func GenReqDefForUpdateInstanceAutoCreateTopic 

func GenReqDefForUpdateInstanceAutoCreateTopic() *def.HttpRequestDef

func GenReqDefForUpdateInstanceCrossVpcIp 

func GenReqDefForUpdateInstanceCrossVpcIp() *def.HttpRequestDef

func GenReqDefForUpdateInstanceTopic 

func GenReqDefForUpdateInstanceTopic() *def.HttpRequestDef

func GenReqDefForUpdateSinkTaskQuota 

func GenReqDefForUpdateSinkTaskQuota() *def.HttpRequestDef

func GenReqDefForUpdateTopicAccessPolicy 

func GenReqDefForUpdateTopicAccessPolicy() *def.HttpRequestDef

func GenReqDefForUpdateTopicReplica 

func GenReqDefForUpdateTopicReplica() *def.HttpRequestDef

func KafkaClientBuilder 

func KafkaClientBuilder() *http_client.HcHttpClientBuilder

Types

type KafkaClient 

type KafkaClient struct {
	HcClient *http_client.HcHttpClient
}

func NewKafkaClient 

func NewKafkaClient(hcClient *http_client.HcHttpClient) *KafkaClient

func (*KafkaClient) BatchCreateOrDeleteKafkaTag 

func (c *KafkaClient) BatchCreateOrDeleteKafkaTag(request *model.BatchCreateOrDeleteKafkaTagRequest) (*model.BatchCreateOrDeleteKafkaTagResponse, error)

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

func (*KafkaClient) BatchDeleteInstanceTopic 

func (c *KafkaClient) BatchDeleteInstanceTopic(request *model.BatchDeleteInstanceTopicRequest) (*model.BatchDeleteInstanceTopicResponse, error)

该接口用于向Kafka实例批量删除Topic。

func (*KafkaClient) BatchDeleteInstanceUsers 

func (c *KafkaClient) BatchDeleteInstanceUsers(request *model.BatchDeleteInstanceUsersRequest) (*model.BatchDeleteInstanceUsersResponse, error)

批量删除Kafka实例的用户

func (*KafkaClient) BatchRestartOrDeleteInstances 

func (c *KafkaClient) BatchRestartOrDeleteInstances(request *model.BatchRestartOrDeleteInstancesRequest) (*model.BatchRestartOrDeleteInstancesResponse, error)

批量重启或删除实例。 在实例重启过程中，客户端的生产与消费消息等请求会被拒绝。 实例删除后，实例中原有的数据将被删除，且没有备份，请谨慎操作。

func (*KafkaClient) CreateConnector 

func (c *KafkaClient) CreateConnector(request *model.CreateConnectorRequest) (*model.CreateConnectorResponse, error)

创建实例的转储节点。

func (*KafkaClient) CreateInstanceTopic 

func (c *KafkaClient) CreateInstanceTopic(request *model.CreateInstanceTopicRequest) (*model.CreateInstanceTopicResponse, error)

该接口用于向Kafka实例创建Topic。

func (*KafkaClient) CreateInstanceUser 

func (c *KafkaClient) CreateInstanceUser(request *model.CreateInstanceUserRequest) (*model.CreateInstanceUserResponse, error)

创建Kafka实例的用户，用户可连接开启SASL的Kafka实例。

func (*KafkaClient) CreatePartition 

func (c *KafkaClient) CreatePartition(request *model.CreatePartitionRequest) (*model.CreatePartitionResponse, error)

新增Kafka实例指定Topic分区。

func (*KafkaClient) CreatePostPaidInstance 

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

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

func (*KafkaClient) CreateSinkTask 

func (c *KafkaClient) CreateSinkTask(request *model.CreateSinkTaskRequest) (*model.CreateSinkTaskResponse, error)

创建转储任务。

func (*KafkaClient) DeleteBackgroundTask 

func (c *KafkaClient) DeleteBackgroundTask(request *model.DeleteBackgroundTaskRequest) (*model.DeleteBackgroundTaskResponse, error)

删除后台任务管理中的指定记录。

func (*KafkaClient) DeleteInstance 

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

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

func (*KafkaClient) DeleteSinkTask 

func (c *KafkaClient) DeleteSinkTask(request *model.DeleteSinkTaskRequest) (*model.DeleteSinkTaskResponse, error)

删除单个转储任务。

func (*KafkaClient) ListAvailableZones 

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

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

func (*KafkaClient) ListBackgroundTasks 

func (c *KafkaClient) ListBackgroundTasks(request *model.ListBackgroundTasksRequest) (*model.ListBackgroundTasksResponse, error)

查询实例的后台任务列表。

func (*KafkaClient) ListInstanceTopics 

func (c *KafkaClient) ListInstanceTopics(request *model.ListInstanceTopicsRequest) (*model.ListInstanceTopicsResponse, error)

该接口用于查询指定Kafka实例的Topic详情。

func (*KafkaClient) ListInstances 

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

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

func (*KafkaClient) ListProducts 

func (c *KafkaClient) ListProducts(request *model.ListProductsRequest) (*model.ListProductsResponse, error)

在创建kafka实例时，需要配置订购的产品ID（即product_id），可通过该接口查询产品规格。 例如，要订购按需计费、基准带宽为100MB的kafka实例，可从接口响应消息中，查找Hourly的消息体，然后找到bandwidth为100MB的记录对应的product_id，该product_id的值即是创建上述kafka实例时需要配置的产品ID。 同时，unavailable_zones字段表示资源不足的可用区列表，如果为空，则表示所有可用区都有资源，如果不为空，则表示字段值的可用区没有资源。所以必须确保您购买的资源所在的可用区有资源，不在该字段列表内。 例如，响应消息中bandwidth字段为1200MB的记录，unavailable_zones字段包含cn-east-2b、cn-east-2a和cn-east-2d，表示在华东-上海2的可用区1、可用区2、可用区3都没有该资源。

func (*KafkaClient) ListSinkTasks 

func (c *KafkaClient) ListSinkTasks(request *model.ListSinkTasksRequest) (*model.ListSinkTasksResponse, error)

查询转储任务列表。

func (*KafkaClient) ResetManagerPassword 

func (c *KafkaClient) ResetManagerPassword(request *model.ResetManagerPasswordRequest) (*model.ResetManagerPasswordResponse, error)

重置Manager密码。

func (*KafkaClient) ResetMessageOffset 

func (c *KafkaClient) ResetMessageOffset(request *model.ResetMessageOffsetRequest) (*model.ResetMessageOffsetResponse, error)

Kafka实例不支持在线重置消费进度。在执行重置消费进度之前，必须停止被重置消费组客户端。 > 在停止被重置消费组客户端后，需要经过ConsumerConfig.SESSION_TIMEOUT_MS_CONFIG配置的时间（默认10000毫秒），服务端才认为消费组客户端真正下线。

func (*KafkaClient) ResetPassword 

func (c *KafkaClient) ResetPassword(request *model.ResetPasswordRequest) (*model.ResetPasswordResponse, error)

重置密码。

func (*KafkaClient) ResetUserPasswrod 

func (c *KafkaClient) ResetUserPasswrod(request *model.ResetUserPasswrodRequest) (*model.ResetUserPasswrodResponse, error)

重置用户密码

func (*KafkaClient) ResizeInstance 

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

实例规格变更。

func (*KafkaClient) RestartManager 

func (c *KafkaClient) RestartManager(request *model.RestartManagerRequest) (*model.RestartManagerResponse, error)

重启Manager。

func (*KafkaClient) ShowBackgroundTask 

func (c *KafkaClient) ShowBackgroundTask(request *model.ShowBackgroundTaskRequest) (*model.ShowBackgroundTaskResponse, error)

查询后台任务管理中的指定记录。

func (*KafkaClient) ShowCesHierarchy 

func (c *KafkaClient) ShowCesHierarchy(request *model.ShowCesHierarchyRequest) (*model.ShowCesHierarchyResponse, error)

查询实例在CES的监控层级关系。

func (*KafkaClient) ShowCluster 

func (c *KafkaClient) ShowCluster(request *model.ShowClusterRequest) (*model.ShowClusterResponse, error)

查询Kafka集群元数据信息。

func (*KafkaClient) ShowCoordinators 

func (c *KafkaClient) ShowCoordinators(request *model.ShowCoordinatorsRequest) (*model.ShowCoordinatorsResponse, error)

查询Kafka实例的协调器信息。

func (*KafkaClient) ShowGroups 

func (c *KafkaClient) ShowGroups(request *model.ShowGroupsRequest) (*model.ShowGroupsResponse, error)

查询消费组信息。

func (*KafkaClient) ShowInstance 

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

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

func (*KafkaClient) ShowInstanceExtendProductInfo 

func (c *KafkaClient) ShowInstanceExtendProductInfo(request *model.ShowInstanceExtendProductInfoRequest) (*model.ShowInstanceExtendProductInfoResponse, error)

查询实例的扩容规格列表。

func (*KafkaClient) ShowInstanceMessages 

func (c *KafkaClient) ShowInstanceMessages(request *model.ShowInstanceMessagesRequest) (*model.ShowInstanceMessagesResponse, error)

查询消息的偏移量和消息内容。 先根据时间戳查询消息的偏移量，再根据偏移量查询消息内容。 **注意：调用接口时message_offset和partition查询参数二选一。**

func (*KafkaClient) ShowInstanceTopicDetail 

func (c *KafkaClient) ShowInstanceTopicDetail(request *model.ShowInstanceTopicDetailRequest) (*model.ShowInstanceTopicDetailResponse, error)

查询Kafka实例Topic详细信息。

func (*KafkaClient) ShowInstanceUsers 

func (c *KafkaClient) ShowInstanceUsers(request *model.ShowInstanceUsersRequest) (*model.ShowInstanceUsersResponse, error)

查询用户列表。 Kafka实例开启SASL功能时，才支持多用户管理的功能。

func (*KafkaClient) ShowKafkaProjectTags 

func (c *KafkaClient) ShowKafkaProjectTags(request *model.ShowKafkaProjectTagsRequest) (*model.ShowKafkaProjectTagsResponse, error)

查询项目标签。

func (*KafkaClient) ShowKafkaTags 

func (c *KafkaClient) ShowKafkaTags(request *model.ShowKafkaTagsRequest) (*model.ShowKafkaTagsResponse, error)

查询实例标签。

func (*KafkaClient) ShowKafkaTopicPartitionDiskusage 

func (c *KafkaClient) ShowKafkaTopicPartitionDiskusage(request *model.ShowKafkaTopicPartitionDiskusageRequest) (*model.ShowKafkaTopicPartitionDiskusageResponse, error)

查询topic在Broker上磁盘占用情况。

func (*KafkaClient) ShowMaintainWindows 

func (c *KafkaClient) ShowMaintainWindows(request *model.ShowMaintainWindowsRequest) (*model.ShowMaintainWindowsResponse, error)

查询维护时间窗开始时间和结束时间。

func (*KafkaClient) ShowMessages 

func (c *KafkaClient) ShowMessages(request *model.ShowMessagesRequest) (*model.ShowMessagesResponse, error)

查询分区指定时间段的消息。

func (*KafkaClient) ShowPartitionBeginningMessage 

func (c *KafkaClient) ShowPartitionBeginningMessage(request *model.ShowPartitionBeginningMessageRequest) (*model.ShowPartitionBeginningMessageResponse, error)

查询分区最早消息的位置。

func (*KafkaClient) ShowPartitionEndMessage 

func (c *KafkaClient) ShowPartitionEndMessage(request *model.ShowPartitionEndMessageRequest) (*model.ShowPartitionEndMessageResponse, error)

查询分区最新消息的位置。

func (*KafkaClient) ShowPartitionMessage 

func (c *KafkaClient) ShowPartitionMessage(request *model.ShowPartitionMessageRequest) (*model.ShowPartitionMessageResponse, error)

查询分区指定偏移量的消息。

func (*KafkaClient) ShowSinkTaskDetail 

func (c *KafkaClient) ShowSinkTaskDetail(request *model.ShowSinkTaskDetailRequest) (*model.ShowSinkTaskDetailResponse, error)

查询单个转储任务。

func (*KafkaClient) ShowTopicAccessPolicy 

func (c *KafkaClient) ShowTopicAccessPolicy(request *model.ShowTopicAccessPolicyRequest) (*model.ShowTopicAccessPolicyResponse, error)

查询用户权限。 Kafka实例开启SASL功能时，才支持多用户管理的功能。

func (*KafkaClient) UpdateInstance 

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

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

func (*KafkaClient) UpdateInstanceAutoCreateTopic 

func (c *KafkaClient) UpdateInstanceAutoCreateTopic(request *model.UpdateInstanceAutoCreateTopicRequest) (*model.UpdateInstanceAutoCreateTopicResponse, error)

开启或关闭实例自动创建topic功能。

func (*KafkaClient) UpdateInstanceCrossVpcIp 

func (c *KafkaClient) UpdateInstanceCrossVpcIp(request *model.UpdateInstanceCrossVpcIpRequest) (*model.UpdateInstanceCrossVpcIpResponse, error)

修改实例跨VPC访问的内网IP。

func (*KafkaClient) UpdateInstanceTopic 

func (c *KafkaClient) UpdateInstanceTopic(request *model.UpdateInstanceTopicRequest) (*model.UpdateInstanceTopicResponse, error)

修改Kafka实例Topic

func (*KafkaClient) UpdateSinkTaskQuota 

func (c *KafkaClient) UpdateSinkTaskQuota(request *model.UpdateSinkTaskQuotaRequest) (*model.UpdateSinkTaskQuotaResponse, error)

修改转储任务的配额。

func (*KafkaClient) UpdateTopicAccessPolicy 

func (c *KafkaClient) UpdateTopicAccessPolicy(request *model.UpdateTopicAccessPolicyRequest) (*model.UpdateTopicAccessPolicyResponse, error)

设置用户权限。 Kafka实例开启SASL功能时，才支持多用户管理的功能。

func (*KafkaClient) UpdateTopicReplica 

func (c *KafkaClient) UpdateTopicReplica(request *model.UpdateTopicReplicaRequest) (*model.UpdateTopicReplicaResponse, error)

修改Kafka实例Topic分区的副本。

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.