()
| 104 | } |
| 105 | |
| 106 | func generateSummaryTable() (*schema.Table, error) { |
| 107 | tableName := "cloudquery_sync_summaries" |
| 108 | t := schema.Tables{{ |
| 109 | Name: tableName, |
| 110 | Transform: transformers.TransformWithStruct( |
| 111 | &syncSummary{}, |
| 112 | // Already added as `_cq` internal columns |
| 113 | transformers.WithSkipFields("SyncTime", "SyncGroupID"), |
| 114 | ), |
| 115 | }} |
| 116 | if err := transformers.TransformTables(t); err != nil { |
| 117 | return nil, err |
| 118 | } |
| 119 | return t[0], nil |
| 120 | } |
| 121 | |
| 122 | func migrateSummaryTable(writeClient safeWriteClient, destTransformer *transformer.RecordTransformer, spec specs.Destination) error { |
| 123 | if !spec.SyncSummary { |
no outgoing calls