Update constants

Signed-off-by: pritamdas99 <[email protected]>
kubedb · Jul 17, 2024 · fee8fa0 · fee8fa0
1 parent c18134a
commit fee8fa0
Show file tree

Hide file tree

Showing 3 changed files with 16 additions and 13 deletions.
diff --git a/solr/api.go b/solr/api.go
@@ -12,8 +12,9 @@ const (
 	Action              = "action"
 	ActionBackup        = "BACKUP"
 	ActionRestore       = "RESTORE"
+	ActionCreate        = "CREATE"
 	ActionDeleteBackup  = "DELETEBACKUP"
-	BackupName          = "name"
+	Name                = "name"
 	Location            = "location"
 	Repository          = "repository"
 	Collection          = "collection"
@@ -23,6 +24,8 @@ const (
 	DeleteStatus        = "DELETESTATUS"
 	RequestStatus       = "REQUESTSTATUS"
 	RequestId           = "requestid"
+	NumShards           = "numShards"
+	ReplicationFactor   = "replicationFactor"
 )
 
 type SLClient interface {

diff --git a/solr/solrv8.go b/solr/solrv8.go
@@ -56,10 +56,10 @@ func (sc *SLClientV8) CreateCollection() (*Response, error) {
 	req := sc.Client.R().SetDoNotParseResponse(true)
 	req.SetHeader("Content-Type", "application/json")
 	params := map[string]string{
-		"action":            "CREATE",
-		"name":              writeCollectionName,
-		"numShards":         "1",
-		"replicationFactor": "1",
+		Action:            ActionCreate,
+		Name:              writeCollectionName,
+		NumShards:         "1",
+		ReplicationFactor: "1",
 	}
 
 	req.SetQueryParams(params)
@@ -131,7 +131,7 @@ func (sc *SLClientV8) BackupCollection(ctx context.Context, collection string, b
 	req.SetHeader("Content-Type", "application/json")
 	params := map[string]string{
 		Action:     ActionBackup,
-		BackupName: backupName,
+		Name:       backupName,
 		Collection: collection,
 		Location:   location,
 		Repository: repository,
@@ -160,7 +160,7 @@ func (sc *SLClientV8) RestoreCollection(ctx context.Context, collection string,
 	req.SetHeader("Content-Type", "application/json")
 	params := map[string]string{
 		Action:     ActionRestore,
-		BackupName: backupName,
+		Name:       backupName,
 		Location:   location,
 		Collection: collection,
 		Repository: repository,
@@ -240,7 +240,7 @@ func (sc *SLClientV8) DeleteBackup(ctx context.Context, backupName string, colle
 	}
 	params := map[string]string{
 		Action:     ActionDeleteBackup,
-		BackupName: backupName,
+		Name:       backupName,
 		Location:   location,
 		Repository: repository,
 		BackupId:   strconv.Itoa(backupId),
@@ -272,7 +272,7 @@ func (sc *SLClientV8) PurgeBackup(ctx context.Context, backupName string, collec
 	}
 	params := map[string]string{
 		Action:      ActionDeleteBackup,
-		BackupName:  backupName,
+		Name:        backupName,
 		Location:    location,
 		Repository:  repository,
 		PurgeUnused: "true",

diff --git a/solr/solrv9.go b/solr/solrv9.go
@@ -135,7 +135,7 @@ func (sc *SLClientV9) BackupCollection(ctx context.Context, collection string, b
 	req.SetHeader("Content-Type", "application/json")
 	backupParams := map[string]string{
 		Action:     ActionBackup,
-		BackupName: backupName,
+		Name:       backupName,
 		Collection: collection,
 		Location:   location,
 		Repository: repository,
@@ -163,7 +163,7 @@ func (sc *SLClientV9) RestoreCollection(ctx context.Context, collection string,
 	req.SetHeader("Content-Type", "application/json")
 	restoreParams := map[string]string{
 		Action:     ActionRestore,
-		BackupName: backupName,
+		Name:       backupName,
 		Location:   location,
 		Collection: collection,
 		Repository: repository,
@@ -232,7 +232,7 @@ func (sc *SLClientV9) DeleteBackup(ctx context.Context, backupName string, colle
 	}
 	params := map[string]string{
 		Action:     ActionDeleteBackup,
-		BackupName: backupName,
+		Name:       backupName,
 		Location:   location,
 		Repository: repository,
 		BackupId:   strconv.Itoa(backupId),
@@ -264,7 +264,7 @@ func (sc *SLClientV9) PurgeBackup(ctx context.Context, backupName string, collec
 	}
 	params := map[string]string{
 		Action:      ActionDeleteBackup,
-		BackupName:  backupName,
+		Name:        backupName,
 		Location:    location,
 		Repository:  repository,
 		PurgeUnused: "true",