monstachemap

Documentation

Index

• func ConvertMapForJSON(m map[string]interface{}) map[string]interface{}
• func ConvertSliceForJSON(a []interface{}) []interface{}
• func EncodeBinData(bi Binary) string
• type Binary
  • func (bi Binary) MarshalJSON() ([]byte, error)
• type Decimal128
  • func (dec Decimal128) MarshalJSON() ([]byte, error)
• type MapperPluginInput
• type MapperPluginOutput
• type ProcessPluginInput
• type Time
  • func (t Time) MarshalJSON() ([]byte, error)

Functions

func ConvertMapForJSON

func ConvertMapForJSON(m map[string]interface{}) map[string]interface{}

func ConvertSliceForJSON

func ConvertSliceForJSON(a []interface{}) []interface{}

func EncodeBinData

func EncodeBinData(bi Binary) string

Types

type Binary

type Binary struct {
	primitive.Binary
}

func (Binary) MarshalJSON

func (bi Binary) MarshalJSON() ([]byte, error)

type Decimal128

type Decimal128 struct {
	primitive.Decimal128
}

func (Decimal128) MarshalJSON

func (dec Decimal128) MarshalJSON() ([]byte, error)

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
	MongoClient       *mongo.Client          // MongoDB driver client
	UpdateDescription map[string]interface{} // map describing changes to the document
}

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

MapperPluginOutput is the output of the Map function

type ProcessPluginInput

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
}

ProcessPluginInput is the input to the Process function

type Time

type Time struct {
	time.Time
}

func (Time) MarshalJSON

func (t Time) MarshalJSON() ([]byte, error)