| 89 | } |
| 90 | |
| 91 | func (op *Operator) SaveDoc(ctx context.Context, indexName string, id string, doc interface{}) (err error) { |
| 92 | log.Debugf("try to save doc to index: %s, %s", indexName, id) |
| 93 | _, err = op.C.Update().Index(indexName).Id(id).Refresh("false").DocAsUpsert(true).Doc(doc).Upsert(doc).Do(ctx) |
| 94 | if err != nil { |
| 95 | log.Errorf("save doc to index %s failed: %s", indexName, err.Error()) |
| 96 | return err |
| 97 | } |
| 98 | return nil |
| 99 | } |
| 100 | |
| 101 | func (op *Operator) DeleteDoc(ctx context.Context, indexName string, id string) (err error) { |
| 102 | log.Debugf("try to delete doc from index: %s, %s", indexName, id) |