monstachemap

type Binary struct {
	primitive.Binary
}

type Decimal128 struct {
	primitive.Decimal128
}

type InitPluginInput struct {
	// ElasticClient is elasticsearch client.
	ElasticClient *elastic.Client

	// ElasticBulkProcessor is elasticsearch processor for indexing in bulk.
	ElasticBulkProcessor *elastic.BulkProcessor

	// MongoClient is mongodb client.
	MongoClient *mongo.Client
}

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
	MongoClient          *mongo.Client          // MongoDB driver client
	ElasticClient        *elastic.Client        // Elasticsearch driver client
	ElasticBulkProcessor *elastic.BulkProcessor // Elasticsearch processor for indexing in bulk
	UpdateDescription    map[string]interface{} // map describing changes to the document
}

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
	ID              string                 // override the _id of the indexed document; not recommended
}

type ProcessPluginInput struct {
	MapperPluginInput
	ElasticClient        *elastic.Client        // Elasticsearch driver client
	ElasticBulkProcessor *elastic.BulkProcessor // Elasticsearch processor for indexing in bulk
	Timestamp            primitive.Timestamp    // the timestamp of the event from the oplog
}

type Time struct {
	time.Time
}