monstachemap

Documentation

Index

• type MapperPluginInput
• type MapperPluginOutput
• type ProcessPluginInput

Types

type MapperPluginInput

type MapperPluginInput struct {
	Document   map[string]interface{} // the original document from MongoDB
	Database   string                 // the origin database in MongoDB
	Collection string                 // the origin collection in MongoDB
	Namespace  string                 // the entire namespace for the original document
	Operation  string                 // "i" for a insert or "u" for update
	Session    *mgo.Session           // MongoDB session handle
}

MapperPluginInput is the input to the Map function

type MapperPluginOutput

type MapperPluginOutput struct {
	Document        map[string]interface{} // an updated document to index into Elasticsearch
	Index           string                 // the name of the index to use
	Type            string                 // the document type
	Routing         string                 // the routing value to use
	Drop            bool                   // set to true to indicate that the document should not be indexed but removed
	Passthrough     bool                   // set to true to indicate the original document should be indexed unchanged
	Parent          string                 // the parent id to use
	Version         int64                  // the version of the document
	VersionType     string                 // the version type of the document (internal, external, external_gte)
	Pipeline        string                 // the pipeline to index with
	RetryOnConflict int                    // how many times to retry updates before failing
	Skip            bool                   // set to true to indicate the the document should be ignored
}

MapperPluginOutput is the output of the Map function

type ProcessPluginInput

type ProcessPluginInput struct {
	MapperPluginInput
	ElasticClient        *elastic.Client
	ElasticBulkProcessor *elastic.BulkProcessor
	Timestamp            bson.MongoTimestamp
}

ProcessPluginInput is the input to the Process function