elastic

Documentation

Index

• func CreateEsIndexBody(mongoDoc *map[string]interface{}, esMapping *map[string]interface{}) map[string]interface{}
• func CreateMapping(doc map[string]interface{}) map[string]interface{}
• func SetupIndexAndMapping(esOptions mongoes.ESOptions) error
• type ElasticWorker
  • func NewElasticWorker(jobQueue chan elastic.BulkableRequest, numWorkers int) *ElasticWorker
  • func (w *ElasticWorker) DispatchWorkers() chan struct{}

Functions

func CreateEsIndexBody

func CreateEsIndexBody(mongoDoc *map[string]interface{}, esMapping *map[string]interface{}) map[string]interface{}

func CreateMapping

func CreateMapping(doc map[string]interface{}) map[string]interface{}

• CreateMapping create Elastic Search Mapping from mongodb collection Example of mapping input: "mapping": { "title": { "es_type": "text" }, "slug": { "es_type": "keyword" } }

  Example of mapping output "properties": { "title": { "type": "text" } "slug": { "type": "keyword" } }

func SetupIndexAndMapping

func SetupIndexAndMapping(esOptions mongoes.ESOptions) error

SetupIndexAndMapping will Delete Index and Create new Mapping Beware, this will delete your current index and create new mapping

Types

type ElasticWorker

type ElasticWorker struct {
	JobQueue   chan elastic.BulkableRequest
	NumWorkers int

	EsOptions    mongoes.ESOptions
	IndexResults int32
	// contains filtered or unexported fields
}

func NewElasticWorker

func NewElasticWorker(jobQueue chan elastic.BulkableRequest, numWorkers int) *ElasticWorker

func (*ElasticWorker) DispatchWorkers

func (w *ElasticWorker) DispatchWorkers() chan struct{}