dd

aiven · Sep 14, 2023 · 4fcd77f · 4fcd77f
1 parent 34fdb1b
commit 4fcd77f
Showing 1 changed file with 0 additions and 9 deletions.
diff --git a/internal/sdkprovider/service/kafkatopic/kafka_topic_cache.go b/internal/sdkprovider/service/kafkatopic/kafka_topic_cache.go
@@ -142,14 +142,6 @@ func (t *kafkaTopicCache) GetMissing(projectName, serviceName string) []string {
 	return t.missing[projectName+serviceName]
 }
 
-// GetFullQueue retrieves a topics queue
-func (t *kafkaTopicCache) GetFullQueue(projectName, serviceName string) []string {
-	t.RLock()
-	defer t.RUnlock()
-
-	return t.inQueue[projectName+serviceName]
-}
-
 // GetQueue retrieves a topics queue, retrieves up to 100 first elements
 func (t *kafkaTopicCache) GetQueue(projectName, serviceName string) []string {
 	t.RLock()
@@ -165,7 +157,6 @@ func (t *kafkaTopicCache) GetQueue(projectName, serviceName string) []string {
 // SetV1List sets v1 topics list
 func (t *kafkaTopicCache) SetV1List(projectName, serviceName string, list []*aiven.KafkaListTopic) {
 	t.Lock()
-	t.v1list[projectName+serviceName] = nil
 	for _, v := range list {
 		t.v1list[projectName+serviceName] = append(t.v1list[projectName+serviceName], v.TopicName)
 	}