Skip to content

Commit 1f8f7d6

Browse files
[refactor]: use slices.Contains to simplify code
Signed-off-by: claudecodering <[email protected]>
1 parent 528476f commit 1f8f7d6

File tree

2 files changed

+9
-9
lines changed

2 files changed

+9
-9
lines changed

internal/storage/elasticsearch/client/index_client.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -223,11 +223,11 @@ func (i *IndicesClient) IndexExists(index string) (bool, error) {
223223
}
224224

225225
func (*IndicesClient) aliasesString(aliases []Alias) string {
226-
concatAliases := ""
226+
var concatAliases strings.Builder
227227
for _, alias := range aliases {
228-
concatAliases += fmt.Sprintf("[index: %s, alias: %s],", alias.Index, alias.Name)
228+
concatAliases.WriteString(fmt.Sprintf("[index: %s, alias: %s],", alias.Index, alias.Name))
229229
}
230-
return strings.Trim(concatAliases, ",")
230+
return strings.Trim(concatAliases.String(), ",")
231231
}
232232

233233
func (i *IndicesClient) aliasAction(action string, aliases []Alias) error {

internal/storage/integration/es_index_cleaner_test.go

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -221,23 +221,23 @@ func createEsIndices(client *elastic.Client, indices []string) error {
221221
}
222222

223223
func runEsCleaner(days int, envs []string) error {
224-
var dockerEnv string
224+
var dockerEnv strings.Builder
225225
for _, e := range envs {
226-
dockerEnv += " -e " + e
226+
dockerEnv.WriteString(" -e " + e)
227227
}
228-
args := fmt.Sprintf("docker run %s --rm --net=host %s %d http://%s", dockerEnv, indexCleanerImage, days, queryHostPort)
228+
args := fmt.Sprintf("docker run %s --rm --net=host %s %d http://%s", dockerEnv.String(), indexCleanerImage, days, queryHostPort)
229229
cmd := exec.Command("/bin/sh", "-c", args)
230230
out, err := cmd.CombinedOutput()
231231
fmt.Println(string(out))
232232
return err
233233
}
234234

235235
func runEsRollover(action string, envs []string, adaptiveSampling bool) error {
236-
var dockerEnv string
236+
var dockerEnv strings.Builder
237237
for _, e := range envs {
238-
dockerEnv += " -e " + e
238+
dockerEnv.WriteString(" -e " + e)
239239
}
240-
args := fmt.Sprintf("docker run %s --rm --net=host %s %s --adaptive-sampling=%t http://%s", dockerEnv, rolloverImage, action, adaptiveSampling, queryHostPort)
240+
args := fmt.Sprintf("docker run %s --rm --net=host %s %s --adaptive-sampling=%t http://%s", dockerEnv.String(), rolloverImage, action, adaptiveSampling, queryHostPort)
241241
cmd := exec.Command("/bin/sh", "-c", args)
242242
out, err := cmd.CombinedOutput()
243243
fmt.Println(string(out))

0 commit comments

Comments
 (0)