adaptor

type Config map[string]interface{}

type Elasticsearch struct {
	// contains filtered or unexported fields
}

type ErrAdaptor struct {
	// contains filtered or unexported fields
}

type Error struct {
	Lvl    ErrorLevel
	Str    string
	Path   string
	Record interface{}
}

type ErrorLevel int

type File struct {
	// contains filtered or unexported fields
}

type FileConfig struct {
	// URI pointing to the resource.  We only recognize file:// and stdout:// currently
	URI string `json:"uri" doc:"the uri to connect to, ie stdout://, file:///tmp/output"`
}

type Mongodb struct {
	// contains filtered or unexported fields
}

type MongodbConfig struct {
	URI       string     `json:"uri" doc:"the uri to connect to, in the form mongodb://user:password@host.com:27017/auth_database"`
	Namespace string     `json:"namespace" doc:"mongo namespace to read/write"`
	Ssl       *SslConfig `json:"ssl,omitempty" doc:"ssl options for connection"`
	Timeout   string     `json:timeout" doc:"timeout for establishing connection, format must be parsable by time.ParseDuration and defaults to 10s"`
	Debug     bool       `json:"debug" doc:"display debug information"`
	Tail      bool       `json:"tail" doc:"if tail is true, then the mongodb source will tail the oplog after copying the namespace"`
	Wc        int        `` /* 143-byte string literal not displayed */
	FSync     bool       `json:"fsync" doc:"When writing, should we flush to disk before returning success"`
	Bulk      bool       `json:"bulk" doc:"use a buffer to bulk insert documents"`
}

type Registry map[string]RegistryEntry

type RegistryEntry struct {
	Name        string
	Description string
	Constructor func(*pipe.Pipe, string, Config) (StopStartListener, error)
	Config      interface{}
}

type Rethinkdb struct {
	// contains filtered or unexported fields
}

type SslConfig struct {
	CaCerts []string `json:"cacerts,omitempty" doc:"array of root CAs to use in order to verify the server certificates"`
}

type StopStartListener interface {
	Start() error
	Listen() error
	Stop() error
}

type SyncDoc struct {
	Doc        map[string]interface{}
	Collection string
}

type Transformer struct {
	// contains filtered or unexported fields
}

type TransformerConfig struct {
	// file containing transformer javascript
	// must define a module.exports = function(doc) { .....; return doc }
	Filename  string `json:"filename" doc:"the filename containing the javascript transform fn"`
	Namespace string `json:"namespace" doc:"namespace to transform"`

	// verbose output
	Debug bool `json:"debug" doc:"display debug information"` // debug mode
}