Documentation
¶
Index ¶
- type TableNameChanger
- func (c *TableNameChanger) LearnTableNameChange(destinationName, oldTableName string, schemaBytes []byte) error
- func (c TableNameChanger) UpdateTableName(destinationName string, oldTableName string) string
- func (c TableNameChanger) UpdateTableNames(destinationName string, tables map[string]bool) map[string]bool
- func (c TableNameChanger) UpdateTableNamesSlice(destinationName string, tables []string) []string
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type TableNameChanger ¶
type TableNameChanger struct {
// contains filtered or unexported fields
}
TableNameChanger manages table name changes due to transformers, on a per-destination basis. It can learn about table name changes and apply those changes on further steps.
func New ¶
func New(destinationSpecs []specs.Destination) *TableNameChanger
func (*TableNameChanger) LearnTableNameChange ¶
func (c *TableNameChanger) LearnTableNameChange(destinationName, oldTableName string, schemaBytes []byte) error
func (TableNameChanger) UpdateTableName ¶
func (c TableNameChanger) UpdateTableName(destinationName string, oldTableName string) string
func (TableNameChanger) UpdateTableNames ¶
func (TableNameChanger) UpdateTableNamesSlice ¶
func (c TableNameChanger) UpdateTableNamesSlice(destinationName string, tables []string) []string
Source Files
Click to show internal directories.
Click to hide internal directories.