ckafka

package
v1.81.61 Latest Latest
Warning

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

 Go to latest Published: Dec 22, 2023 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 = COMMON_PAYTYPE_POSTPAID
	CKAFKA_CHARGE_TYPE_PREPAID  = COMMON_PAYTYPE_PREPAID
)
View Source 
const (
	POSTGRESQL_PAYTYPE_PREPAID  = "prepaid"
	POSTGRESQL_PAYTYPE_POSTPAID = "postpaid"
)
View Source 
const (
	COMMON_PAYTYPE_PREPAID  = "PREPAID"
	COMMON_PAYTYPE_POSTPAID = "POSTPAID_BY_HOUR"
)
View Source 
const (
	POSTGRESQL_DB_VERSION_9_3_5 = "9.3.5"
	POSTGRESQL_DB_VERSION_9_5_4 = "9.5.4"
	POSTGRESQL_DB_VERSION_10_4  = "10.4"
)
View Source 
const (
	POSTGRESQL_KERNEL_UPGRADE_IMMEDIATELY     = 0
	POSTGRESQL_KERNEL_UPGRADE_SPECIFIED_TIME  = 1
	POSTGRESQL_KERNEL_UPGRADE_MAINTAIN_WINDOW = 2
)
View Source 
const (
	POSTGRESQL_DB_CHARSET_UTF8   = "UTF8"
	POSTGRESQL_DB_CHARSET_LATIN1 = "LATIN1"
)
View Source 
const (
	POSTGRESQL_STAUTS_RUNNING  = "running"
	POSTGRESQL_STAUTS_ISOLATED = "isolated"
)
View Source 
const (
	SYNC_MODE_SEMI  = "Semi-sync"
	SYNC_MODE_ASYNC = "Async"
)
View Source 
const CkafkaFailedOperation = "FailedOperation"
View Source 
const CkafkaInstanceNotFound = "InvalidParameterValue.InstanceNotExist"

sdk ckafka not found error

View Source 
const DESCRIBE_TAGS_LIMIT = 20

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",
}
View Source 
var POSTGRESQL_DB_CHARSET = []string{POSTGRESQL_DB_CHARSET_UTF8, POSTGRESQL_DB_CHARSET_LATIN1}
View Source 
var POSTGRESQL_PAYTYPE = []string{COMMON_PAYTYPE_POSTPAID}
View Source 
var POSTGRESQL_RETRYABLE_STATUS = []string{
	"initing",
	"expanding",
	"switching",

	"deployment changing",
}
View Source 
var POSTSQL_DB_VERSION = []string{POSTGRESQL_DB_VERSION_9_3_5, POSTGRESQL_DB_VERSION_9_5_4, POSTGRESQL_DB_VERSION_10_4}
View Source 
var SYNC_MODE = []string{
	SYNC_MODE_SEMI,
	SYNC_MODE_ASYNC,
}

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)

type TagService 

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

func (*TagService) DeleteTagResourceById 

func (me *TagService) DeleteTagResourceById(ctx context.Context, tagKey string, tagValue string) (errRet error)

func (*TagService) DeleteTagTagAttachmentById 

func (me *TagService) DeleteTagTagAttachmentById(ctx context.Context, tagKey string, resource string) (errRet error)

func (*TagService) DescribeProjectById 

func (me *TagService) DescribeProjectById(ctx context.Context, projectId uint64) (project *tag.Project, disable *uint64, errRet error)

func (*TagService) DescribeProjects 

func (me *TagService) DescribeProjects(ctx context.Context, param map[string]interface{}) (project []*tag.Project, errRet error)

func (*TagService) DescribeResourceTags 

func (me *TagService) DescribeResourceTags(ctx context.Context, serviceType, resourceType, region, resourceId string) (tags map[string]string, err error)

func (*TagService) DescribeTagResourceById 

func (me *TagService) DescribeTagResourceById(ctx context.Context, tagKey string, tagValue string) (tagRes *tag.Tag, errRet error)

func (*TagService) DescribeTagTagAttachmentById 

func (me *TagService) DescribeTagTagAttachmentById(ctx context.Context, tagKey string, tagValue string, resource string) (resourceTag *tag.ResourceTagMapping, errRet error)

func (*TagService) DisableProjectById 

func (me *TagService) DisableProjectById(ctx context.Context, projectId uint64) (errRet error)

func (*TagService) ModifyTags 

func (me *TagService) ModifyTags(ctx context.Context, resourceName string, replaceTags map[string]string, deleteKeys []string) 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.