(maybeSchema *common.SchemaContext, tableName string)
| 1686 | } |
| 1687 | |
| 1688 | func (b *BinlogReader) findCurrentTable(maybeSchema *common.SchemaContext, tableName string) *common.TableContext { |
| 1689 | if maybeSchema == nil { |
| 1690 | return nil |
| 1691 | } |
| 1692 | table, ok := maybeSchema.TableMap[tableName] |
| 1693 | if !ok { |
| 1694 | return nil |
| 1695 | } |
| 1696 | return table |
| 1697 | } |
| 1698 | |
| 1699 | func (b *BinlogReader) findTableConfig(maybeSchemaConfig *common.DataSource, tableName string) *common.Table { |
| 1700 | if nil == maybeSchemaConfig { |
no outgoing calls
no test coverage detected