Do sends the request with body to ES.

Close closes the River

DoBulk sends the bulk request to the ES.

DoRequest sends a request with body to ES.

IndexTypeBulk sends the bulk request for index and doc type.

NewRiver creates the River from config

Run syncs the data from MySQL and inserts to ES.

If id in toml file is none, get primary keys in one row and format them into a string, and PK must not be nil Else get the ID's column in one row and

Bulk sends the bulk request. only support parent in 'Bulk' related apis

CheckFilter checkers whether the field needs to be filtered.

CreateMapping creates a ES mapping.

Ctx returns the internal context for outside use.

Exists checks whether id exists or not.

Get gets the item by id.

NewClient creates the Cient with configuration.

NewConfig creates a Config from data.

get mysql field value and convert it to specific value to es

for insert and delete

Delete deletes the item by id.

DeleteIndex deletes the index.

GetMapping gets the mapping.

NewConfigWithFile creates a Config from file.

Update creates or updates the data

IndexBulk sends the bulk request for index.

this requires a parent setting in _mapping

UnmarshalText implementes TOML UnmarshalText