fix lint failures

wso2 · Oct 21, 2024 · b05d4e8 · b05d4e8
1 parent a6c226b
commit b05d4e8
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/adapter/config/types.go b/adapter/config/types.go
@@ -543,7 +543,7 @@ type controlPlane struct {
 	SyncApisOnStartUp          bool
 	SendRevisionUpdate         bool
 	EnvironmentLabels          []string
-	ASBDataplaneTopics         []ASBDataplaneTopic `toml:"asbDataplaneTopics"`
+	ASBDataplaneTopics         []asbDataplaneTopic `toml:"asbDataplaneTopics"`
 	DynamicEnvironments        dynamicEnvironments
 	RetryInterval              time.Duration
 	SkipSSLVerification        bool
@@ -553,7 +553,7 @@ type controlPlane struct {
 	InitialFetch               initialFetch
 }
 
-type ASBDataplaneTopic struct {
+type asbDataplaneTopic struct {
 	Type                      string `toml:"type"`
 	TopicName                 string `toml:"topicName"`
 	ConnectionString          string `toml:"connectionString"`

diff --git a/adapter/pkg/messaging/azure_connection.go b/adapter/pkg/messaging/azure_connection.go
@@ -80,7 +80,7 @@ func InitiateBrokerConnectionAndValidate(connectionString string, topic string,
 		logger.LoggerMsg.Debugf("ASB client initialized for connection url: %s", maskSharedAccessKey(connectionString))
 
 		for j := 0; j < reconnectRetryCount || reconnectRetryCount == -1; j++ {
-			sub, err := RetrieveSubscriptionMetadataForTopic(connectionString, topic,
+			sub, err := retrieveSubscriptionMetadataForTopic(connectionString, topic,
 				clientOptions, componentName, subProps, reconnectInterval)
 			if err != nil {
 				logError(reconnectRetryCount, reconnectInterval, err)
@@ -101,7 +101,7 @@ func InitiateConsumer(sub *Subscription, consumerType string) {
 	go startBrokerConsumer(sub, consumerType)
 }
 
-func RetrieveSubscriptionMetadataForTopic(connectionString string, topicName string, clientOptions *asb.ClientOptions,
+func retrieveSubscriptionMetadataForTopic(connectionString string, topicName string, clientOptions *asb.ClientOptions,
 	componentName string, opts *admin.SubscriptionProperties, reconnectInterval time.Duration) (*Subscription, error) {
 	ctx, cancel := context.WithCancel(context.Background())
 	defer cancel()