core

package
v0.0.0-...-2247000 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 23, 2015 License: MIT Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var LastTs int64

last oplog document date

Functions

func Do

func Do(last_ts int64)

start the connection with mongodb and elasticsearch to sync data

func Listen

func Listen() *mgo.Iter

create a listener to oplog collection

func Start

func Start()

create file to control the data to sincronize

Types

type Esmsync

type Esmsync struct {
	Config struct {
		Force bool
	}
	Mongo         mongo.MongoConf
	Elasticsearch es.ElasticConf
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL