Method rollback

pgserver/logrepl/replication.go:452–464

(ctx *sql.Context)

}

func (r *LogicalReplicator) rollback(ctx *sql.Context) error {
	defer adapter.CloseTxn(ctx)
	txn := adapter.TryGetTxn(ctx)
	if txn == nil {
		return nil
	}
	err := txn.Rollback()
	if err != nil && !strings.Contains(err.Error(), "no transaction is active") {
		r.logger.Debugf("Failed to roll back transaction: %v", err)
		return err
	}
	return nil
}

func (r *LogicalReplicator) shutdown(ctx *sql.Context, state *replicationState) {
	r.mu.Lock()