Skip to content
Snippets Groups Projects

Initial implementation of an elasticsearch indexer in Go

Merged Nick Thomas requested to merge 1-initial-implementation into master
All threads resolved!
4 files
+ 31
34
Compare changes
  • Side-by-side
  • Inline
Files
4
+ 0
26
@@ -84,29 +84,3 @@ func NewClient(config *Config) (*Client, error) {
func (c *Client) Flush() error {
return c.bulk.Flush()
}
func (c *Client) CreateIndex(indexName, mapping string) error {
createIndex, err := c.client.CreateIndex(indexName).BodyString(mapping).Do(context.Background())
if err != nil {
return err
}
if !createIndex.Acknowledged {
return timeoutError
}
return nil
}
func (c *Client) DeleteIndex(indexName string) error {
deleteIndex, err := c.client.DeleteIndex(indexName).Do(context.Background())
if err != nil {
return err
}
if !deleteIndex.Acknowledged {
return timeoutError
}
return nil
}
Loading