v1

package
v0.0.62 Latest Latest
Warning

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

 Go to latest Published: Sep 24, 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 DisClientBuilder 

func DisClientBuilder() *http_client.HcHttpClientBuilder

func GenReqDefForCommitCheckpoint 

func GenReqDefForCommitCheckpoint() *def.HttpRequestDef

func GenReqDefForCreateApp 

func GenReqDefForCreateApp() *def.HttpRequestDef

func GenReqDefForCreateAppV3 

func GenReqDefForCreateAppV3() *def.HttpRequestDef

func GenReqDefForCreatePoliciesV3 

func GenReqDefForCreatePoliciesV3() *def.HttpRequestDef

func GenReqDefForCreateStream 

func GenReqDefForCreateStream() *def.HttpRequestDef

func GenReqDefForCreateTransferTask 

func GenReqDefForCreateTransferTask() *def.HttpRequestDef

func GenReqDefForCreateTransferTaskV3 

func GenReqDefForCreateTransferTaskV3() *def.HttpRequestDef

func GenReqDefForDeleteApp 

func GenReqDefForDeleteApp() *def.HttpRequestDef

func GenReqDefForDeleteCheckpoint 

func GenReqDefForDeleteCheckpoint() *def.HttpRequestDef

func GenReqDefForDeleteStream 

func GenReqDefForDeleteStream() *def.HttpRequestDef

func GenReqDefForDeleteStreamV3 

func GenReqDefForDeleteStreamV3() *def.HttpRequestDef

func GenReqDefForDeleteTransferTask 

func GenReqDefForDeleteTransferTask() *def.HttpRequestDef

func GenReqDefForDeleteTransferTaskV3 

func GenReqDefForDeleteTransferTaskV3() *def.HttpRequestDef

func GenReqDefForDescribeApp 

func GenReqDefForDescribeApp() *def.HttpRequestDef

func GenReqDefForDescribeStream 

func GenReqDefForDescribeStream() *def.HttpRequestDef

func GenReqDefForGetCheckpoint 

func GenReqDefForGetCheckpoint() *def.HttpRequestDef

func GenReqDefForGetCursor 

func GenReqDefForGetCursor() *def.HttpRequestDef

func GenReqDefForGetRecords 

func GenReqDefForGetRecords() *def.HttpRequestDef

func GenReqDefForListApp 

func GenReqDefForListApp() *def.HttpRequestDef

func GenReqDefForListAppV3 

func GenReqDefForListAppV3() *def.HttpRequestDef

func GenReqDefForListPoliciesV3 

func GenReqDefForListPoliciesV3() *def.HttpRequestDef

func GenReqDefForListStreams 

func GenReqDefForListStreams() *def.HttpRequestDef

func GenReqDefForListTransferTasksV3 

func GenReqDefForListTransferTasksV3() *def.HttpRequestDef

func GenReqDefForPutRecords 

func GenReqDefForPutRecords() *def.HttpRequestDef

func GenReqDefForUpdatePartitionCount 

func GenReqDefForUpdatePartitionCount() *def.HttpRequestDef

func GenReqDefForUpdateStreamV3 

func GenReqDefForUpdateStreamV3() *def.HttpRequestDef

Types

type DisClient 

type DisClient struct {
	HcClient *http_client.HcHttpClient
}

func NewDisClient 

func NewDisClient(hcClient *http_client.HcHttpClient) *DisClient

func (*DisClient) CommitCheckpoint 

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

本接口用于新增Checkpoint。

func (*DisClient) CreateApp 

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

本接口用于创建消费APP。

func (*DisClient) CreateAppV3 

func (c *DisClient) CreateAppV3(request *model.CreateAppV3Request) (*model.CreateAppV3Response, error)

本接口用于创建消费APP。

func (*DisClient) CreatePoliciesV3 

func (c *DisClient) CreatePoliciesV3(request *model.CreatePoliciesV3Request) (*model.CreatePoliciesV3Response, error)

本接口用于给指定通道添加权限策略。

func (*DisClient) CreateStream 

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

本接口用于创建通道，推荐使用V3版本接口。

func (*DisClient) CreateTransferTask 

func (c *DisClient) CreateTransferTask(request *model.CreateTransferTaskRequest) (*model.CreateTransferTaskResponse, error)

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

func (*DisClient) CreateTransferTaskV3 

func (c *DisClient) CreateTransferTaskV3(request *model.CreateTransferTaskV3Request) (*model.CreateTransferTaskV3Response, error)

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

func (*DisClient) DeleteApp 

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

本接口用于删除APP。

func (*DisClient) DeleteCheckpoint 

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

本接口用于删除Checkpoint。

func (*DisClient) DeleteStream 

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

本接口用于删除指定通道，推荐使用V3版本接口。

func (*DisClient) DeleteStreamV3 

func (c *DisClient) DeleteStreamV3(request *model.DeleteStreamV3Request) (*model.DeleteStreamV3Response, error)

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

func (*DisClient) DeleteTransferTask 

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

This API is used to delete a checkpoint.

func (*DisClient) DeleteTransferTaskV3 

func (c *DisClient) DeleteTransferTaskV3(request *model.DeleteTransferTaskV3Request) (*model.DeleteTransferTaskV3Response, error)

This API is used to delete a checkpoint.

func (*DisClient) DescribeApp 

func (c *DisClient) DescribeApp(request *model.DescribeAppRequest) (*model.DescribeAppResponse, error)

本接口用于查询APP详情。

func (*DisClient) DescribeStream 

func (c *DisClient) DescribeStream(request *model.DescribeStreamRequest) (*model.DescribeStreamResponse, error)

本接口用于查询指定通道的详情，推荐使用V3版本接口。

func (*DisClient) GetCheckpoint 

func (c *DisClient) GetCheckpoint(request *model.GetCheckpointRequest) (*model.GetCheckpointResponse, error)

本接口用于查询Checkpoint详情。

func (*DisClient) GetCursor 

func (c *DisClient) GetCursor(request *model.GetCursorRequest) (*model.GetCursorResponse, error)

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

func (*DisClient) GetRecords 

func (c *DisClient) GetRecords(request *model.GetRecordsRequest) (*model.GetRecordsResponse, error)

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

func (*DisClient) ListApp 

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

本接口用于查询APP列表。

func (*DisClient) ListAppV3 

func (c *DisClient) ListAppV3(request *model.ListAppV3Request) (*model.ListAppV3Response, error)

本接口用于查询APP列表。

func (*DisClient) ListPoliciesV3 

func (c *DisClient) ListPoliciesV3(request *model.ListPoliciesV3Request) (*model.ListPoliciesV3Response, error)

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

func (*DisClient) ListStreams 

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

本接口用户查询当前租户创建的所有通道，推荐使用V3版本接口。 查询时，需要指定从哪个通道开始返回通道列表和单次请求需要返回的最大数量。

func (*DisClient) ListTransferTasksV3 

func (c *DisClient) ListTransferTasksV3(request *model.ListTransferTasksV3Request) (*model.ListTransferTasksV3Response, error)

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

func (*DisClient) PutRecords 

func (c *DisClient) PutRecords(request *model.PutRecordsRequest) (*model.PutRecordsResponse, error)

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

func (*DisClient) UpdatePartitionCount 

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

本接口用于变更指定通道中的分区数量，推荐使用V3版本接口。

func (*DisClient) UpdateStreamV3 

func (c *DisClient) UpdateStreamV3(request *model.UpdateStreamV3Request) (*model.UpdateStreamV3Response, 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.