正在显示
1 个修改的文件
包含
1 行增加
和
1 行删除
@@ -93,7 +93,7 @@ func (idx *Index) ensureIndex(index string) error { | @@ -93,7 +93,7 @@ func (idx *Index) ensureIndex(index string) error { | ||
93 | } | 93 | } |
94 | 94 | ||
95 | createService := idx.client.CreateIndex(index) | 95 | createService := idx.client.CreateIndex(index) |
96 | - if err := fx.DoWithRetries(func() error { | 96 | + if err := fx.DoWithRetry(func() error { |
97 | // is it necessary to check the result? | 97 | // is it necessary to check the result? |
98 | _, err := createService.Do(context.Background()) | 98 | _, err := createService.Do(context.Background()) |
99 | return err | 99 | return err |
-
请 注册 或 登录 后发表评论