From 4fcd77fc32522eba3a22ac589bbf5f1d5ab468b6 Mon Sep 17 00:00:00 2001 From: Ivan Savciuc Date: Thu, 14 Sep 2023 16:16:42 +0300 Subject: [PATCH] dd --- .../sdkprovider/service/kafkatopic/kafka_topic_cache.go | 9 --------- 1 file changed, 9 deletions(-) diff --git a/internal/sdkprovider/service/kafkatopic/kafka_topic_cache.go b/internal/sdkprovider/service/kafkatopic/kafka_topic_cache.go index f8b30635c..e2465684e 100644 --- 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) }