commands

Documentation

Index

• Variables
• func IndexMongoToES(cliContext *cli.Context)

Variables

var Commands = cli.Commands{
	{
		Name:   "index",
		Usage:  "Index collection to elasticsearch",
		Action: IndexMongoToES,
		Flags: []cli.Flag{
			cli.StringFlag{
				Name:  "config",
				Value: "",
				Usage: "Configuration file path",
			},
			cli.IntFlag{
				Name:  "workers",
				Value: 2,
				Usage: "Number of workers to index the mongo collection",
			},
			cli.IntFlag{
				Name:  "bulk",
				Value: 1000,
				Usage: "Number of documents to index per bulk request",
			},
		},
	},
}

var (

	// Mongodb Query to filter document that will be indexed to elasticsearch
	// It's json formatted query
	// Elaticsearch Mapping in JSON format
	// see https://www.elastic.co/guide/en/elasticsearch/reference/current/mapping.html for more information
	// Done channel signal, main goroutines should exit
	Done = make(chan struct{})
)

Functions

func IndexMongoToES

func IndexMongoToES(cliContext *cli.Context)

Main Commands Function