mysql2elasticsearch

Aug 27, 2020

Changes in this version

+ func SetLogger(w io.Writer)

type SyncMySQLToElasticSearchOption

+ MaxQueueSize int

Aug 26, 2020

Changes in this version

type SyncMySQLToElasticSearch

+ func (this *SyncMySQLToElasticSearch) GetObjectValues(object interface{}) map[string]interface{}

Aug 26, 2020

Changes in this version

type SyncMySQLToElasticSearch

+ func (this *SyncMySQLToElasticSearch) SetOnPosSynced(onPostSynced func(name string, pos uint32, force bool))

Aug 26, 2020

Changes in this version

+ func IndexOf(data []string, element string) int

+ type DBDataTypeMapping struct

+ Field string

+ Index int

+ TableIndex int

+ Type reflect.Type

+ type ESQueueItem struct

+ Action string

+ Data interface{}

+ IndexName string

+ PrimaryKey string

+ type Queue struct

+ func NewQueue() *Queue

+ func (c *Queue) Dequeue() (interface{}, error)

+ func (c *Queue) Empty() bool

+ func (c *Queue) Enqueue(value interface{})

+ func (c *Queue) Size() int

+ type SyncMySQLToElasticSearch struct

+ func NewSyncMySQLToElasticSearch(addr, user, password, dbName, esAddr string, ...) (*SyncMySQLToElasticSearch, error)

+ func (this *SyncMySQLToElasticSearch) Init(addr, user, password, dbName, esAddr string, ...) error

+ func (this *SyncMySQLToElasticSearch) OnPosSynced(pos mysql.Position, set mysql.GTIDSet, force bool) error

+ func (this *SyncMySQLToElasticSearch) OnRow(rowsEvent *canal.RowsEvent) error

+ func (this *SyncMySQLToElasticSearch) RegisterTable(tableName string, tableStruct interface{}) error

+ func (this *SyncMySQLToElasticSearch) Sync() error

+ func (this *SyncMySQLToElasticSearch) SyncFrom(binlogFile string, binlogPosition uint32) error

+ func (this *SyncMySQLToElasticSearch) Syncer()

+ type SyncMySQLToElasticSearchOption struct

+ IndexNameSeparator string

+ QueueSize int