MCPcopy Create free account

hub / github.com/Mongey/terraform-provider-kafka / functions

Functions236 in github.com/Mongey/terraform-provider-kafka

⨍ Functions 236◇ Types & classes 24
↓ 40 callersMethodSet
(key string, value interface{})
kafka/resource_kafka_acl.go:191
↓ 30 callersFunctioncfg
lintignore:AT004
kafka/resource_kafka_acl_test.go:280
↓ 20 callersMethodinit
()
kafka/lazy_client.go:19
↓ 20 callersFunctionoverrideProviderFactory
()
kafka/provider_test.go:38
↓ 17 callersFunctionassertEquals
(t *testing.T, expected any, actual any)
kafka/config_test.go:15
↓ 17 callersFunctiontestAccPreCheck
(t *testing.T)
kafka/provider_test.go:24
↓ 16 callersMethodString
()
kafka/kafka_quotas.go:29
↓ 13 callersMethodError
()
kafka/client.go:18
↓ 13 callersMethodReadTopic
(name string, refreshMetadata bool)
kafka/client.go:524
↓ 8 callersFunctionloadFile
(t *testing.T, file string)
kafka/config_test.go:163
↓ 7 callersMethodInvalidateACLCache
()
kafka/kafka_acls.go:435
↓ 7 callersMethodversionForKey
(apiKey, wantedMaxVersion int)
kafka/client.go:587
↓ 6 callersMethodID
()
kafka/kafka_quotas.go:35
↓ 6 callersMethodListACLs
()
kafka/kafka_acls.go:442
↓ 6 callersFunctionnewOauthbearerTokenProvider
(oauth2Config OAuth2Config)
kafka/config.go:63
↓ 5 callersMethodDescribeQuota
(entityType string, entityName string)
kafka/kafka_quotas.go:101
↓ 5 callersMethodToken
(ctx context.Context)
kafka/config.go:54
↓ 5 callersMethodgetDescribeAclsRequestAPIVersion
()
kafka/client.go:653
↓ 5 callersFunctionkafkaUserScramCredentialResource
()
kafka/resource_kafka_user_scram_credential.go:78
↓ 5 callersFunctionparseUserScramCredential
(d *schema.ResourceData)
kafka/resource_kafka_user_scram_credential.go:259
↓ 5 callersFunctionstringPtr
Helper function to create string pointers
kafka/topic_test.go:99
↓ 4 callersMethodDescribeUserScramCredential
(username string, mechanism string)
kafka/lazy_client.go:182
↓ 4 callersFunctionassertNil
(t *testing.T, actual any)
kafka/config_test.go:21
↓ 4 callersMethodcopyWithMaskedSensitiveValues
()
kafka/config.go:320
↓ 4 callersMethodisAWSMSKServerless
()
kafka/config.go:351
↓ 4 callersMethodnewKafkaConfig
()
kafka/config.go:131
↓ 3 callersFunctionACLOperationToString
ACLOperationToString converts sarama.AclOperations to a String representation
kafka/kafka_acls.go:340
↓ 3 callersFunctionACLPermissionTypeToString
ACLPermissionTypeToString converts sarama.AclPermissionTypes to Strings
kafka/kafka_acls.go:387
↓ 3 callersFunctionACLResourceToString
(in sarama.AclResourceType)
kafka/kafka_acls.go:287
↓ 3 callersMethodListACLs
()
kafka/lazy_client.go:142
↓ 3 callersFunctionNewClient
(config *Config)
kafka/client.go:58
↓ 3 callersMethodString
()
kafka/kafka_acls.go:30
↓ 3 callersFunctionaclInfo
(d *schema.ResourceData)
kafka/resource_kafka_acl.go:199
↓ 3 callersFunctioncfgs
lintignore:AT004
kafka/resource_kafka_quota_test.go:228
↓ 3 callersFunctiongetPasswordFromConfig
getPasswordFromConfig extracts password from either 'password' or 'password_wo' field, handling write-only fields by accessing raw config when necessa
kafka/resource_kafka_user_scram_credential.go:19
↓ 3 callersFunctionmetaToTopic
(d *schema.ResourceData, meta interface{})
kafka/topic.go:73
↓ 3 callersFunctionmigrateKafkaAclV0toV1
(is *terraform.InstanceState)
kafka/migrate_kafka_acl_state.go:20
↓ 3 callersFunctionnewTLSConfig
(clientCert, clientKey, caCert, clientKeyPassphrase string)
kafka/config.go:256
↓ 3 callersFunctionoverrideProvider
()
kafka/provider_test.go:46
↓ 3 callersFunctionparsePemOrLoadFromFile
(input string)
kafka/config.go:235
↓ 3 callersFunctionstrPtrMapToStrMap
TODO: can I just get rid of this?
kafka/utils.go:53
↓ 3 callersFunctiontestResourceTopic_checkSameMessages
(producedMessages []*sarama.ProducerMessage)
kafka/resource_kafka_topic_test.go:391
↓ 3 callersFunctiontestResourceUserScramCredentialCheck_writeOnlyInternal
(s *terraform.State, expectedVersion string, withIterations bool)
kafka/resource_kafka_user_scram_credential_test.go:203
↓ 2 callersMethodAlterQuota
(quota Quota, validateOnly bool)
kafka/kafka_quotas.go:42
↓ 2 callersMethodDeleteACL
(s StringlyTypedACL)
kafka/kafka_acls.go:172
↓ 2 callersMethodDone
()
kafka/scram_client.go:34
↓ 2 callersMethodEqual
(other Topic)
kafka/topic.go:18
↓ 2 callersFunctionMapEq
MapEq compares two maps, and checks that the keys and values are the same
kafka/utils.go:14
↓ 2 callersFunctionProvider
()
kafka/provider.go:10
↓ 2 callersMethodString
()
kafka/kafka_user_scram_credentials.go:19
↓ 2 callersMethodUpsertUserScramCredential
(userScramCredential UserScramCredential)
kafka/lazy_client.go:174
↓ 2 callersFunctionbootstrapServersFromEnv
()
kafka/provider_test.go:79
↓ 2 callersFunctionconfigToResources
(topic Topic, c *Config)
kafka/topic.go:49
↓ 2 callersFunctionconvertedScramMechanism
(scram_mechanism_string string)
kafka/resource_kafka_user_scram_credential.go:276
↓ 2 callersFunctiondTos
(key string, d *schema.ResourceData)
kafka/provider.go:259
↓ 2 callersMethodextractTopics
()
kafka/client.go:213
↓ 2 callersFunctionnewQuota
(d *schema.ResourceData, removeAll bool)
kafka/resource_kafka_quota.go:141
↓ 2 callersFunctionnonEmptyAndTrimmed
(bootstrapServers []string)
kafka/utils.go:35
↓ 2 callersFunctionstringToACLPrefix
(s string)
kafka/kafka_acls.go:105
↓ 2 callersFunctionstringToACLResource
(in string)
kafka/kafka_acls.go:267
↓ 2 callersFunctionstringToAclPermissionType
(in string)
kafka/kafka_acls.go:372
↓ 2 callersFunctionstringToOperation
(in string)
kafka/kafka_acls.go:307
↓ 2 callersFunctiontestAccCheckAclDestroy
(name string)
kafka/resource_kafka_acl_test.go:103
↓ 2 callersFunctiontestResourceUserScramCredentialCheck
(s *terraform.State, withIterations bool)
kafka/resource_kafka_user_scram_credential_test.go:252
↓ 2 callersFunctiontfToAclFilter
(s StringlyTypedACL)
kafka/kafka_acls.go:71
↓ 2 callersFunctionvalidateDiagFunc
(validateFunc func(interface{}, string) ([]string, []error))
kafka/utils.go:61
↓ 1 callersMethodAddPartitions
(t Topic)
kafka/client.go:335
↓ 1 callersMethodAlterReplicationFactor
(t Topic)
kafka/client.go:379
↓ 1 callersMethodCanAlterReplicationFactor
()
kafka/client.go:372
↓ 1 callersMethodCreateACL
(s StringlyTypedACL)
kafka/kafka_acls.go:246
↓ 1 callersMethodCreateTopic
(t Topic)
kafka/client.go:295
↓ 1 callersMethodDeleteTopic
(t string)
kafka/client.go:229
↓ 1 callersMethodDeleteUserScramCredential
(userScramCredential UserScramCredential)
kafka/lazy_client.go:190
↓ 1 callersMethodGetKafkaTopics
()
kafka/lazy_client.go:197
↓ 1 callersMethodIsReplicationFactorUpdating
(topic string)
kafka/client.go:490
↓ 1 callersFunctionNewTLSConfig
(clientCert, clientKey, caCert, clientKeyPassphrase string)
kafka/config.go:231
↓ 1 callersFunctionReplicaCount
ReplicaCount returns the replication_factor for a partition Returns an error if it cannot determine the count, or if the number of replicas is differe
kafka/topic.go:30
↓ 1 callersMethodSaramaClient
()
kafka/client.go:109
↓ 1 callersMethodUpdateTopic
(topic Topic)
kafka/client.go:264
↓ 1 callersFunctionaccTestProviderConfig
()
kafka/provider_test.go:63
↓ 1 callersMethodallReplicas
()
kafka/client.go:427
↓ 1 callersFunctionapiVersionsFromBroker
(broker *sarama.Broker, config *sarama.Config, ch chan<- []sarama.ApiVersionsResponseKey, errCh chan<- error)
kafka/client.go:156
↓ 1 callersFunctionassertNotNil
(t *testing.T, actual any)
kafka/config_test.go:25
↓ 1 callersMethodbuildAssignment
(t Topic)
kafka/client.go:398
↓ 1 callersFunctionbuildNewReplicas
(allReplicas *[]int32, usedReplicas *[]int32, deltaRF int16)
kafka/client.go:441
↓ 1 callersMethodcheckTLSConfig
()
kafka/lazy_client.go:44
↓ 1 callersFunctionclient
(broker, caLocation, clientCertLocation, clientKeyLocation string)
tls-debug/main.go:22
↓ 1 callersMethodenqueueCreateACL
(broker *sarama.Broker, create *sarama.AclCreation)
kafka/kafka_acls.go:192
↓ 1 callersMethodenqueueDeleteACL
(broker *sarama.Broker, filter *sarama.AclFilter)
kafka/kafka_acls.go:119
↓ 1 callersFunctionfauxMain
()
tls-debug/main.go:59
↓ 1 callersFunctionfindUnusedReplicas
(allReplicas *[]int32, usedReplicas *[]int32, extraCount int16)
kafka/client.go:473
↓ 1 callersFunctionflattenTopicsData
(topicList *[]Topic)
kafka/data_source_kafka_topics.go:65
↓ 1 callersFunctiongenerateRandomBytes
(n int)
kafka/kafka_user_scram_credentials.go:136
↓ 1 callersMethodgetCreateAclsRequestAPIVersion
()
kafka/client.go:657
↓ 1 callersMethodgetDeleteAclsRequestAPIVersion
()
kafka/client.go:661
↓ 1 callersMethodgetDescribeConfigAPIVersion
()
kafka/client.go:665
↓ 1 callersMethodgetKafkaTopics
()
kafka/client.go:669
↓ 1 callersFunctionisDefault
(tc *sarama.ConfigEntry, version int)
kafka/topic.go:64
↓ 1 callersFunctionisPartitionRFChanging
(status *sarama.PartitionReplicaReassignmentsStatus)
kafka/client.go:520
↓ 1 callersFunctionkafkaACLResource
()
kafka/resource_kafka_acl.go:14
next →1–100 of 236, ranked by callers