v2

package
v0.1.76 Latest Latest
Warning

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

 Go to latest Published: Jan 4, 2024 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 DisClientBuilder 

func DisClientBuilder() *http_client.HcHttpClientBuilder

func GenReqDefForBatchCreateTags added in v0.1.72 

func GenReqDefForBatchCreateTags() *def.HttpRequestDef

func GenReqDefForBatchDeleteTags added in v0.1.72 

func GenReqDefForBatchDeleteTags() *def.HttpRequestDef

func GenReqDefForBatchStartTransferTask added in v0.1.72 

func GenReqDefForBatchStartTransferTask() *def.HttpRequestDef

func GenReqDefForBatchStopTransferTask added in v0.1.72 

func GenReqDefForBatchStopTransferTask() *def.HttpRequestDef

func GenReqDefForCommitCheckpoint added in v0.1.72 

func GenReqDefForCommitCheckpoint() *def.HttpRequestDef

func GenReqDefForConsumeRecords added in v0.1.72 

func GenReqDefForConsumeRecords() *def.HttpRequestDef

func GenReqDefForCreateApp added in v0.1.72 

func GenReqDefForCreateApp() *def.HttpRequestDef

func GenReqDefForCreateObsTransferTask added in v0.1.72 

func GenReqDefForCreateObsTransferTask() *def.HttpRequestDef

func GenReqDefForCreateStream added in v0.1.72 

func GenReqDefForCreateStream() *def.HttpRequestDef

func GenReqDefForCreateTag added in v0.1.72 

func GenReqDefForCreateTag() *def.HttpRequestDef

func GenReqDefForDeleteApp added in v0.1.72 

func GenReqDefForDeleteApp() *def.HttpRequestDef

func GenReqDefForDeleteCheckpoint added in v0.1.72 

func GenReqDefForDeleteCheckpoint() *def.HttpRequestDef

func GenReqDefForDeleteStream added in v0.1.72 

func GenReqDefForDeleteStream() *def.HttpRequestDef

func GenReqDefForDeleteTag added in v0.1.72 

func GenReqDefForDeleteTag() *def.HttpRequestDef

func GenReqDefForDeleteTransferTask added in v0.1.72 

func GenReqDefForDeleteTransferTask() *def.HttpRequestDef

func GenReqDefForListApp added in v0.1.72 

func GenReqDefForListApp() *def.HttpRequestDef

func GenReqDefForListPolicies added in v0.1.72 

func GenReqDefForListPolicies() *def.HttpRequestDef

func GenReqDefForListResourcesByTags added in v0.1.72 

func GenReqDefForListResourcesByTags() *def.HttpRequestDef

func GenReqDefForListStreams added in v0.1.72 

func GenReqDefForListStreams() *def.HttpRequestDef

func GenReqDefForListTags added in v0.1.72 

func GenReqDefForListTags() *def.HttpRequestDef

func GenReqDefForListTransferTasks added in v0.1.72 

func GenReqDefForListTransferTasks() *def.HttpRequestDef

func GenReqDefForSendRecords added in v0.1.72 

func GenReqDefForSendRecords() *def.HttpRequestDef

func GenReqDefForShowApp added in v0.1.72 

func GenReqDefForShowApp() *def.HttpRequestDef

func GenReqDefForShowCheckpoint added in v0.1.72 

func GenReqDefForShowCheckpoint() *def.HttpRequestDef

func GenReqDefForShowConsumerState added in v0.1.72 

func GenReqDefForShowConsumerState() *def.HttpRequestDef

func GenReqDefForShowCursor added in v0.1.72 

func GenReqDefForShowCursor() *def.HttpRequestDef

func GenReqDefForShowPartitionMetrics added in v0.1.72 

func GenReqDefForShowPartitionMetrics() *def.HttpRequestDef

func GenReqDefForShowStream added in v0.1.72 

func GenReqDefForShowStream() *def.HttpRequestDef

func GenReqDefForShowStreamMetrics added in v0.1.72 

func GenReqDefForShowStreamMetrics() *def.HttpRequestDef

func GenReqDefForShowStreamTags added in v0.1.72 

func GenReqDefForShowStreamTags() *def.HttpRequestDef

func GenReqDefForShowTransferTask added in v0.1.72 

func GenReqDefForShowTransferTask() *def.HttpRequestDef

func GenReqDefForUpdatePartitionCount added in v0.1.72 

func GenReqDefForUpdatePartitionCount() *def.HttpRequestDef

func GenReqDefForUpdateStream added in v0.1.72 

func GenReqDefForUpdateStream() *def.HttpRequestDef

Types

type BatchCreateTagsInvoker added in v0.1.72 

type BatchCreateTagsInvoker struct {
	*invoker.BaseInvoker
}

func (*BatchCreateTagsInvoker) Invoke added in v0.1.72 

func (i *BatchCreateTagsInvoker) Invoke() (*model.BatchCreateTagsResponse, error)

type BatchDeleteTagsInvoker added in v0.1.72 

type BatchDeleteTagsInvoker struct {
	*invoker.BaseInvoker
}

func (*BatchDeleteTagsInvoker) Invoke added in v0.1.72 

func (i *BatchDeleteTagsInvoker) Invoke() (*model.BatchDeleteTagsResponse, error)

type BatchStartTransferTaskInvoker added in v0.1.72 

type BatchStartTransferTaskInvoker struct {
	*invoker.BaseInvoker
}

func (*BatchStartTransferTaskInvoker) Invoke added in v0.1.72 

func (i *BatchStartTransferTaskInvoker) Invoke() (*model.BatchStartTransferTaskResponse, error)

type BatchStopTransferTaskInvoker added in v0.1.72 

type BatchStopTransferTaskInvoker struct {
	*invoker.BaseInvoker
}

func (*BatchStopTransferTaskInvoker) Invoke added in v0.1.72 

func (i *BatchStopTransferTaskInvoker) Invoke() (*model.BatchStopTransferTaskResponse, error)

type CommitCheckpointInvoker added in v0.1.72 

type CommitCheckpointInvoker struct {
	*invoker.BaseInvoker
}

func (*CommitCheckpointInvoker) Invoke added in v0.1.72 

func (i *CommitCheckpointInvoker) Invoke() (*model.CommitCheckpointResponse, error)

type ConsumeRecordsInvoker added in v0.1.72 

type ConsumeRecordsInvoker struct {
	*invoker.BaseInvoker
}

func (*ConsumeRecordsInvoker) Invoke added in v0.1.72 

func (i *ConsumeRecordsInvoker) Invoke() (*model.ConsumeRecordsResponse, error)

type CreateAppInvoker added in v0.1.72 

type CreateAppInvoker struct {
	*invoker.BaseInvoker
}

func (*CreateAppInvoker) Invoke added in v0.1.72 

func (i *CreateAppInvoker) Invoke() (*model.CreateAppResponse, error)

type CreateObsTransferTaskInvoker added in v0.1.72 

type CreateObsTransferTaskInvoker struct {
	*invoker.BaseInvoker
}

func (*CreateObsTransferTaskInvoker) Invoke added in v0.1.72 

func (i *CreateObsTransferTaskInvoker) Invoke() (*model.CreateObsTransferTaskResponse, error)

type CreateStreamInvoker added in v0.1.72 

type CreateStreamInvoker struct {
	*invoker.BaseInvoker
}

func (*CreateStreamInvoker) Invoke added in v0.1.72 

func (i *CreateStreamInvoker) Invoke() (*model.CreateStreamResponse, error)

type CreateTagInvoker added in v0.1.72 

type CreateTagInvoker struct {
	*invoker.BaseInvoker
}

func (*CreateTagInvoker) Invoke added in v0.1.72 

func (i *CreateTagInvoker) Invoke() (*model.CreateTagResponse, error)

type DeleteAppInvoker added in v0.1.72 

type DeleteAppInvoker struct {
	*invoker.BaseInvoker
}

func (*DeleteAppInvoker) Invoke added in v0.1.72 

func (i *DeleteAppInvoker) Invoke() (*model.DeleteAppResponse, error)

type DeleteCheckpointInvoker added in v0.1.72 

type DeleteCheckpointInvoker struct {
	*invoker.BaseInvoker
}

func (*DeleteCheckpointInvoker) Invoke added in v0.1.72 

func (i *DeleteCheckpointInvoker) Invoke() (*model.DeleteCheckpointResponse, error)

type DeleteStreamInvoker added in v0.1.72 

type DeleteStreamInvoker struct {
	*invoker.BaseInvoker
}

func (*DeleteStreamInvoker) Invoke added in v0.1.72 

func (i *DeleteStreamInvoker) Invoke() (*model.DeleteStreamResponse, error)

type DeleteTagInvoker added in v0.1.72 

type DeleteTagInvoker struct {
	*invoker.BaseInvoker
}

func (*DeleteTagInvoker) Invoke added in v0.1.72 

func (i *DeleteTagInvoker) Invoke() (*model.DeleteTagResponse, error)

type DeleteTransferTaskInvoker added in v0.1.72 

type DeleteTransferTaskInvoker struct {
	*invoker.BaseInvoker
}

func (*DeleteTransferTaskInvoker) Invoke added in v0.1.72 

func (i *DeleteTransferTaskInvoker) Invoke() (*model.DeleteTransferTaskResponse, error)

type DisClient 

type DisClient struct {
	HcClient *http_client.HcHttpClient
}

func NewDisClient 

func NewDisClient(hcClient *http_client.HcHttpClient) *DisClient

func (*DisClient) BatchCreateTags added in v0.1.72 

func (c *DisClient) BatchCreateTags(request *model.BatchCreateTagsRequest) (*model.BatchCreateTagsResponse, error)

BatchCreateTags 批量添加资源标签

该接口用于批量添加资源（通道等）标签。此接口为幂等接口：创建时如果请求体中存在重复key则报错。创建时，不允许设置重复key数据，如果数据库已存在该key，就覆盖value的值。

Please refer to HUAWEI cloud API Explorer for details.

func (*DisClient) BatchCreateTagsInvoker added in v0.1.72 

func (c *DisClient) BatchCreateTagsInvoker(request *model.BatchCreateTagsRequest) *BatchCreateTagsInvoker

BatchCreateTagsInvoker 批量添加资源标签

func (*DisClient) BatchDeleteTags added in v0.1.72 

func (c *DisClient) BatchDeleteTags(request *model.BatchDeleteTagsRequest) (*model.BatchDeleteTagsResponse, error)

BatchDeleteTags 批量删除资源标签

该接口用于批量删除资源（通道等）标签。此接口为幂等接口：删除时，如果删除的标签不存在，默认处理成功；删除时不对标签字符集范围做校验。删除时tags结构体不能缺失，key不能为空，或者空字符串。

Please refer to HUAWEI cloud API Explorer for details.

func (*DisClient) BatchDeleteTagsInvoker added in v0.1.72 

func (c *DisClient) BatchDeleteTagsInvoker(request *model.BatchDeleteTagsRequest) *BatchDeleteTagsInvoker

BatchDeleteTagsInvoker 批量删除资源标签

func (*DisClient) BatchStartTransferTask added in v0.1.72 

func (c *DisClient) BatchStartTransferTask(request *model.BatchStartTransferTaskRequest) (*model.BatchStartTransferTaskResponse, error)

BatchStartTransferTask 批量启动转储任务

此接口用于批量启动转储任务。

Please refer to HUAWEI cloud API Explorer for details.

func (*DisClient) BatchStartTransferTaskInvoker added in v0.1.72 

func (c *DisClient) BatchStartTransferTaskInvoker(request *model.BatchStartTransferTaskRequest) *BatchStartTransferTaskInvoker

BatchStartTransferTaskInvoker 批量启动转储任务

func (*DisClient) BatchStopTransferTask added in v0.1.72 

func (c *DisClient) BatchStopTransferTask(request *model.BatchStopTransferTaskRequest) (*model.BatchStopTransferTaskResponse, error)

BatchStopTransferTask 批量暂停转储任务

此接口用于批量暂停转储任务。

Please refer to HUAWEI cloud API Explorer for details.

func (*DisClient) BatchStopTransferTaskInvoker added in v0.1.72 

func (c *DisClient) BatchStopTransferTaskInvoker(request *model.BatchStopTransferTaskRequest) *BatchStopTransferTaskInvoker

BatchStopTransferTaskInvoker 批量暂停转储任务

func (*DisClient) CommitCheckpoint added in v0.1.72 

func (c *DisClient) CommitCheckpoint(request *model.CommitCheckpointRequest) (*model.CommitCheckpointResponse, error)

CommitCheckpoint 提交Checkpoint

本接口用于提交Checkpoint。

Please refer to HUAWEI cloud API Explorer for details.

func (*DisClient) CommitCheckpointInvoker added in v0.1.72 

func (c *DisClient) CommitCheckpointInvoker(request *model.CommitCheckpointRequest) *CommitCheckpointInvoker

CommitCheckpointInvoker 提交Checkpoint

func (*DisClient) ConsumeRecords added in v0.1.72 

func (c *DisClient) ConsumeRecords(request *model.ConsumeRecordsRequest) (*model.ConsumeRecordsResponse, error)

ConsumeRecords 下载数据

本接口用于从DIS通道中下载数据。

Please refer to HUAWEI cloud API Explorer for details.

func (*DisClient) ConsumeRecordsInvoker added in v0.1.72 

func (c *DisClient) ConsumeRecordsInvoker(request *model.ConsumeRecordsRequest) *ConsumeRecordsInvoker

ConsumeRecordsInvoker 下载数据

func (*DisClient) CreateApp added in v0.1.72 

func (c *DisClient) CreateApp(request *model.CreateAppRequest) (*model.CreateAppResponse, error)

CreateApp 创建消费App

本接口用于创建消费APP。

Please refer to HUAWEI cloud API Explorer for details.

func (*DisClient) CreateAppInvoker added in v0.1.72 

func (c *DisClient) CreateAppInvoker(request *model.CreateAppRequest) *CreateAppInvoker

CreateAppInvoker 创建消费App

func (*DisClient) CreateObsTransferTask added in v0.1.72 

func (c *DisClient) CreateObsTransferTask(request *model.CreateObsTransferTaskRequest) (*model.CreateObsTransferTaskResponse, error)

CreateObsTransferTask 添加OBS转储任务

本接口用于添加OBS转储任务。

Please refer to HUAWEI cloud API Explorer for details.

func (*DisClient) CreateObsTransferTaskInvoker added in v0.1.72 

func (c *DisClient) CreateObsTransferTaskInvoker(request *model.CreateObsTransferTaskRequest) *CreateObsTransferTaskInvoker

CreateObsTransferTaskInvoker 添加OBS转储任务

func (*DisClient) CreateStream added in v0.1.72 

func (c *DisClient) CreateStream(request *model.CreateStreamRequest) (*model.CreateStreamResponse, error)

CreateStream 创建通道

本接口用于创建通道。

- 创建通道时，需指定通道类型（普通、高级）、分区数量。 - 一个账号默认最多可以创建10个高级通道分区和50个普通通道分区，可提交工单增加配额。

Please refer to HUAWEI cloud API Explorer for details.

func (*DisClient) CreateStreamInvoker added in v0.1.72 

func (c *DisClient) CreateStreamInvoker(request *model.CreateStreamRequest) *CreateStreamInvoker

CreateStreamInvoker 创建通道

func (*DisClient) CreateTag added in v0.1.72 

func (c *DisClient) CreateTag(request *model.CreateTagRequest) (*model.CreateTagResponse, error)

CreateTag 给指定通道添加标签

本接口用于给指定通道添加标签。

Please refer to HUAWEI cloud API Explorer for details.

func (*DisClient) CreateTagInvoker added in v0.1.72 

func (c *DisClient) CreateTagInvoker(request *model.CreateTagRequest) *CreateTagInvoker

CreateTagInvoker 给指定通道添加标签

func (*DisClient) DeleteApp added in v0.1.72 

func (c *DisClient) DeleteApp(request *model.DeleteAppRequest) (*model.DeleteAppResponse, error)

DeleteApp 删除App

本接口用于删除App。

Please refer to HUAWEI cloud API Explorer for details.

func (*DisClient) DeleteAppInvoker added in v0.1.72 

func (c *DisClient) DeleteAppInvoker(request *model.DeleteAppRequest) *DeleteAppInvoker

DeleteAppInvoker 删除App

func (*DisClient) DeleteCheckpoint added in v0.1.72 

func (c *DisClient) DeleteCheckpoint(request *model.DeleteCheckpointRequest) (*model.DeleteCheckpointResponse, error)

DeleteCheckpoint 删除Checkpoint

本接口用于删除Checkpoint。

Please refer to HUAWEI cloud API Explorer for details.

func (*DisClient) DeleteCheckpointInvoker added in v0.1.72 

func (c *DisClient) DeleteCheckpointInvoker(request *model.DeleteCheckpointRequest) *DeleteCheckpointInvoker

DeleteCheckpointInvoker 删除Checkpoint

func (*DisClient) DeleteStream added in v0.1.72 

func (c *DisClient) DeleteStream(request *model.DeleteStreamRequest) (*model.DeleteStreamResponse, error)

DeleteStream 删除指定通道

本接口用于删除指定通道。

Please refer to HUAWEI cloud API Explorer for details.

func (*DisClient) DeleteStreamInvoker added in v0.1.72 

func (c *DisClient) DeleteStreamInvoker(request *model.DeleteStreamRequest) *DeleteStreamInvoker

DeleteStreamInvoker 删除指定通道

func (*DisClient) DeleteTag added in v0.1.72 

func (c *DisClient) DeleteTag(request *model.DeleteTagRequest) (*model.DeleteTagResponse, error)

DeleteTag 删除指定通道的标签

该接口用于删除指定通道的标签。

Please refer to HUAWEI cloud API Explorer for details.

func (*DisClient) DeleteTagInvoker added in v0.1.72 

func (c *DisClient) DeleteTagInvoker(request *model.DeleteTagRequest) *DeleteTagInvoker

DeleteTagInvoker 删除指定通道的标签

func (*DisClient) DeleteTransferTask added in v0.1.72 

func (c *DisClient) DeleteTransferTask(request *model.DeleteTransferTaskRequest) (*model.DeleteTransferTaskResponse, error)

DeleteTransferTask 删除转储任务

该接口用于删除转储任务。

Please refer to HUAWEI cloud API Explorer for details.

func (*DisClient) DeleteTransferTaskInvoker added in v0.1.72 

func (c *DisClient) DeleteTransferTaskInvoker(request *model.DeleteTransferTaskRequest) *DeleteTransferTaskInvoker

DeleteTransferTaskInvoker 删除转储任务

func (*DisClient) ListApp added in v0.1.72 

func (c *DisClient) ListApp(request *model.ListAppRequest) (*model.ListAppResponse, error)

ListApp 查询App列表

本接口用于查询APP列表。

Please refer to HUAWEI cloud API Explorer for details.

func (*DisClient) ListAppInvoker added in v0.1.72 

func (c *DisClient) ListAppInvoker(request *model.ListAppRequest) *ListAppInvoker

ListAppInvoker 查询App列表

func (*DisClient) ListPolicies added in v0.1.72 

func (c *DisClient) ListPolicies(request *model.ListPoliciesRequest) (*model.ListPoliciesResponse, error)

ListPolicies 查询权限策略列表

本接口用于查询指定通道的权限策略列表。

Please refer to HUAWEI cloud API Explorer for details.

func (*DisClient) ListPoliciesInvoker added in v0.1.72 

func (c *DisClient) ListPoliciesInvoker(request *model.ListPoliciesRequest) *ListPoliciesInvoker

ListPoliciesInvoker 查询权限策略列表

func (*DisClient) ListResourcesByTags added in v0.1.72 

func (c *DisClient) ListResourcesByTags(request *model.ListResourcesByTagsRequest) (*model.ListResourcesByTagsResponse, error)

ListResourcesByTags 使用标签过滤资源（通道等）

该接口用于使用标签过滤资源（通道等）。

Please refer to HUAWEI cloud API Explorer for details.

func (*DisClient) ListResourcesByTagsInvoker added in v0.1.72 

func (c *DisClient) ListResourcesByTagsInvoker(request *model.ListResourcesByTagsRequest) *ListResourcesByTagsInvoker

ListResourcesByTagsInvoker 使用标签过滤资源（通道等）

func (*DisClient) ListStreams added in v0.1.72 

func (c *DisClient) ListStreams(request *model.ListStreamsRequest) (*model.ListStreamsResponse, error)

ListStreams 查询通道列表

本接口用户查询当前租户创建的所有通道。

查询时，需要指定从哪个通道开始返回通道列表和单次请求需要返回的最大数量。

Please refer to HUAWEI cloud API Explorer for details.

func (*DisClient) ListStreamsInvoker added in v0.1.72 

func (c *DisClient) ListStreamsInvoker(request *model.ListStreamsRequest) *ListStreamsInvoker

ListStreamsInvoker 查询通道列表

func (*DisClient) ListTags added in v0.1.72 

func (c *DisClient) ListTags(request *model.ListTagsRequest) (*model.ListTagsResponse, error)

ListTags 查询指定区域所有标签集合

该接口用于查询指定区域所有标签集合。

Please refer to HUAWEI cloud API Explorer for details.

func (*DisClient) ListTagsInvoker added in v0.1.72 

func (c *DisClient) ListTagsInvoker(request *model.ListTagsRequest) *ListTagsInvoker

ListTagsInvoker 查询指定区域所有标签集合

func (*DisClient) ListTransferTasks added in v0.1.72 

func (c *DisClient) ListTransferTasks(request *model.ListTransferTasksRequest) (*model.ListTransferTasksResponse, error)

ListTransferTasks 查询转储任务列表

本接口用于查询转储任务列表。

Please refer to HUAWEI cloud API Explorer for details.

func (*DisClient) ListTransferTasksInvoker added in v0.1.72 

func (c *DisClient) ListTransferTasksInvoker(request *model.ListTransferTasksRequest) *ListTransferTasksInvoker

ListTransferTasksInvoker 查询转储任务列表

func (*DisClient) SendRecords added in v0.1.72 

func (c *DisClient) SendRecords(request *model.SendRecordsRequest) (*model.SendRecordsResponse, error)

SendRecords 上传数据

本接口用于上传数据到DIS通道中。

Please refer to HUAWEI cloud API Explorer for details.

func (*DisClient) SendRecordsInvoker added in v0.1.72 

func (c *DisClient) SendRecordsInvoker(request *model.SendRecordsRequest) *SendRecordsInvoker

SendRecordsInvoker 上传数据

func (*DisClient) ShowApp added in v0.1.72 

func (c *DisClient) ShowApp(request *model.ShowAppRequest) (*model.ShowAppResponse, error)

ShowApp 查看App详情

本接口用于查询APP详情。

Please refer to HUAWEI cloud API Explorer for details.

func (*DisClient) ShowAppInvoker added in v0.1.72 

func (c *DisClient) ShowAppInvoker(request *model.ShowAppRequest) *ShowAppInvoker

ShowAppInvoker 查看App详情

func (*DisClient) ShowCheckpoint added in v0.1.72 

func (c *DisClient) ShowCheckpoint(request *model.ShowCheckpointRequest) (*model.ShowCheckpointResponse, error)

ShowCheckpoint 查询Checkpoint详情

本接口用于查询Checkpoint详情。

Please refer to HUAWEI cloud API Explorer for details.

func (*DisClient) ShowCheckpointInvoker added in v0.1.72 

func (c *DisClient) ShowCheckpointInvoker(request *model.ShowCheckpointRequest) *ShowCheckpointInvoker

ShowCheckpointInvoker 查询Checkpoint详情

func (*DisClient) ShowConsumerState added in v0.1.72 

func (c *DisClient) ShowConsumerState(request *model.ShowConsumerStateRequest) (*model.ShowConsumerStateResponse, error)

ShowConsumerState 查看App消费状态

本接口用于查询APP消费状态。

Please refer to HUAWEI cloud API Explorer for details.

func (*DisClient) ShowConsumerStateInvoker added in v0.1.72 

func (c *DisClient) ShowConsumerStateInvoker(request *model.ShowConsumerStateRequest) *ShowConsumerStateInvoker

ShowConsumerStateInvoker 查看App消费状态

func (*DisClient) ShowCursor added in v0.1.72 

func (c *DisClient) ShowCursor(request *model.ShowCursorRequest) (*model.ShowCursorResponse, error)

ShowCursor 获取数据游标

本接口用于获取数据游标。

Please refer to HUAWEI cloud API Explorer for details.

func (*DisClient) ShowCursorInvoker added in v0.1.72 

func (c *DisClient) ShowCursorInvoker(request *model.ShowCursorRequest) *ShowCursorInvoker

ShowCursorInvoker 获取数据游标

func (*DisClient) ShowPartitionMetrics added in v0.1.72 

func (c *DisClient) ShowPartitionMetrics(request *model.ShowPartitionMetricsRequest) (*model.ShowPartitionMetricsResponse, error)

ShowPartitionMetrics 查询分区监控

本接口用于查询通道指定分区的监控数据。

Please refer to HUAWEI cloud API Explorer for details.

func (*DisClient) ShowPartitionMetricsInvoker added in v0.1.72 

func (c *DisClient) ShowPartitionMetricsInvoker(request *model.ShowPartitionMetricsRequest) *ShowPartitionMetricsInvoker

ShowPartitionMetricsInvoker 查询分区监控

func (*DisClient) ShowStream added in v0.1.72 

func (c *DisClient) ShowStream(request *model.ShowStreamRequest) (*model.ShowStreamResponse, error)

ShowStream 查看通道详情

本接口用于查询指定通道的详情。

Please refer to HUAWEI cloud API Explorer for details.

func (*DisClient) ShowStreamInvoker added in v0.1.72 

func (c *DisClient) ShowStreamInvoker(request *model.ShowStreamRequest) *ShowStreamInvoker

ShowStreamInvoker 查看通道详情

func (*DisClient) ShowStreamMetrics added in v0.1.72 

func (c *DisClient) ShowStreamMetrics(request *model.ShowStreamMetricsRequest) (*model.ShowStreamMetricsResponse, error)

ShowStreamMetrics 查询通道监控

本接口用于查询指定通道的监控数据。

Please refer to HUAWEI cloud API Explorer for details.

func (*DisClient) ShowStreamMetricsInvoker added in v0.1.72 

func (c *DisClient) ShowStreamMetricsInvoker(request *model.ShowStreamMetricsRequest) *ShowStreamMetricsInvoker

ShowStreamMetricsInvoker 查询通道监控

func (*DisClient) ShowStreamTags added in v0.1.72 

func (c *DisClient) ShowStreamTags(request *model.ShowStreamTagsRequest) (*model.ShowStreamTagsResponse, error)

ShowStreamTags 查询指定通道的标签信息

该接口用于查询指定通道的标签信息。

Please refer to HUAWEI cloud API Explorer for details.

func (*DisClient) ShowStreamTagsInvoker added in v0.1.72 

func (c *DisClient) ShowStreamTagsInvoker(request *model.ShowStreamTagsRequest) *ShowStreamTagsInvoker

ShowStreamTagsInvoker 查询指定通道的标签信息

func (*DisClient) ShowTransferTask added in v0.1.72 

func (c *DisClient) ShowTransferTask(request *model.ShowTransferTaskRequest) (*model.ShowTransferTaskResponse, error)

ShowTransferTask 查询转储任务详情

查询转储任务详情。

Please refer to HUAWEI cloud API Explorer for details.

func (*DisClient) ShowTransferTaskInvoker added in v0.1.72 

func (c *DisClient) ShowTransferTaskInvoker(request *model.ShowTransferTaskRequest) *ShowTransferTaskInvoker

ShowTransferTaskInvoker 查询转储任务详情

func (*DisClient) UpdatePartitionCount added in v0.1.72 

func (c *DisClient) UpdatePartitionCount(request *model.UpdatePartitionCountRequest) (*model.UpdatePartitionCountResponse, error)

UpdatePartitionCount 修改分区数量

本接口用于变更指定通道中的分区数量。

Please refer to HUAWEI cloud API Explorer for details.

func (*DisClient) UpdatePartitionCountInvoker added in v0.1.72 

func (c *DisClient) UpdatePartitionCountInvoker(request *model.UpdatePartitionCountRequest) *UpdatePartitionCountInvoker

UpdatePartitionCountInvoker 修改分区数量

func (*DisClient) UpdateStream added in v0.1.72 

func (c *DisClient) UpdateStream(request *model.UpdateStreamRequest) (*model.UpdateStreamResponse, error)

UpdateStream 更新通道信息

本接口用于更新指定通道的通道信息。

Please refer to HUAWEI cloud API Explorer for details.

func (*DisClient) UpdateStreamInvoker added in v0.1.72 

func (c *DisClient) UpdateStreamInvoker(request *model.UpdateStreamRequest) *UpdateStreamInvoker

UpdateStreamInvoker 更新通道信息

type ListAppInvoker added in v0.1.72 

type ListAppInvoker struct {
	*invoker.BaseInvoker
}

func (*ListAppInvoker) Invoke added in v0.1.72 

func (i *ListAppInvoker) Invoke() (*model.ListAppResponse, error)

type ListPoliciesInvoker added in v0.1.72 

type ListPoliciesInvoker struct {
	*invoker.BaseInvoker
}

func (*ListPoliciesInvoker) Invoke added in v0.1.72 

func (i *ListPoliciesInvoker) Invoke() (*model.ListPoliciesResponse, error)

type ListResourcesByTagsInvoker added in v0.1.72 

type ListResourcesByTagsInvoker struct {
	*invoker.BaseInvoker
}

func (*ListResourcesByTagsInvoker) Invoke added in v0.1.72 

func (i *ListResourcesByTagsInvoker) Invoke() (*model.ListResourcesByTagsResponse, error)

type ListStreamsInvoker added in v0.1.72 

type ListStreamsInvoker struct {
	*invoker.BaseInvoker
}

func (*ListStreamsInvoker) Invoke added in v0.1.72 

func (i *ListStreamsInvoker) Invoke() (*model.ListStreamsResponse, error)

type ListTagsInvoker added in v0.1.72 

type ListTagsInvoker struct {
	*invoker.BaseInvoker
}

func (*ListTagsInvoker) Invoke added in v0.1.72 

func (i *ListTagsInvoker) Invoke() (*model.ListTagsResponse, error)

type ListTransferTasksInvoker added in v0.1.72 

type ListTransferTasksInvoker struct {
	*invoker.BaseInvoker
}

func (*ListTransferTasksInvoker) Invoke added in v0.1.72 

func (i *ListTransferTasksInvoker) Invoke() (*model.ListTransferTasksResponse, error)

type SendRecordsInvoker added in v0.1.72 

type SendRecordsInvoker struct {
	*invoker.BaseInvoker
}

func (*SendRecordsInvoker) Invoke added in v0.1.72 

func (i *SendRecordsInvoker) Invoke() (*model.SendRecordsResponse, error)

type ShowAppInvoker added in v0.1.72 

type ShowAppInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowAppInvoker) Invoke added in v0.1.72 

func (i *ShowAppInvoker) Invoke() (*model.ShowAppResponse, error)

type ShowCheckpointInvoker added in v0.1.72 

type ShowCheckpointInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowCheckpointInvoker) Invoke added in v0.1.72 

func (i *ShowCheckpointInvoker) Invoke() (*model.ShowCheckpointResponse, error)

type ShowConsumerStateInvoker added in v0.1.72 

type ShowConsumerStateInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowConsumerStateInvoker) Invoke added in v0.1.72 

func (i *ShowConsumerStateInvoker) Invoke() (*model.ShowConsumerStateResponse, error)

type ShowCursorInvoker added in v0.1.72 

type ShowCursorInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowCursorInvoker) Invoke added in v0.1.72 

func (i *ShowCursorInvoker) Invoke() (*model.ShowCursorResponse, error)

type ShowPartitionMetricsInvoker added in v0.1.72 

type ShowPartitionMetricsInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowPartitionMetricsInvoker) Invoke added in v0.1.72 

func (i *ShowPartitionMetricsInvoker) Invoke() (*model.ShowPartitionMetricsResponse, error)

type ShowStreamInvoker added in v0.1.72 

type ShowStreamInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowStreamInvoker) Invoke added in v0.1.72 

func (i *ShowStreamInvoker) Invoke() (*model.ShowStreamResponse, error)

type ShowStreamMetricsInvoker added in v0.1.72 

type ShowStreamMetricsInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowStreamMetricsInvoker) Invoke added in v0.1.72 

func (i *ShowStreamMetricsInvoker) Invoke() (*model.ShowStreamMetricsResponse, error)

type ShowStreamTagsInvoker added in v0.1.72 

type ShowStreamTagsInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowStreamTagsInvoker) Invoke added in v0.1.72 

func (i *ShowStreamTagsInvoker) Invoke() (*model.ShowStreamTagsResponse, error)

type ShowTransferTaskInvoker added in v0.1.72 

type ShowTransferTaskInvoker struct {
	*invoker.BaseInvoker
}

func (*ShowTransferTaskInvoker) Invoke added in v0.1.72 

func (i *ShowTransferTaskInvoker) Invoke() (*model.ShowTransferTaskResponse, error)

type UpdatePartitionCountInvoker added in v0.1.72 

type UpdatePartitionCountInvoker struct {
	*invoker.BaseInvoker
}

func (*UpdatePartitionCountInvoker) Invoke added in v0.1.72 

func (i *UpdatePartitionCountInvoker) Invoke() (*model.UpdatePartitionCountResponse, error)

type UpdateStreamInvoker added in v0.1.72 

type UpdateStreamInvoker struct {
	*invoker.BaseInvoker
}

func (*UpdateStreamInvoker) Invoke added in v0.1.72 

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