@@ -124,7 +124,7 @@ func (d *db) Status() error {
124124 d .metrics .RecordErrorCnt (egressTarget )
125125 msg := fmt .Sprintf ("Connectivity check using DescribeTable failed. Error: '%v'" , err .Error ())
126126 log .Errorf (msg )
127- return fmt .Errorf (msg )
127+ return fmt .Errorf ("%s" , msg )
128128 }
129129
130130 return nil
@@ -151,7 +151,7 @@ func (d *db) GetCluster(name string) (*registryv1.Cluster, error) {
151151 if err != nil {
152152 msg := fmt .Sprintf ("Cannot get cluster '%s' from the database. Error: '%v'" , name , err .Error ())
153153 log .Errorf (msg )
154- return nil , fmt .Errorf (msg )
154+ return nil , fmt .Errorf ("%s" , msg )
155155 }
156156
157157 if resp .Item == nil {
@@ -164,7 +164,7 @@ func (d *db) GetCluster(name string) (*registryv1.Cluster, error) {
164164 if err != nil {
165165 msg := fmt .Sprintf ("Cannot unmarshal cluster '%s': '%v'" , name , err .Error ())
166166 log .Errorf (msg )
167- return nil , fmt .Errorf (msg )
167+ return nil , fmt .Errorf ("%s" , msg )
168168 }
169169
170170 return clusterDb .Cluster , err
@@ -199,7 +199,7 @@ func (d *db) ListClusters(offset int, limit int, region string, environment stri
199199 if err != nil {
200200 msg := fmt .Sprintf ("Error converting lastUpdated parameter to RFC3339: '%v'." , err )
201201 log .Errorf (msg )
202- return nil , 0 , false , fmt .Errorf (msg )
202+ return nil , 0 , false , fmt .Errorf ("%s" , msg )
203203 }
204204 filter = filter .And (expression .Name ("lastUpdatedUnix" ).GreaterThanEqual (expression .Value (t .Unix ())))
205205 }
@@ -209,8 +209,8 @@ func (d *db) ListClusters(offset int, limit int, region string, environment stri
209209
210210 if err != nil {
211211 msg := fmt .Sprintf ("Building dynamodb query expersion failed: '%v'." , err )
212- log .Errorf (msg )
213- return nil , 0 , false , fmt .Errorf (msg )
212+ log .Errorf ("%s" , msg )
213+ return nil , 0 , false , fmt .Errorf ("%s" , msg )
214214 }
215215
216216 queryInput = & dynamodb.QueryInput {
@@ -233,7 +233,7 @@ func (d *db) ListClusters(offset int, limit int, region string, environment stri
233233 if err != nil {
234234 msg := fmt .Sprintf ("DynamonDB API query call failed: '%v'." , err .Error ())
235235 log .Errorf (msg )
236- return nil , 0 , false , fmt .Errorf (msg )
236+ return nil , 0 , false , fmt .Errorf ("%s" , msg )
237237 }
238238
239239 for _ , i := range result .Items {
@@ -243,7 +243,7 @@ func (d *db) ListClusters(offset int, limit int, region string, environment stri
243243 if err != nil {
244244 msg := fmt .Sprintf ("Error when trying to unmarshal cluster: '%v'." , err .Error ())
245245 log .Errorf (msg )
246- return nil , 0 , false , fmt .Errorf (msg )
246+ return nil , 0 , false , fmt .Errorf ("%s" , msg )
247247 }
248248 clusters = append (clusters , * item .Cluster )
249249 }
@@ -283,7 +283,7 @@ func (d *db) ListClustersWithFilter(offset int, limit int, filter *DynamoDBFilte
283283 if err != nil {
284284 msg := fmt .Sprintf ("Building dynamodb scan expersion failed: '%v'." , err )
285285 log .Errorf (msg )
286- return nil , 0 , false , fmt .Errorf (msg )
286+ return nil , 0 , false , fmt .Errorf ("%s" , msg )
287287 }
288288
289289 scanInput = & dynamodb.ScanInput {
@@ -305,7 +305,7 @@ func (d *db) ListClustersWithFilter(offset int, limit int, filter *DynamoDBFilte
305305 if err != nil {
306306 msg := fmt .Sprintf ("DynamoDB API scan call failed: '%v'." , err .Error ())
307307 log .Errorf (msg )
308- return nil , 0 , false , fmt .Errorf (msg )
308+ return nil , 0 , false , fmt .Errorf ("%s" , msg )
309309 }
310310
311311 for _ , i := range result .Items {
@@ -315,7 +315,7 @@ func (d *db) ListClustersWithFilter(offset int, limit int, filter *DynamoDBFilte
315315 if err != nil {
316316 msg := fmt .Sprintf ("Error when trying to unmarshal cluster: '%v'." , err .Error ())
317317 log .Errorf (msg )
318- return nil , 0 , false , fmt .Errorf (msg )
318+ return nil , 0 , false , fmt .Errorf ("%s" , msg )
319319 }
320320 clusters = append (clusters , * item .Cluster )
321321 }
@@ -347,7 +347,7 @@ func (d *db) PutCluster(cluster *registryv1.Cluster) error {
347347 if err != nil {
348348 msg := fmt .Sprintf ("Error converting lastUpdated parameter to RFC3339 for cluster %s: '%v'." , cluster .Spec .Name , err )
349349 log .Errorf (msg )
350- return fmt .Errorf (msg )
350+ return fmt .Errorf ("%s" , msg )
351351 }
352352
353353 existingCluster , _ := d .GetCluster (cluster .Spec .Name )
@@ -369,7 +369,7 @@ func (d *db) PutCluster(cluster *registryv1.Cluster) error {
369369 if err != nil {
370370 msg := fmt .Sprintf ("Cannot marshal cluster '%s' into AttributeValue map." , cluster .Spec .Name )
371371 log .Errorf (msg )
372- return fmt .Errorf (msg )
372+ return fmt .Errorf ("%s" , msg )
373373 }
374374
375375 params := & dynamodb.PutItemInput {
@@ -387,7 +387,7 @@ func (d *db) PutCluster(cluster *registryv1.Cluster) error {
387387 if err != nil {
388388 msg := fmt .Sprintf ("Cluster '%s' cannot be updated or created in the database. Error: '%v'" , cluster .Spec .Name , err .Error ())
389389 log .Errorf (msg )
390- return fmt .Errorf (msg )
390+ return fmt .Errorf ("%s" , msg )
391391 }
392392
393393 log .Infof ("Cluster '%s' updated." , cluster .Spec .Name )
@@ -416,7 +416,7 @@ func (d *db) DeleteCluster(name string) error {
416416 if err != nil {
417417 msg := fmt .Sprintf ("Error while deleting cluster %s from db: %v" , name , err .Error ())
418418 log .Errorf (msg )
419- return fmt .Errorf (msg )
419+ return fmt .Errorf ("%s" , msg )
420420 }
421421
422422 log .Infof ("Cluster %s deleted." , name )
@@ -462,7 +462,7 @@ func (d *db) ListClustersWithServiceAndFilter(serviceId string, offset int, limi
462462 if err != nil {
463463 msg := fmt .Sprintf ("Failed to list clusters with filter: '%v'." , err )
464464 log .Errorf (msg )
465- return nil , 0 , false , fmt .Errorf (msg )
465+ return nil , 0 , false , fmt .Errorf ("%s" , msg )
466466 }
467467
468468 var clustersWithService []registryv1.Cluster
0 commit comments