| 1117 | }() |
| 1118 | |
| 1119 | _, err := state.deltas.Flush(state.replicaCtx, conn, tx, reason) |
| 1120 | return err |
| 1121 | } |
| 1122 | |
| 1123 | func (r *LogicalReplicator) append(state *replicationState, relationID uint32, tuple []*pglogrepl.TupleDataColumn, actionType, eventType binlog.RowEventType, onlyKeys bool) error { |
| 1124 | rel, ok := state.relations[relationID] |
| 1125 | if !ok { |
| 1126 | return fmt.Errorf("unknown relation ID %d", relationID) |
| 1127 | } |
| 1128 | appender, err := state.deltas.GetDeltaAppender(rel.Namespace, rel.RelationName, state.schemas[relationID]) |
| 1129 | if err != nil { |