ckafka

package
v1.81.121 Latest Latest
Warning

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

 Go to latest Published: Sep 11, 2024 License: MPL-2.0 Imports: 19 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	CKAFKA_DESCRIBE_LIMIT    = 50
	CKAFKA_ACL_PRINCIPAL_STR = "User:"
)
View Source 
const (
	CKAFKA_CHARGE_TYPE_POSTPAID = svcpostgresql.COMMON_PAYTYPE_POSTPAID
	CKAFKA_CHARGE_TYPE_PREPAID  = svcpostgresql.COMMON_PAYTYPE_PREPAID
)
View Source 
const CkafkaFailedOperation = "FailedOperation"
View Source 
const CkafkaInstanceNotFound = "InvalidParameterValue.InstanceNotExist"

sdk ckafka not found error

View Source 
const CkafkaResourceNotFound = "ResourceNotFound"

Variables

View Source 
var CKAFKA_ACL_OPERATION = map[string]int64{
	"UNKNOWN":          0,
	"ANY":              1,
	"ALL":              2,
	"READ":             3,
	"WRITE":            4,
	"CREATE":           5,
	"DELETE":           6,
	"ALTER":            7,
	"DESCRIBE":         8,
	"CLUSTER_ACTION":   9,
	"DESCRIBE_CONFIGS": 10,
	"ALTER_CONFIGS":    11,
	"IDEMPOTEN_WRITE":  12,
}
View Source 
var CKAFKA_ACL_OPERATION_TO_STRING = map[int64]string{
	0:  "UNKNOWN",
	1:  "ANY",
	2:  "ALL",
	3:  "READ",
	4:  "WRITE",
	5:  "CREATE",
	6:  "DELETE",
	7:  "ALTER",
	8:  "DESCRIBE",
	9:  "CLUSTER_ACTION",
	10: "DESCRIBE_CONFIGS",
	11: "ALTER_CONFIGS",
	12: "IDEMPOTEN_WRITE",
}
View Source 
var CKAFKA_ACL_RESOURCE_TYPE = map[string]int64{
	"UNKNOWN":          0,
	"ANY":              1,
	"TOPIC":            2,
	"GROUP":            3,
	"CLUSTER":          4,
	"TRANSACTIONAL_ID": 5,
}
View Source 
var CKAFKA_ACL_RESOURCE_TYPE_TO_STRING = map[int64]string{
	0: "UNKNOWN",
	1: "ANY",
	2: "TOPIC",
	3: "GROUP",
	4: "CLUSTER",
	5: "TRANSACTIONAL_ID",
}
View Source 
var CKAFKA_INSTANCE_TYPE = map[string]int64{
	"general":       1,
	"standard":      2,
	"advanced":      3,
	"capacity":      4,
	"specialized-1": 5,
	"specialized-2": 6,
	"specialized-3": 7,
	"specialized-4": 8,
	"exclusive":     9,
}
View Source 
var CKAFKA_PERMISSION_TYPE = map[string]int64{
	"UNKNOWN": 0,
	"ANY":     1,
	"DENY":    2,
	"ALLOW":   3,
}
View Source 
var CKAFKA_PERMISSION_TYPE_TO_STRING = map[int64]string{
	0: "UNKNOWN",
	1: "ANY",
	2: "DENY",
	3: "ALLOW",
}

Functions

func DataSourceTencentCloudCkafkaAcls 

func DataSourceTencentCloudCkafkaAcls() *schema.Resource

func DataSourceTencentCloudCkafkaConnectResource 

func DataSourceTencentCloudCkafkaConnectResource() *schema.Resource

func DataSourceTencentCloudCkafkaDatahubGroupOffsets 

func DataSourceTencentCloudCkafkaDatahubGroupOffsets() *schema.Resource

func DataSourceTencentCloudCkafkaDatahubTask 

func DataSourceTencentCloudCkafkaDatahubTask() *schema.Resource

func DataSourceTencentCloudCkafkaDatahubTopic 

func DataSourceTencentCloudCkafkaDatahubTopic() *schema.Resource

func DataSourceTencentCloudCkafkaGroup 

func DataSourceTencentCloudCkafkaGroup() *schema.Resource

func DataSourceTencentCloudCkafkaGroupInfo 

func DataSourceTencentCloudCkafkaGroupInfo() *schema.Resource

func DataSourceTencentCloudCkafkaGroupOffsets 

func DataSourceTencentCloudCkafkaGroupOffsets() *schema.Resource

func DataSourceTencentCloudCkafkaInstances 

func DataSourceTencentCloudCkafkaInstances() *schema.Resource

func DataSourceTencentCloudCkafkaRegion 

func DataSourceTencentCloudCkafkaRegion() *schema.Resource

func DataSourceTencentCloudCkafkaTaskStatus 

func DataSourceTencentCloudCkafkaTaskStatus() *schema.Resource

func DataSourceTencentCloudCkafkaTopicFlowRanking 

func DataSourceTencentCloudCkafkaTopicFlowRanking() *schema.Resource

func DataSourceTencentCloudCkafkaTopicProduceConnection 

func DataSourceTencentCloudCkafkaTopicProduceConnection() *schema.Resource

func DataSourceTencentCloudCkafkaTopicSubscribeGroup 

func DataSourceTencentCloudCkafkaTopicSubscribeGroup() *schema.Resource

func DataSourceTencentCloudCkafkaTopicSyncReplica 

func DataSourceTencentCloudCkafkaTopicSyncReplica() *schema.Resource

func DataSourceTencentCloudCkafkaTopics 

func DataSourceTencentCloudCkafkaTopics() *schema.Resource

func DataSourceTencentCloudCkafkaUsers 

func DataSourceTencentCloudCkafkaUsers() *schema.Resource

func DataSourceTencentCloudCkafkaZone 

func DataSourceTencentCloudCkafkaZone() *schema.Resource

func ResourceTencentCloudCkafkaAcl 

func ResourceTencentCloudCkafkaAcl() *schema.Resource

func ResourceTencentCloudCkafkaAclRule 

func ResourceTencentCloudCkafkaAclRule() *schema.Resource

func ResourceTencentCloudCkafkaConnectResource 

func ResourceTencentCloudCkafkaConnectResource() *schema.Resource

func ResourceTencentCloudCkafkaConsumerGroup 

func ResourceTencentCloudCkafkaConsumerGroup() *schema.Resource

func ResourceTencentCloudCkafkaConsumerGroupModifyOffset 

func ResourceTencentCloudCkafkaConsumerGroupModifyOffset() *schema.Resource

func ResourceTencentCloudCkafkaDatahubTask 

func ResourceTencentCloudCkafkaDatahubTask() *schema.Resource

func ResourceTencentCloudCkafkaDatahubTopic 

func ResourceTencentCloudCkafkaDatahubTopic() *schema.Resource

func ResourceTencentCloudCkafkaInstance 

func ResourceTencentCloudCkafkaInstance() *schema.Resource

func ResourceTencentCloudCkafkaRenewInstance 

func ResourceTencentCloudCkafkaRenewInstance() *schema.Resource

func ResourceTencentCloudCkafkaRoute 

func ResourceTencentCloudCkafkaRoute() *schema.Resource

func ResourceTencentCloudCkafkaTopic 

func ResourceTencentCloudCkafkaTopic() *schema.Resource

func ResourceTencentCloudCkafkaUser 

func ResourceTencentCloudCkafkaUser() *schema.Resource

Types

type CkafkaService 

type CkafkaService struct {
	// contains filtered or unexported fields
}

func NewCkafkaService 

func NewCkafkaService(client *connectivity.TencentCloudClient) CkafkaService

func (*CkafkaService) AddCkafkaTopicIpWhiteList 

func (me *CkafkaService) AddCkafkaTopicIpWhiteList(ctx context.Context, instanceId string, topicName string, whiteIpList []*string) (errRet error)

func (*CkafkaService) AddCkafkaTopicPartition 

func (me *CkafkaService) AddCkafkaTopicPartition(ctx context.Context, instanceId string, topicName string, partitionNum int64) (errRet error)

func (*CkafkaService) CheckCkafkaInstanceReady 

func (me *CkafkaService) CheckCkafkaInstanceReady(ctx context.Context,
	instanceId string) (has bool, ready bool, errRet error)

func (*CkafkaService) CkafkaConnectResourceStateRefreshFunc 

func (me *CkafkaService) CkafkaConnectResourceStateRefreshFunc(resourceId string, failStates []string) resource.StateRefreshFunc

func (*CkafkaService) CkafkaDatahubTaskStateRefreshFunc 

func (me *CkafkaService) CkafkaDatahubTaskStateRefreshFunc(taskId string, failStates []string) resource.StateRefreshFunc

func (*CkafkaService) CkafkaRouteStateRefreshFunc 

func (me *CkafkaService) CkafkaRouteStateRefreshFunc(flowId int64, failStates []string) resource.StateRefreshFunc

func (*CkafkaService) CreateAcl 

func (me *CkafkaService) CreateAcl(ctx context.Context, instanceId, resourceType, resourceName, operation, permissionType, host, principal string) (errRet error)

func (*CkafkaService) CreateCkafkaTopic 

func (me *CkafkaService) CreateCkafkaTopic(ctx context.Context, request *ckafka.CreateTopicRequest) (errRet error)

func (*CkafkaService) CreateUser 

func (me *CkafkaService) CreateUser(ctx context.Context, instanceId, user, password string) (errRet error)

func (*CkafkaService) DeleteAcl 

func (me *CkafkaService) DeleteAcl(ctx context.Context, aclId string) (errRet error)

func (*CkafkaService) DeleteCkafkaAclRuleById 

func (me *CkafkaService) DeleteCkafkaAclRuleById(ctx context.Context, instanceId string, ruleName string) (errRet error)

func (*CkafkaService) DeleteCkafkaConnectResourceById 

func (me *CkafkaService) DeleteCkafkaConnectResourceById(ctx context.Context, resourceId string) (errRet error)

func (*CkafkaService) DeleteCkafkaConsumerGroupById 

func (me *CkafkaService) DeleteCkafkaConsumerGroupById(ctx context.Context, instanceId string, groupName string) (errRet error)

func (*CkafkaService) DeleteCkafkaDatahubTaskById 

func (me *CkafkaService) DeleteCkafkaDatahubTaskById(ctx context.Context, taskId string) (errRet error)

func (*CkafkaService) DeleteCkafkaDatahubTopicById 

func (me *CkafkaService) DeleteCkafkaDatahubTopicById(ctx context.Context, topicName string) (errRet error)

func (*CkafkaService) DeleteCkafkaRouteById 

func (me *CkafkaService) DeleteCkafkaRouteById(ctx context.Context, instanceId string, routeId int64) (errRet error)

func (*CkafkaService) DeleteCkafkaTopic 

func (me *CkafkaService) DeleteCkafkaTopic(ctx context.Context, instanceId string, name string) (errRet error)

func (*CkafkaService) DeleteUser 

func (me *CkafkaService) DeleteUser(ctx context.Context, userId string) (errRet error)

func (*CkafkaService) DescribeAclByAclId 

func (me *CkafkaService) DescribeAclByAclId(ctx context.Context, aclId string) (aclInfo *ckafka.Acl, has bool, errRet error)

func (*CkafkaService) DescribeAclByFilter 

func (me *CkafkaService) DescribeAclByFilter(ctx context.Context, params map[string]interface{}) (aclInfos []*ckafka.Acl, errRet error)

func (*CkafkaService) DescribeCkafkaAclRuleById 

func (me *CkafkaService) DescribeCkafkaAclRuleById(ctx context.Context, instanceId string, ruleName string) (aclRule *ckafka.AclRule, errRet error)

func (*CkafkaService) DescribeCkafkaById 

func (me *CkafkaService) DescribeCkafkaById(ctx context.Context, instanceId string) (instance *ckafka.InstanceDetail, has bool, errRet error)

func (*CkafkaService) DescribeCkafkaCkafkaZoneByFilter 

func (me *CkafkaService) DescribeCkafkaCkafkaZoneByFilter(ctx context.Context, param map[string]interface{}) (ckafkaZone *ckafka.ZoneResponse, errRet error)

func (*CkafkaService) DescribeCkafkaConnectResourceByFilter 

func (me *CkafkaService) DescribeCkafkaConnectResourceByFilter(ctx context.Context, params map[string]interface{}) (describeConnectResourceResp *ckafka.DescribeConnectResourcesResp, errRet error)

func (*CkafkaService) DescribeCkafkaConnectResourceById 

func (me *CkafkaService) DescribeCkafkaConnectResourceById(ctx context.Context, resourceId string) (connectResource *ckafka.DescribeConnectResourceResp, errRet error)

func (*CkafkaService) DescribeCkafkaConsumerGroupById 

func (me *CkafkaService) DescribeCkafkaConsumerGroupById(ctx context.Context, instanceId string, groupName string) (consumerGroup *ckafka.ConsumerGroupResponse, errRet error)

func (*CkafkaService) DescribeCkafkaDatahubGroupOffsetsByFilter 

func (me *CkafkaService) DescribeCkafkaDatahubGroupOffsetsByFilter(ctx context.Context, param map[string]interface{}) (groupOffsetTopics []*ckafka.GroupOffsetTopic, errRet error)

func (*CkafkaService) DescribeCkafkaDatahubTaskByFilter 

func (me *CkafkaService) DescribeCkafkaDatahubTaskByFilter(ctx context.Context, param map[string]interface{}) (datahubTaskInfos []*ckafka.DatahubTaskInfo, errRet error)

func (*CkafkaService) DescribeCkafkaDatahubTopicByFilter 

func (me *CkafkaService) DescribeCkafkaDatahubTopicByFilter(ctx context.Context, paramMap map[string]interface{}) (result *ckafka.DescribeDatahubTopicsResp, errRet error)

func (*CkafkaService) DescribeCkafkaDatahubTopicById 

func (me *CkafkaService) DescribeCkafkaDatahubTopicById(ctx context.Context, topicName string) (datahubTopic *ckafka.DescribeDatahubTopicResp, errRet error)

func (*CkafkaService) DescribeCkafkaGroupByFilter 

func (me *CkafkaService) DescribeCkafkaGroupByFilter(ctx context.Context, param map[string]interface{}) (groups []*ckafka.DescribeGroup, errRet error)

func (*CkafkaService) DescribeCkafkaGroupInfoByFilter 

func (me *CkafkaService) DescribeCkafkaGroupInfoByFilter(ctx context.Context, param map[string]interface{}) (groupInfo []*ckafka.GroupInfoResponse, errRet error)

func (*CkafkaService) DescribeCkafkaGroupOffsetsByFilter 

func (me *CkafkaService) DescribeCkafkaGroupOffsetsByFilter(ctx context.Context, param map[string]interface{}) (groupOffsetTopics []*ckafka.GroupOffsetTopic, errRet error)

func (*CkafkaService) DescribeCkafkaInstanceById 

func (me *CkafkaService) DescribeCkafkaInstanceById(ctx context.Context,
	instanceId string) (info *ckafka.InstanceDetail, has bool, errRet error)

func (*CkafkaService) DescribeCkafkaRouteById 

func (me *CkafkaService) DescribeCkafkaRouteById(ctx context.Context, instanceId string, routeId int64) (route *ckafka.Route, errRet error)

func (*CkafkaService) DescribeCkafkaTaskStatusByFilter 

func (me *CkafkaService) DescribeCkafkaTaskStatusByFilter(ctx context.Context, flowId int) (taskStatus *ckafka.TaskStatusResponse, errRet error)

func (*CkafkaService) DescribeCkafkaTopicAttributes 

func (me *CkafkaService) DescribeCkafkaTopicAttributes(ctx context.Context, instanceId string, topicName string) (topicInfo *ckafka.TopicAttributesResponse, errRet error)

func (*CkafkaService) DescribeCkafkaTopicByName 

func (me *CkafkaService) DescribeCkafkaTopicByName(ctx context.Context, instanceId string, topicName string) (topic *ckafka.TopicDetail, has bool, errRet error)

func (*CkafkaService) DescribeCkafkaTopicFlowRankingByFilter 

func (me *CkafkaService) DescribeCkafkaTopicFlowRankingByFilter(ctx context.Context, param map[string]interface{}) (topicFlowRanking *ckafka.TopicFlowRankingResult, errRet error)

func (*CkafkaService) DescribeCkafkaTopicProduceConnectionByFilter 

func (me *CkafkaService) DescribeCkafkaTopicProduceConnectionByFilter(ctx context.Context, param map[string]interface{}) (topicProduceConnection []*ckafka.DescribeConnectInfoResultDTO, errRet error)

func (*CkafkaService) DescribeCkafkaTopicSubscribeGroupByFilter 

func (me *CkafkaService) DescribeCkafkaTopicSubscribeGroupByFilter(ctx context.Context, param map[string]interface{}) (groupInfos []*ckafka.GroupInfoResponse, errRet error)

func (*CkafkaService) DescribeCkafkaTopicSyncReplicaByFilter 

func (me *CkafkaService) DescribeCkafkaTopicSyncReplicaByFilter(ctx context.Context, param map[string]interface{}) (topicInSyncReplicaInfos []*ckafka.TopicInSyncReplicaInfo, errRet error)

func (*CkafkaService) DescribeCkafkaTopics 

func (me *CkafkaService) DescribeCkafkaTopics(ctx context.Context, instanceId string, topicName string) (topicList []*ckafka.TopicDetail, errRet error)

func (*CkafkaService) DescribeDatahubTask 

func (me *CkafkaService) DescribeDatahubTask(ctx context.Context, taskId string) (result *ckafka.DescribeDatahubTaskRes, errRet error)

func (*CkafkaService) DescribeInstanceById 

func (me *CkafkaService) DescribeInstanceById(ctx context.Context, instanceId string) (instanceInfo *ckafka.InstanceAttributesResponse, has bool, errRet error)

func (*CkafkaService) DescribeTopicById 

func (me *CkafkaService) DescribeTopicById(ctx context.Context, topicId string) (topicInfo *ckafka.TopicAttributesResponse, has bool, errRet error)

func (*CkafkaService) DescribeUserByFilter 

func (me *CkafkaService) DescribeUserByFilter(ctx context.Context, params map[string]interface{}) (userInfos []*ckafka.User, errRet error)

func (*CkafkaService) DescribeUserByUserId 

func (me *CkafkaService) DescribeUserByUserId(ctx context.Context, userId string) (userInfo *ckafka.User, has bool, errRet error)

func (*CkafkaService) ModifyCkafkaInstanceAttributes 

func (me *CkafkaService) ModifyCkafkaInstanceAttributes(ctx context.Context,
	request *ckafka.ModifyInstanceAttributesRequest) (errRet error)

func (*CkafkaService) ModifyCkafkaTopicAttribute 

func (me *CkafkaService) ModifyCkafkaTopicAttribute(ctx context.Context, request *ckafka.ModifyTopicAttributesRequest) (errRet error)

func (*CkafkaService) ModifyPassword 

func (me *CkafkaService) ModifyPassword(ctx context.Context, instanceId, user, oldPasswd, newPasswd string) (errRet error)

func (*CkafkaService) OperateStatusCheck 

func (me *CkafkaService) OperateStatusCheck(ctx context.Context, result *ckafka.JgwOperateResponse) (isSucceed bool)

func (*CkafkaService) RemoveCkafkaTopicIpWhiteList 

func (me *CkafkaService) RemoveCkafkaTopicIpWhiteList(ctx context.Context, instaneId string, topicName string, whiteIpList []*string) (errRet error)

Source Files

View all Source files

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.