()
| 1615 | } |
| 1616 | |
| 1617 | func (e *Extractor) sendFullComplete() (err error) { |
| 1618 | dumpMsg, err := common.Encode(&common.DumpStatResult{ |
| 1619 | Coord: e.initialBinlogCoordinates, |
| 1620 | TableSpecs: e.tableSpecs, |
| 1621 | }) |
| 1622 | if err != nil { |
| 1623 | return err |
| 1624 | } |
| 1625 | if err := e.publish(fmt.Sprintf("%s_full_complete", e.subject), dumpMsg, 0); err != nil { |
| 1626 | return err |
| 1627 | } |
| 1628 | return nil |
| 1629 | } |
| 1630 | |
| 1631 | func (e *Extractor) Finish1() (err error) { |
| 1632 | // TODO shutdown job on error |